Uses of Class org.apache.cassandra.net.Message (apache-cassandra API)
Date: 2012-05-04

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

## 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` | `IndexScanCommand.getMessage(java.lang.Integer version)`
`Message` | `RangeSliceCommand.getMessage(java.lang.Integer version)`
`Message` | `ReadCommand.getMessage(java.lang.Integer version)`
`Message` | `RowMutation.getMessage(java.lang.Integer version)`
`Message` | `Truncation.getMessage(java.lang.Integer version)`
`Message` | `RowMutation.getMessage(StorageService.Verb verb, int version)`
`Message` | `RangeSliceReply.getReply(Message originalMessage)`
`Message` | `CounterMutation.makeMutationMessage(int version)`
`static Message` | `TruncateResponse.makeTruncateResponseMessage(Message original, TruncateResponse truncateResponseMessage)`
`static Message` | `WriteResponse.makeWriteResponseMessage(Message original, WriteResponse respose)`

Methods in org.apache.cassandra.db with parameters of type Message
`void` | `CounterMutationVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `DefinitionsUpdateVerbHandler.doVerb(Message message, java.lang.String id)` someone sent me their data definitions
`void` | `ReadRepairVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `ReadVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `RowMutationVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `SchemaCheckVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `TruncateVerbHandler.doVerb(Message message, java.lang.String id)`
`Message` | `RangeSliceReply.getReply(Message originalMessage)`
`static Message` | `TruncateResponse.makeTruncateResponseMessage(Message original, TruncateResponse truncateResponseMessage)`
`static Message` | `WriteResponse.makeWriteResponseMessage(Message original, WriteResponse respose)`
`static IndexScanCommand` | `IndexScanCommand.read(Message message)`
`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, java.lang.String id)`

Uses of Message in org.apache.cassandra.gms

Methods in org.apache.cassandra.gms with parameters of type Message
`void` | `GossipDigestAck2VerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `GossipDigestAckVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `GossipDigestSynVerbHandler.doVerb(Message message, java.lang.String id)`

Uses of Message in org.apache.cassandra.net

Methods in org.apache.cassandra.net that return Message
`Message` | `Message.getInternalReply(byte[] body, int version)`
`Message` | `CachingMessageProducer.getMessage(java.lang.Integer version)`
`Message` | `MessageProducer.getMessage(java.lang.Integer version)`
`Message` | `Message.getReply(java.net.InetAddress from, byte[] body, int version)`
`Message` | `Message.withHeaderAdded(java.lang.String key, byte[] value)`
`Message` | `Message.withHeaderRemoved(java.lang.String key)`

Methods in org.apache.cassandra.net with parameters of type Message
`void` | `IVerbHandler.doVerb(Message message, java.lang.String id)` 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, java.lang.String id)`
`void` | `OutboundTcpConnection.enqueue(Message message, java.lang.String id)`
`OutboundTcpConnection` | `MessagingService.getConnection(java.net.InetAddress to, Message msg)`
`void` | `MessagingService.receive(Message message, java.lang.String id)`
`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)`
`void` | `MessagingService.sendReply(Message message, java.lang.String id, java.net.InetAddress to)`
`IAsyncResult` | `MessagingService.sendRR(Message message, java.net.InetAddress to)`
`java.lang.String` | `MessagingService.sendRR(Message message, java.net.InetAddress to, IMessageCallback cb)`
`java.lang.String` | `MessagingService.sendRR(Message message, java.net.InetAddress to, IMessageCallback cb, long timeout)` Send a message to a given endpoint.

Constructors in org.apache.cassandra.net with parameters of type Message
`MessageDeliveryTask(Message message, java.lang.String id)`

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

Methods in org.apache.cassandra.net.sink that return Message
`Message` | `IMessageSink.handleMessage(Message message, java.lang.String id, java.net.InetAddress to)`
`static Message` | `SinkManager.processClientMessage(Message message, java.lang.String id, java.net.InetAddress to)`
`static Message` | `SinkManager.processServerMessage(Message message, java.lang.String id)`

Methods in org.apache.cassandra.net.sink with parameters of type Message
`Message` | `IMessageSink.handleMessage(Message message, java.lang.String id, java.net.InetAddress to)`
`static Message` | `SinkManager.processClientMessage(Message message, java.lang.String id, java.net.InetAddress to)`
`static Message` | `SinkManager.processServerMessage(Message message, java.lang.String id)`

Uses of Message in org.apache.cassandra.service

Fields in org.apache.cassandra.service with type parameters of type Message
`protected java.util.concurrent.ConcurrentMap<Message,ReadResponse>` | `AbstractRowResolver.replies`
`protected java.util.Collection<Message>` | `RangeSliceResponseResolver.responses`

Methods in org.apache.cassandra.service that return types with arguments of type Message
`java.lang.Iterable<Message>` | `AbstractRowResolver.getMessages()`
`java.lang.Iterable<Message>` | `IResponseResolver.getMessages()`
`java.lang.Iterable<Message>` | `RangeSliceResponseResolver.getMessages()`

Methods in org.apache.cassandra.service with parameters of type Message
`void` | `AntiEntropyService.TreeRequestVerbHandler.doVerb(Message message, java.lang.String id)` Trigger a validation compaction which will return the tree upon completion.
`void` | `AntiEntropyService.TreeResponseVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `IndexScanVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `RangeSliceVerbHandler.doVerb(Message message, java.lang.String id)`
`static java.util.Collection<Column>` | `MigrationManager.makeColumns(Message msg)`
`void` | `AbstractRowResolver.preprocess(Message message)`
`void` | `IResponseResolver.preprocess(Message message)`
`void` | `RangeSliceResponseResolver.preprocess(Message message)`
`abstract void` | `AbstractWriteResponseHandler.response(Message msg)` null message means "response from local write"
`void` | `AsyncRepairCallback.response(Message message)`
`void` | `DatacenterSyncWriteResponseHandler.response(Message message)`
`void` | `DatacenterWriteResponseHandler.response(Message message)`
`void` | `ReadCallback.response(Message message)`
`void` | `RepairCallback.response(Message message)`
`void` | `TruncateResponseHandler.response(Message message)`
`void` | `WriteResponseHandler.response(Message m)`
`protected boolean` | `DatacenterReadCallback.waitingFor(Message message)`
`protected boolean` | `ReadCallback.waitingFor(Message message)`

Uses of Message in org.apache.cassandra.streaming

Methods in org.apache.cassandra.streaming with parameters of type Message
`void` | `ReplicationFinishedVerbHandler.doVerb(Message msg, java.lang.String id)`
`void` | `StreamReplyVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `StreamRequestVerbHandler.doVerb(Message message, java.lang.String id)`
`void` | `StreamingRepairTask.StreamingRepairRequest.doVerb(Message message, java.lang.String id)`
`void` | `StreamingRepairTask.StreamingRepairResponse.doVerb(Message message, java.lang.String id)`

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

Copyright © 2012 The Apache Software Foundation