|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Message in org.apache.cassandra.db |
---|
Methods in org.apache.cassandra.db that return Message | |
---|---|
Message |
RangeSliceCommand.getMessage()
|
Message |
RangeSliceReply.getReply(Message originalMessage)
|
Message |
ReadCommand.makeReadMessage()
|
Message |
RowMutation.makeRowMutationMessage()
|
Message |
RowMutationMessage.makeRowMutationMessage()
|
Message |
RowMutation.makeRowMutationMessage(StorageService.Verb verb)
|
Message |
RowMutationMessage.makeRowMutationMessage(StorageService.Verb verb)
|
static Message |
WriteResponse.makeWriteResponseMessage(Message original,
WriteResponse writeResponseMessage)
|
Methods in org.apache.cassandra.db with parameters of type Message | |
---|---|
void |
BinaryVerbHandler.doVerb(Message message)
|
void |
ReadRepairVerbHandler.doVerb(Message message)
|
void |
ReadVerbHandler.doVerb(Message message)
|
void |
RowMutationVerbHandler.doVerb(Message message)
|
Message |
RangeSliceReply.getReply(Message originalMessage)
|
static Message |
WriteResponse.makeWriteResponseMessage(Message original,
WriteResponse writeResponseMessage)
|
static RangeSliceCommand |
RangeSliceCommand.read(Message message)
|
Uses of Message in org.apache.cassandra.dht |
---|
Methods in org.apache.cassandra.dht with parameters of type Message | |
---|---|
void |
BootStrapper.BootstrapTokenVerbHandler.doVerb(Message message)
|
Uses of Message in org.apache.cassandra.gms |
---|
Methods in org.apache.cassandra.gms with parameters of type Message | |
---|---|
void |
GossipDigestAck2VerbHandler.doVerb(Message message)
|
void |
GossipDigestAckVerbHandler.doVerb(Message message)
|
void |
GossipDigestSynVerbHandler.doVerb(Message message)
|
void |
GossiperJoinVerbHandler.doVerb(Message message)
|
Uses of Message in org.apache.cassandra.net |
---|
Methods in org.apache.cassandra.net that return Message | |
---|---|
Message |
Message.getReply(java.net.InetAddress from,
byte[] args)
|
Methods in org.apache.cassandra.net with parameters of type Message | |
---|---|
void |
IVerbHandler.doVerb(Message message)
This method delivers a message to the implementing class (if the implementing class was registered by a call to MessagingService.registerVerbHandlers). |
void |
ResponseVerbHandler.doVerb(Message message)
|
static OutboundTcpConnection |
MessagingService.getConnection(java.net.InetAddress to,
Message msg)
|
static void |
MessagingService.receive(Message message)
|
void |
IAsyncCallback.response(Message msg)
|
void |
IAsyncResult.result(Message result)
Store the result obtained for the submitted task. |
void |
MessagingService.sendOneWay(Message message,
java.net.InetAddress to)
Send a message to a given endpoint. |
java.lang.String |
MessagingService.sendRR(Message[] messages,
java.net.InetAddress[] to,
IAsyncCallback cb)
Send a message to a given endpoint. |
IAsyncResult |
MessagingService.sendRR(Message message,
java.net.InetAddress to)
|
java.lang.String |
MessagingService.sendRR(Message message,
java.net.InetAddress[] to,
IAsyncCallback cb)
Send a message to a given endpoint. |
java.lang.String |
MessagingService.sendRR(Message message,
java.net.InetAddress to,
IAsyncCallback cb)
Send a message to a given endpoint. |
Constructors in org.apache.cassandra.net with parameters of type Message | |
---|---|
MessageDeliveryTask(Message message)
|
Uses of Message in org.apache.cassandra.net.sink |
---|
Methods in org.apache.cassandra.net.sink that return Message | |
---|---|
Message |
IMessageSink.handleMessage(Message message)
|
static Message |
SinkManager.processClientMessageSink(Message message)
|
static Message |
SinkManager.processServerMessageSink(Message message)
|
Methods in org.apache.cassandra.net.sink with parameters of type Message | |
---|---|
Message |
IMessageSink.handleMessage(Message message)
|
static Message |
SinkManager.processClientMessageSink(Message message)
|
static Message |
SinkManager.processServerMessageSink(Message message)
|
Uses of Message in org.apache.cassandra.service |
---|
Fields in org.apache.cassandra.service with type parameters of type Message | |
---|---|
protected java.util.Collection<Message> |
QuorumResponseHandler.responses
|
protected java.util.Collection<Message> |
WriteResponseHandler.responses
|
Methods in org.apache.cassandra.service with parameters of type Message | |
---|---|
void |
AntiEntropyService.TreeRequestVerbHandler.doVerb(Message message)
Trigger a validation compaction which will return the tree upon completion. |
void |
AntiEntropyService.TreeResponseVerbHandler.doVerb(Message message)
|
void |
RangeSliceVerbHandler.doVerb(Message message)
|
void |
ReadResponseResolver.injectPreProcessed(Message message,
ReadResponse result)
hack so ConsistencyChecker doesn't have to serialize/deserialize an extra real Message |
void |
IResponseResolver.preprocess(Message message)
|
void |
RangeSliceResponseResolver.preprocess(Message message)
|
void |
ReadResponseResolver.preprocess(Message message)
|
void |
QuorumResponseHandler.response(Message message)
|
void |
WriteResponseHandler.response(Message message)
|
Method parameters in org.apache.cassandra.service with type arguments of type Message | |
---|---|
boolean |
IResponseResolver.isDataPresent(java.util.Collection<Message> responses)
|
boolean |
RangeSliceResponseResolver.isDataPresent(java.util.Collection<Message> responses)
|
boolean |
ReadResponseResolver.isDataPresent(java.util.Collection<Message> responses)
|
T |
IResponseResolver.resolve(java.util.Collection<Message> responses)
|
java.util.List<Row> |
RangeSliceResponseResolver.resolve(java.util.Collection<Message> responses)
|
Row |
ReadResponseResolver.resolve(java.util.Collection<Message> responses)
|
Uses of Message in org.apache.cassandra.streaming |
---|
Methods in org.apache.cassandra.streaming with parameters of type Message | |
---|---|
void |
StreamFinishedVerbHandler.doVerb(Message message)
|
void |
StreamInitiateDoneVerbHandler.doVerb(Message message)
|
void |
StreamInitiateVerbHandler.doVerb(Message message)
|
void |
StreamRequestVerbHandler.doVerb(Message message)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |