Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.net | |
org.apache.cassandra.net.sink | |
org.apache.cassandra.service | |
org.apache.cassandra.streaming |
Modifier and Type | Method and Description |
---|---|
MessageOut<IndexScanCommand> |
IndexScanCommand.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 |
---|---|
protected MessageOut<?> |
CallbackInfo.sentMessage |
Modifier and Type | Method and Description |
---|---|
MessageOut<T> |
MessageOut.withParameter(java.lang.String key,
byte[] value) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
MessagingService.addCallback(IMessageCallback cb,
MessageOut message,
java.net.InetAddress to,
long timeout) |
void |
OutboundTcpConnection.enqueue(MessageOut<?> message,
java.lang.String id) |
OutboundTcpConnection |
MessagingService.getConnection(java.net.InetAddress to,
MessageOut msg) |
void |
MessagingService.sendOneWay(MessageOut message,
java.net.InetAddress to) |
void |
MessagingService.sendOneWay(MessageOut message,
java.lang.String id,
java.net.InetAddress to)
Send a message to a given endpoint.
|
void |
MessagingService.sendReply(MessageOut message,
java.lang.String id,
java.net.InetAddress to) |
<T> IAsyncResult<T> |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to) |
java.lang.String |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to,
IMessageCallback cb) |
java.lang.String |
MessagingService.sendRR(MessageOut message,
java.net.InetAddress to,
IMessageCallback cb,
long timeout)
Send a message to a given endpoint.
|
static void |
OutboundTcpConnection.write(MessageOut message,
java.lang.String id,
long timestamp,
java.io.DataOutputStream out,
int version) |
Constructor and Description |
---|
CallbackInfo(java.net.InetAddress target,
IMessageCallback callback,
MessageOut<?> sentMessage,
IVersionedSerializer<?> serializer) |
Modifier and Type | Method and Description |
---|---|
MessageOut |
IMessageSink.handleMessage(MessageOut message,
java.lang.String id,
java.net.InetAddress to) |
static MessageOut |
SinkManager.processOutboundMessage(MessageOut message,
java.lang.String id,
java.net.InetAddress to) |
Modifier and Type | Method and Description |
---|---|
MessageOut |
IMessageSink.handleMessage(MessageOut message,
java.lang.String id,
java.net.InetAddress to) |
static MessageOut |
SinkManager.processOutboundMessage(MessageOut message,
java.lang.String id,
java.net.InetAddress to) |
Modifier and Type | Method and Description |
---|---|
MessageOut<AntiEntropyService.Validator> |
AntiEntropyService.Validator.createMessage() |
MessageOut<AntiEntropyService.TreeRequest> |
AntiEntropyService.TreeRequest.createMessage() |
Modifier and Type | Method and Description |
---|---|
MessageOut<StreamReply> |
StreamReply.createMessage() |
MessageOut<StreamRequest> |
StreamRequest.createMessage() |
Modifier and Type | Method and Description |
---|---|
void |
StreamInSession.sendMessage(MessageOut<StreamReply> message) |
Copyright © 2014 The Apache Software Foundation