Package | Description |
---|---|
org.apache.cassandra.net | |
org.apache.cassandra.service |
Modifier and Type | Interface and Description |
---|---|
interface |
IAsyncCallback<T>
implementors of IAsyncCallback need to make sure that any public methods
are threadsafe with respect to response() being called from the message
service.
|
interface |
IAsyncResult<T> |
Modifier and Type | Field and Description |
---|---|
protected IMessageCallback |
CallbackInfo.callback |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
MessagingService.addCallback(IMessageCallback cb,
MessageOut message,
java.net.InetAddress to,
long timeout) |
void |
MessagingService.maybeAddLatency(IMessageCallback cb,
java.net.InetAddress address,
long latency)
Track latency information for the dynamic snitch
|
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.
|
void |
MessagingService.sendUnhintableMutation(RowMutation mutation,
java.net.InetAddress to,
IMessageCallback cb)
A special version of sendRR that doesn't trigger a hint for the mutation on a timeout.
|
Constructor and Description |
---|
CallbackInfo(java.net.InetAddress target,
IMessageCallback callback,
IVersionedSerializer<?> serializer)
Create CallbackInfo without sent message
|
CallbackInfo(java.net.InetAddress target,
IMessageCallback callback,
MessageOut<?> sentMessage,
IVersionedSerializer<?> serializer) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractWriteResponseHandler |
class |
AsyncRepairCallback |
class |
DatacenterSyncWriteResponseHandler
This class blocks for a quorum of responses _in all datacenters_ (CL.EACH_QUORUM).
|
class |
DatacenterWriteResponseHandler
This class blocks for a quorum of responses _in the local datacenter only_ (CL.LOCAL_QUORUM).
|
class |
ReadCallback<TMessage,TResolved> |
class |
TruncateResponseHandler |
class |
WriteResponseHandler
Handles blocking writes for ONE, ANY, TWO, THREE, QUORUM, and ALL consistency levels.
|
Copyright © 2014 The Apache Software Foundation