Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.net | |
org.apache.cassandra.repair.messages | |
org.apache.cassandra.sink |
Modifier and Type | Method and Description |
---|---|
abstract MessageOut<? extends AbstractRangeCommand> |
AbstractRangeCommand.createMessage() |
MessageOut<PagedRangeCommand> |
PagedRangeCommand.createMessage() |
MessageOut<RangeSliceCommand> |
RangeSliceCommand.createMessage() |
MessageOut<RangeSliceReply> |
RangeSliceReply.createMessage() |
MessageOut<ReadCommand> |
ReadCommand.createMessage() |
MessageOut<RowMutation> |
RowMutation.createMessage() |
MessageOut |
SnapshotCommand.createMessage() |
MessageOut<TruncateResponse> |
TruncateResponse.createMessage() |
MessageOut<Truncation> |
Truncation.createMessage() |
MessageOut<WriteResponse> |
WriteResponse.createMessage() |
MessageOut<RowMutation> |
RowMutation.createMessage(MessagingService.Verb verb) |
MessageOut<CounterMutation> |
CounterMutation.makeMutationMessage() |
Modifier and Type | Field and Description |
---|---|
MessageOut |
WriteCallbackInfo.sentMessage |
Modifier and Type | Method and Description |
---|---|
MessageOut<T> |
MessageOut.withParameter(java.lang.String key,
byte[] value) |
Modifier and Type | Method and Description |
---|---|
int |
MessagingService.addCallback(IAsyncCallback cb,
MessageOut<? extends IMutation> message,
java.net.InetAddress to,
long timeout,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
int |
MessagingService.addCallback(IAsyncCallback cb,
MessageOut message,
java.net.InetAddress to,
long timeout,
boolean failureCallback) |
void |
OutboundTcpConnection.enqueue(MessageOut<?> message,
int id) |
OutboundTcpConnection |
MessagingService.getConnection(java.net.InetAddress to,
MessageOut msg) |
void |
MessagingService.sendOneWay(MessageOut message,
java.net.InetAddress to) |
void |
MessagingService.sendOneWay(MessageOut message,
int id,
java.net.InetAddress to)
Send a message to a given endpoint.
|
void |
MessagingService.sendReply(MessageOut message,
int id,
java.net.InetAddress to) |
int |
MessagingService.sendRR(MessageOut<? extends IMutation> message,
java.net.InetAddress to,
AbstractWriteResponseHandler handler,
boolean allowHints)
Send a mutation message to a given endpoint.
|
<T> AsyncOneResponse<T> |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to) |
int |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to,
IAsyncCallback cb) |
int |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to,
IAsyncCallback cb,
long timeout,
boolean failureCallback)
Send a non-mutation message to a given endpoint.
|
int |
MessagingService.sendRRWithFailure(MessageOut message,
java.net.InetAddress to,
IAsyncCallbackWithFailure cb) |
Constructor and Description |
---|
WriteCallbackInfo(java.net.InetAddress target,
IAsyncCallback callback,
MessageOut message,
IVersionedSerializer<?> serializer,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
Modifier and Type | Method and Description |
---|---|
MessageOut<RepairMessage> |
RepairMessage.createMessage() |
Modifier and Type | Method and Description |
---|---|
MessageOut |
IMessageSink.handleMessage(MessageOut message,
int id,
java.net.InetAddress to)
Transform or drop an outgoing message
|
static MessageOut |
SinkManager.processOutboundMessage(MessageOut message,
int id,
java.net.InetAddress to) |
Modifier and Type | Method and Description |
---|---|
MessageOut |
IMessageSink.handleMessage(MessageOut message,
int id,
java.net.InetAddress to)
Transform or drop an outgoing message
|
static MessageOut |
SinkManager.processOutboundMessage(MessageOut message,
int id,
java.net.InetAddress to) |
Copyright © 2014 The Apache Software Foundation