Modifier and Type | Method and Description |
---|---|
void |
DefinitionsUpdateVerbHandler.doVerb(MessageIn<java.util.Collection<Mutation>> message,
int id) |
void |
CounterMutationVerbHandler.doVerb(MessageIn<CounterMutation> message,
int id) |
void |
MutationVerbHandler.doVerb(MessageIn<Mutation> message,
int id) |
void |
ReadRepairVerbHandler.doVerb(MessageIn<Mutation> message,
int id) |
void |
ReadVerbHandler.doVerb(MessageIn<ReadCommand> message,
int id) |
void |
TruncateVerbHandler.doVerb(MessageIn<Truncation> message,
int id) |
void |
MigrationRequestVerbHandler.doVerb(MessageIn message,
int id) |
void |
SchemaCheckVerbHandler.doVerb(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
GossipDigestAckVerbHandler.doVerb(MessageIn<GossipDigestAck> message,
int id) |
void |
GossipDigestAck2VerbHandler.doVerb(MessageIn<GossipDigestAck2> message,
int id) |
void |
GossipDigestSynVerbHandler.doVerb(MessageIn<GossipDigestSyn> message,
int id) |
void |
GossipShutdownVerbHandler.doVerb(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
static <T> MessageIn<T> |
MessageIn.create(java.net.InetAddress from,
T payload,
java.util.Map<java.lang.String,byte[]> parameters,
MessagingService.Verb verb,
int version) |
static <T2> MessageIn<T2> |
MessageIn.read(java.io.DataInput in,
int version,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
IVerbHandler.doVerb(MessageIn<T> message,
int 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(MessageIn message,
int id) |
void |
MessagingService.receive(MessageIn message,
int id,
long timestamp) |
void |
AsyncOneResponse.response(MessageIn<T> response) |
void |
IAsyncCallback.response(MessageIn<T> msg) |
Constructor and Description |
---|
MessageDeliveryTask(MessageIn message,
int id,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
RepairMessageVerbHandler.doVerb(MessageIn<RepairMessage> message,
int id) |
Modifier and Type | Field and Description |
---|---|
protected java.util.Queue<MessageIn<ReadResponse>> |
AbstractRowResolver.replies |
protected java.util.Collection<MessageIn<RangeSliceReply>> |
RangeSliceResponseResolver.responses |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<MessageIn<ReadResponse>> |
AbstractRowResolver.getMessages() |
java.lang.Iterable<MessageIn<TMessage>> |
IResponseResolver.getMessages() |
java.lang.Iterable<MessageIn<RangeSliceReply>> |
RangeSliceResponseResolver.getMessages() |
Modifier and Type | Method and Description |
---|---|
void |
RangeSliceVerbHandler.doVerb(MessageIn<AbstractRangeCommand> message,
int id) |
void |
EchoVerbHandler.doVerb(MessageIn<EchoMessage> message,
int id) |
void |
SnapshotVerbHandler.doVerb(MessageIn<SnapshotCommand> message,
int id) |
void |
RangeSliceResponseResolver.preprocess(MessageIn message) |
void |
AbstractRowResolver.preprocess(MessageIn<ReadResponse> message) |
void |
IResponseResolver.preprocess(MessageIn<TMessage> message) |
abstract void |
AbstractWriteResponseHandler.response(MessageIn msg)
null message means "response from local write"
|
void |
DatacenterSyncWriteResponseHandler.response(MessageIn message) |
void |
DatacenterWriteResponseHandler.response(MessageIn message) |
void |
TruncateResponseHandler.response(MessageIn message) |
void |
WriteResponseHandler.response(MessageIn m) |
void |
AsyncRepairCallback.response(MessageIn<ReadResponse> message) |
void |
ReadCallback.response(MessageIn<TMessage> message) |
Modifier and Type | Method and Description |
---|---|
void |
CommitVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
PrepareVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
ProposeVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
ProposeCallback.response(MessageIn<java.lang.Boolean> msg) |
void |
PrepareCallback.response(MessageIn<PrepareResponse> message) |
Modifier and Type | Method and Description |
---|---|
MessageIn |
IMessageSink.handleMessage(MessageIn message,
int id,
java.net.InetAddress to)
Transform or drop an incoming message
|
static MessageIn |
SinkManager.processInboundMessage(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
MessageIn |
IMessageSink.handleMessage(MessageIn message,
int id,
java.net.InetAddress to)
Transform or drop an incoming message
|
static MessageIn |
SinkManager.processInboundMessage(MessageIn message,
int id) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationFinishedVerbHandler.doVerb(MessageIn msg,
int id) |
Modifier and Type | Method and Description |
---|---|
TraceState |
Tracing.initializeFromMessage(MessageIn<?> message)
Determines the tracing context from a message.
|
Copyright © 2014 The Apache Software Foundation