Uses of Class
org.apache.cassandra.net.Message

Packages that use Message
org.apache.cassandra.db   
org.apache.cassandra.dht   
org.apache.cassandra.net   
org.apache.cassandra.net.io   
org.apache.cassandra.net.sink   
org.apache.cassandra.service   
org.apache.cassandra.tools   
 

Uses of Message in org.apache.cassandra.db
 

Methods in org.apache.cassandra.db that return Message
 Message RangeCommand.getMessage()
           
 Message RangeReply.getReply(Message originalMessage)
           
 Message ReadCommand.makeReadMessage()
           
static Message ReadResponse.makeReadResponseMessage(ReadResponse readResponse)
           
 Message RowMutation.makeRowMutationMessage()
           
 Message RowMutationMessage.makeRowMutationMessage()
           
 Message RowMutation.makeRowMutationMessage(java.lang.String verbHandlerName)
           
 Message RowMutationMessage.makeRowMutationMessage(java.lang.String verbHandlerName)
           
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 DataFileVerbHandler.doVerb(Message message)
           
 void ReadRepairVerbHandler.doVerb(Message message)
           
 void ReadVerbHandler.doVerb(Message message)
           
 void RowMutationVerbHandler.doVerb(Message message)
           
 void Table.BootStrapInitiateVerbHandler.doVerb(Message message)
           
 Message RangeReply.getReply(Message originalMessage)
           
static Message WriteResponse.makeWriteResponseMessage(Message original, WriteResponse writeResponseMessage)
           
static RangeCommand RangeCommand.read(Message message)
           
 

Uses of Message in org.apache.cassandra.dht
 

Methods in org.apache.cassandra.dht that return Message
static Message BootstrapInitiateMessage.makeBootstrapInitiateMessage(BootstrapInitiateMessage biMessage)
           
 

Methods in org.apache.cassandra.dht with parameters of type Message
 void BootstrapMetadataVerbHandler.doVerb(Message message)
           
 

Uses of Message in org.apache.cassandra.net
 

Methods in org.apache.cassandra.net that return Message
 Message Message.getReply(EndPoint from, byte[] args)
           
 

Methods in org.apache.cassandra.net that return types with arguments of type Message
static ICompactSerializer<Message> Message.serializer()
           
 

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).
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 IMessagingService.sendOneWay(Message message, EndPoint to)
          Send a message to a given endpoint.
 void MessagingService.sendOneWay(Message message, EndPoint to)
           
 java.lang.String IMessagingService.sendRR(Message[][] messages, EndPoint[][] to, IAsyncCallback cb)
          Send a message to a given endpoint.
 java.lang.String MessagingService.sendRR(Message[][] messages, EndPoint[][] to, IAsyncCallback cb)
           
 java.lang.String IMessagingService.sendRR(Message[] messages, EndPoint[] to, IAsyncCallback cb)
          Send a message to a given endpoint.
 java.lang.String MessagingService.sendRR(Message[] messages, EndPoint[] to, IAsyncCallback cb)
           
 IAsyncResult IMessagingService.sendRR(Message message, EndPoint to)
          Send a message to a given endpoint.
 IAsyncResult MessagingService.sendRR(Message message, EndPoint to)
           
 java.lang.String IMessagingService.sendRR(Message message, EndPoint[] to, IAsyncCallback cb)
          Send a message to the given set of endpoints and informs the MessagingService to wait for at least howManyResults responses to determine success of failure.
 java.lang.String MessagingService.sendRR(Message message, EndPoint[] to, IAsyncCallback cb)
           
 java.lang.String IMessagingService.sendRR(Message message, EndPoint to, IAsyncCallback cb)
          Send a message to a given endpoint.
 java.lang.String MessagingService.sendRR(Message message, EndPoint to, IAsyncCallback cb)
           
 void IMessagingService.sendUdpOneWay(Message message, EndPoint to)
          Send a message to a given endpoint.
 void MessagingService.sendUdpOneWay(Message message, EndPoint to)
           
 void TcpConnection.write(Message message)
           
 boolean UdpConnection.write(Message message, EndPoint to)
           
 

Constructors in org.apache.cassandra.net with parameters of type Message
MessageDeliveryTask(Message message)
           
 

Uses of Message in org.apache.cassandra.net.io
 

Methods in org.apache.cassandra.net.io that return Message
 Message FastSerializer.deserialize(byte[] bytes)
           
 Message ISerializer.deserialize(byte[] bytes)
           
static Message StreamContextManager.StreamStatusMessage.makeStreamStatusMessage(StreamContextManager.StreamStatusMessage streamStatusMessage)
           
 

Methods in org.apache.cassandra.net.io with parameters of type Message
 byte[] FastSerializer.serialize(Message message)
           
 byte[] ISerializer.serialize(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
 

Methods in org.apache.cassandra.service with parameters of type Message
 void RangeVerbHandler.doVerb(Message message)
           
 void StorageService.BootstrapInitiateDoneVerbHandler.doVerb(Message message)
           
 void StreamManager.BootstrapTerminateVerbHandler.doVerb(Message message)
           
 void TokenUpdateVerbHandler.doVerb(Message message)
           
 void MultiQuorumResponseHandler.response(Message message)
          The handler of the response message that has been sent by one of the replicas for one of the keys.
 void QuorumResponseHandler.response(Message message)
           
 

Method parameters in org.apache.cassandra.service with type arguments of type Message
 boolean IResponseResolver.isDataPresent(java.util.List<Message> responses)
           
 boolean ReadResponseResolver.isDataPresent(java.util.List<Message> responses)
           
 boolean WriteResponseResolver.isDataPresent(java.util.List<Message> responses)
           
 T IResponseResolver.resolve(java.util.List<Message> responses)
           
 Row ReadResponseResolver.resolve(java.util.List<Message> responses)
           
 java.lang.Boolean WriteResponseResolver.resolve(java.util.List<Message> responses)
           
 

Uses of Message in org.apache.cassandra.tools
 

Methods in org.apache.cassandra.tools with parameters of type Message
 void MembershipCleanerVerbHandler.doVerb(Message message)
           
 void TokenUpdateVerbHandler.doVerb(Message message)
           
 



Copyright © 2009 The Apache Software Foundation