Package org.apache.cassandra.streaming.async

Class NettyStreamingChannel

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

org.apache.cassandra.streaming.async.NettyStreamingChannel

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, StreamingChannel

public class NettyStreamingChannel
extends io.netty.channel.ChannelInboundHandlerAdapter
implements StreamingChannel

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Nested classes/interfaces inherited from interface org.apache.cassandra.streaming.StreamingChannel

StreamingChannel.Factory, StreamingChannel.Kind, StreamingChannel.Send

Constructor Summary

Constructors

Constructor	Description
NettyStreamingChannel(int messagingVersion, io.netty.channel.Channel channel, StreamingChannel.Kind kind)

Method Summary

Modifier and Type	Method	Description
StreamingDataOutputPlus	acquireOut()	until closed, cannot invoke StreamingChannel.send(Send)
void	channelInactive(io.netty.channel.ChannelHandlerContext ctx)
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object message)
io.netty.util.concurrent.Future<?>	close()
boolean	connected()
java.net.InetSocketAddress	connectedTo()
java.lang.String	description()
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, java.lang.Throwable cause)
java.lang.Object	id()
StreamingDataInputPlus	in()
void	onClose(java.lang.Runnable runOnClose)
java.net.InetSocketAddress	peer()
Future<?>	send(StreamingChannel.Send send)
static void	shutdown()	Shutdown for in-JVM tests.
static void	trackInboundHandlers()

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

NettyStreamingChannel

public NettyStreamingChannel(int messagingVersion,
                             io.netty.channel.Channel channel,
                             StreamingChannel.Kind kind)

Method Detail

id

public java.lang.Object id()

Specified by:

id in interface StreamingChannel

description

public java.lang.String description()

Specified by:

description in interface StreamingChannel

peer

public java.net.InetSocketAddress peer()

Specified by:

peer in interface StreamingChannel

connectedTo

public java.net.InetSocketAddress connectedTo()

Specified by:

connectedTo in interface StreamingChannel

connected

public boolean connected()

Specified by:

connected in interface StreamingChannel

in

public StreamingDataInputPlus in()

Specified by:

in in interface StreamingChannel

acquireOut

public StreamingDataOutputPlus acquireOut()

Description copied from interface: StreamingChannel

until closed, cannot invoke StreamingChannel.send(Send)

Specified by:

acquireOut in interface StreamingChannel

send

public Future<?> send(StreamingChannel.Send send)

Specified by:

send in interface StreamingChannel

close

public io.netty.util.concurrent.Future<?> close()

Specified by:

close in interface StreamingChannel

onClose

public void onClose(java.lang.Runnable runOnClose)

Specified by:

onClose in interface StreamingChannel

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        java.lang.Object message)

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

channelInactive

public void channelInactive(io.netty.channel.ChannelHandlerContext ctx)

Specified by:

channelInactive in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class io.netty.channel.ChannelInboundHandlerAdapter

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
                            java.lang.Throwable cause)

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class io.netty.channel.ChannelInboundHandlerAdapter

shutdown

public static void shutdown()

Shutdown for in-JVM tests. For any other usage, tracking of active inbound streaming handlers should be revisted first and in-JVM shutdown refactored with it. This does not prevent new inbound handlers being added after shutdown, nor is not thread-safe around new inbound handlers being opened during shutdown.

trackInboundHandlers

public static void trackInboundHandlers()