Modifier and Type | Method and Description |
---|---|
void |
BatchStoreVerbHandler.doVerb(Message<Batch> message) |
void |
BatchRemoveVerbHandler.doVerb(Message<java.util.UUID> message) |
Modifier and Type | Method and Description |
---|---|
Message<ReadCommand> |
ReadCommand.createMessage(boolean trackRepairedData)
Creates a message for this command.
|
Modifier and Type | Method and Description |
---|---|
void |
CounterMutationVerbHandler.doVerb(Message<CounterMutation> message) |
void |
MutationVerbHandler.doVerb(Message<Mutation> message) |
void |
ReadRepairVerbHandler.doVerb(Message<Mutation> message) |
void |
ReadCommandVerbHandler.doVerb(Message<ReadCommand> message) |
void |
TruncateVerbHandler.doVerb(Message<TruncateRequest> message) |
Modifier and Type | Method and Description |
---|---|
void |
GossipShutdownVerbHandler.doVerb(Message message) |
void |
GossipDigestAckVerbHandler.doVerb(Message<GossipDigestAck> message) |
void |
GossipDigestAck2VerbHandler.doVerb(Message<GossipDigestAck2> message) |
void |
GossipDigestSynVerbHandler.doVerb(Message<GossipDigestSyn> message) |
void |
GossipVerbHandler.doVerb(Message<T> message) |
Modifier and Type | Method and Description |
---|---|
void |
HintVerbHandler.doVerb(Message<HintMessage> message) |
Modifier and Type | Method and Description |
---|---|
void |
MessagingMetrics.recordDroppedMessage(Message<?> message,
long timeElapsed,
java.util.concurrent.TimeUnit timeUnit) |
Modifier and Type | Method and Description |
---|---|
Message<T> |
Message.Builder.build() |
<T> Message<T> |
Message.Serializer.deserialize(DataInputPlus in,
InetAddressAndPort peer,
int version) |
<T> Message<T> |
Message.Serializer.deserialize(DataInputPlus in,
Message.Header header,
int version)
A partial variant of deserialize, taking in a previously deserialized
Message.Header as an argument. |
Message<NoPayload> |
Message.emptyResponse()
Builds a response Message with no payload, and all the right fields inferred from request Message
|
Message<RequestFailureReason> |
Message.failureResponse(RequestFailureReason reason)
Builds a failure response Message with an explicit reason, and fields inferred from request Message
|
static <T> Message<T> |
Message.internalResponse(Verb verb,
T payload) |
static <T> Message<T> |
Message.out(Verb verb,
T payload)
Make a request
Message with supplied verb and payload. |
static <T> Message<T> |
Message.out(Verb verb,
T payload,
long expiresAtNanos) |
static <T> Message<T> |
Message.outWithFlag(Verb verb,
T payload,
MessageFlag flag) |
static <T> Message<T> |
Message.outWithFlags(Verb verb,
T payload,
MessageFlag flag1,
MessageFlag flag2) |
<T> Message<T> |
Message.responseWith(T payload)
Builds a response Message with provided payload, and all the right fields inferred from request Message
|
Message<T> |
Message.withForwardTo(ForwardingInfo peers) |
Modifier and Type | Method and Description |
---|---|
void |
InboundSink.accept(Message<?> message) |
void |
OutboundSink.accept(Message<?> message,
InetAddressAndPort to,
ConnectionType connectionType) |
void |
OutboundSink.Sink.accept(Message<?> message,
InetAddressAndPort to,
ConnectionType connectionType) |
void |
RequestCallbacks.addWithExpiration(AbstractWriteResponseHandler<?> cb,
Message<?> message,
Replica to,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
boolean |
InboundSink.allow(Message<?> message)
Deprecated.
|
static <T> Message.Builder<T> |
Message.builder(Message<T> message) |
void |
IVerbHandler.doVerb(Message<T> message)
This method delivers a message to the implementing class (if the implementing
class was registered by a call to MessagingService.registerVerbHandlers).
|
void |
OutboundConnection.enqueue(Message message)
This is the main entry point for enqueuing a message to be sent to the remote peer.
|
void |
OutboundConnections.enqueue(Message msg,
ConnectionType type)
Select the appropriate connection for the provided message and use it to send the message.
|
void |
RequestCallbacks.onDiscardOnClose(Message<?> message,
InetAddressAndPort peer) |
void |
RequestCallbacks.onExpired(Message<?> message,
InetAddressAndPort peer) |
void |
RequestCallbacks.onFailedSerialize(Message<?> message,
InetAddressAndPort peer,
int messagingVersion,
int bytesWrittenToNetwork,
java.lang.Throwable failure) |
void |
RequestCallbacks.onOverloaded(Message<?> message,
InetAddressAndPort peer) |
void |
AsyncOneResponse.onResponse(Message<T> response) |
void |
RequestCallback.onResponse(Message<T> msg) |
void |
RequestCallbacks.removeAndRespond(long id,
InetAddressAndPort peer,
Message message) |
void |
MessagingService.send(Message message,
InetAddressAndPort to)
Send a message to a given endpoint.
|
void |
MessagingService.send(Message message,
InetAddressAndPort to,
ConnectionType specifyConnection) |
void |
MessagingService.sendWithCallback(Message message,
InetAddressAndPort to,
RequestCallback cb)
Send a non-mutation message to a given endpoint.
|
void |
MessagingService.sendWithCallback(Message message,
InetAddressAndPort to,
RequestCallback cb,
ConnectionType specifyConnection) |
void |
MessagingService.sendWriteWithCallback(Message message,
Replica to,
AbstractWriteResponseHandler<?> handler,
boolean allowHints)
Send a mutation message or a Paxos Commit to a given endpoint.
|
<T> void |
Message.Serializer.serialize(Message<T> message,
DataOutputPlus out,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
OutboundSink.add(java.util.function.BiPredicate<Message<?>,InetAddressAndPort> allow) |
void |
InboundSink.add(java.util.function.Predicate<Message<?>> allow) |
void |
OutboundSink.remove(java.util.function.BiPredicate<Message<?>,InetAddressAndPort> allow) |
void |
InboundSink.remove(java.util.function.Predicate<Message<?>> allow) |
Modifier and Type | Method and Description |
---|---|
void |
RepairMessageVerbHandler.doVerb(Message<RepairMessage> message) |
Modifier and Type | Method and Description |
---|---|
protected void |
LocalSessions.sendMessage(InetAddressAndPort destination,
Message<? extends RepairMessage> message) |
protected void |
CoordinatorSession.sendMessage(InetAddressAndPort destination,
Message<RepairMessage> message) |
Modifier and Type | Method and Description |
---|---|
void |
SchemaPushVerbHandler.doVerb(Message<java.util.Collection<Mutation>> message) |
void |
SchemaPullVerbHandler.doVerb(Message<NoPayload> message) |
void |
SchemaVersionVerbHandler.doVerb(Message<NoPayload> message) |
Modifier and Type | Method and Description |
---|---|
void |
EchoVerbHandler.doVerb(Message<NoPayload> message) |
void |
SnapshotVerbHandler.doVerb(Message<SnapshotCommand> message) |
void |
ActiveRepairService.handleMessage(Message<? extends RepairMessage> message) |
protected void |
AbstractWriteResponseHandler.logResponseToIdealCLDelegate(Message<T> m)
This logs the response but doesn't do any further processing related to this write response handler
on whether the CL was achieved.
|
void |
TruncateResponseHandler.onResponse(Message message) |
abstract void |
AbstractWriteResponseHandler.onResponse(Message<T> msg)
null message means "response from local write"
|
void |
BatchlogResponseHandler.onResponse(Message<T> msg) |
void |
DatacenterSyncWriteResponseHandler.onResponse(Message<T> message) |
void |
DatacenterWriteResponseHandler.onResponse(Message<T> message) |
void |
WriteResponseHandler.onResponse(Message<T> m) |
Modifier and Type | Method and Description |
---|---|
void |
CommitVerbHandler.doVerb(Message<Commit> message) |
void |
PrepareVerbHandler.doVerb(Message<Commit> message) |
void |
ProposeVerbHandler.doVerb(Message<Commit> message) |
void |
ProposeCallback.onResponse(Message<java.lang.Boolean> msg) |
void |
PrepareCallback.onResponse(Message<PrepareResponse> message) |
Modifier and Type | Field and Description |
---|---|
protected Accumulator<Message<ReadResponse>> |
ResponseResolver.responses |
Modifier and Type | Method and Description |
---|---|
Accumulator<Message<ReadResponse>> |
ResponseResolver.getMessages() |
Modifier and Type | Method and Description |
---|---|
void |
ReadCallback.onResponse(Message<ReadResponse> message) |
void |
DigestResolver.preprocess(Message<ReadResponse> message) |
void |
ResponseResolver.preprocess(Message<ReadResponse> message) |
Modifier and Type | Method and Description |
---|---|
void |
BlockingPartitionRepair.onResponse(Message<java.lang.Object> msg) |
protected void |
BlockingPartitionRepair.sendRR(Message<Mutation> message,
InetAddressAndPort endpoint) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationDoneVerbHandler.doVerb(Message msg) |
Modifier and Type | Method and Description |
---|---|
void |
Tracing.traceOutgoingMessage(Message<?> message,
int serializedSize,
InetAddressAndPort sendTo)
Record any tracing data, if enabled on this message.
|
Copyright © 2009-2020 The Apache Software Foundation