Uses of Class
org.apache.cassandra.streaming.messages.StreamMessage

Packages that use StreamMessage

Package	Description
org.apache.cassandra.streaming
org.apache.cassandra.streaming.async	Non-blocking streaming with netty
org.apache.cassandra.streaming.messages

Uses of StreamMessage in org.apache.cassandra.streaming

Methods in org.apache.cassandra.streaming with parameters of type StreamMessage

Modifier and Type	Method	Description
StreamSession	StreamDeserializingTask.deriveSession(StreamMessage message)
void	StreamSession.messageReceived(StreamMessage message)
protected io.netty.util.concurrent.Future<?>	StreamSession.sendControlMessage(StreamMessage message)

Uses of StreamMessage in org.apache.cassandra.streaming.async

Methods in org.apache.cassandra.streaming.async with parameters of type StreamMessage

Modifier and Type	Method	Description
io.netty.util.concurrent.Future<?>	StreamingMultiplexedChannel.sendControlMessage(StreamMessage message)
io.netty.util.concurrent.Future<?>	StreamingMultiplexedChannel.sendMessage(StreamingChannel channel, StreamMessage message)

Uses of StreamMessage in org.apache.cassandra.streaming.messages

Classes in org.apache.cassandra.streaming.messages with type parameters of type StreamMessage

Modifier and Type	Interface	Description
static interface	StreamMessage.Serializer<V extends StreamMessage>	StreamMessage serializer

Subclasses of StreamMessage in org.apache.cassandra.streaming.messages

Modifier and Type	Class	Description
class	CompleteMessage
class	IncomingStreamMessage
class	KeepAliveMessage
class	OutgoingStreamMessage
class	PrepareAckMessage
class	PrepareSynAckMessage
class	PrepareSynMessage
class	ReceivedMessage
class	SessionFailedMessage
class	StreamInitMessage	StreamInitMessage is first sent from the node where StreamSession is started, to initiate corresponding StreamSession on the other side.

Fields in org.apache.cassandra.streaming.messages with type parameters of type StreamMessage

Modifier and Type	Field	Description
StreamMessage.Serializer<StreamMessage>	StreamMessage.Type.inSerializer
StreamMessage.Serializer<StreamMessage>	StreamMessage.Type.outSerializer

Methods in org.apache.cassandra.streaming.messages that return StreamMessage

Modifier and Type	Method	Description
static StreamMessage	StreamMessage.deserialize(DataInputPlus in, int version)

Methods in org.apache.cassandra.streaming.messages with parameters of type StreamMessage

Modifier and Type	Method	Description
static void	StreamMessage.serialize(StreamMessage message, StreamingDataOutputPlus out, int version, StreamSession session)
static long	StreamMessage.serializedSize(StreamMessage message, int version)