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

Packages that use Message
org.apache.cassandra.db   
org.apache.cassandra.dht   
org.apache.cassandra.gms   
org.apache.cassandra.net   
org.apache.cassandra.net.sink   
org.apache.cassandra.service   
org.apache.cassandra.streaming   
 

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)
           
 



Copyright © 2010 The Apache Software Foundation