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 nettyorg.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 void
StreamSession. messageReceived(StreamMessage message)
void
StreamingMessageSender. sendMessage(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 void
NettyStreamingMessageSender. sendMessage(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 serializerSubclasses 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 whereStreamSession
is started, to initiate correspondingStreamSession
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, DataOutputStreamPlus out, int version, StreamSession session)
static long
StreamMessage. serializedSize(StreamMessage message, int version)
-