|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.net.MessagingService
public class MessagingService
Field Summary | |
---|---|
static MessagingService |
instance
|
static int |
PROTOCOL_MAGIC
we preface every message with this number so the recipient can validate the sender is sane |
Constructor Summary | |
---|---|
protected |
MessagingService()
|
Method Summary | |
---|---|
void |
addCallback(IAsyncCallback cb,
java.lang.String messageId)
|
java.lang.Object |
clone()
|
static java.nio.ByteBuffer |
constructStreamHeader(boolean compress)
|
void |
convict(java.net.InetAddress ep)
called by failure detection code to notify that housekeeping should be performed on downed sockets. |
static IAsyncResult |
getAsyncResult(java.lang.String key)
|
static long |
getAsyncResultAge(java.lang.String key)
|
static int |
getBits(int x,
int p,
int n)
|
static OutboundTcpConnection |
getConnection(java.net.InetAddress to,
Message msg)
|
static org.apache.cassandra.net.OutboundTcpConnectionPool |
getConnectionPool(java.net.InetAddress to)
|
static IAsyncCallback |
getRegisteredCallback(java.lang.String key)
|
static long |
getRegisteredCallbackAge(java.lang.String key)
|
IVerbHandler |
getVerbHandler(StorageService.Verb type)
This method returns the verb handler associated with the registered verb. |
byte[] |
hash(java.lang.String type,
byte[] data)
|
static int |
incrementDroppedMessages(StorageService.Verb verb)
|
void |
listen(java.net.InetAddress localEp)
Listen on the specified port. |
static java.nio.ByteBuffer |
packIt(byte[] bytes,
boolean compress)
|
static void |
receive(Message message)
|
void |
registerVerbHandlers(StorageService.Verb verb,
IVerbHandler verbHandler)
Register a verb and the corresponding verb handler with the Messaging Service. |
static void |
removeRegisteredCallback(java.lang.String key)
|
void |
sendOneWay(Message message,
java.net.InetAddress to)
Send a message to a given endpoint. |
java.lang.String |
sendRR(Message[] messages,
java.net.InetAddress[] to,
IAsyncCallback cb)
Send a message to a given endpoint. |
IAsyncResult |
sendRR(Message message,
java.net.InetAddress to)
|
java.lang.String |
sendRR(Message message,
java.net.InetAddress[] to,
IAsyncCallback cb)
Send a message to a given endpoint. |
java.lang.String |
sendRR(Message message,
java.net.InetAddress to,
IAsyncCallback cb)
Send a message to a given endpoint. |
static void |
shutdown()
|
void |
stream(java.lang.String file,
long startPosition,
long endPosition,
java.net.InetAddress from,
java.net.InetAddress to)
Stream a file from source to destination. |
static void |
validateMagic(int magic)
|
static void |
waitFor()
blocks until the processing pools are empty and done. |
void |
waitUntilListening()
|
Methods inherited from class java.lang.Object |
---|
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final int PROTOCOL_MAGIC
public static final MessagingService instance
Constructor Detail |
---|
protected MessagingService()
Method Detail |
---|
public java.lang.Object clone() throws java.lang.CloneNotSupportedException
clone
in class java.lang.Object
java.lang.CloneNotSupportedException
public byte[] hash(java.lang.String type, byte[] data)
public void convict(java.net.InetAddress ep)
public void listen(java.net.InetAddress localEp) throws java.io.IOException
localEp
- InetAddress whose port to listen on.
java.io.IOException
public void waitUntilListening()
public static org.apache.cassandra.net.OutboundTcpConnectionPool getConnectionPool(java.net.InetAddress to)
public static OutboundTcpConnection getConnection(java.net.InetAddress to, Message msg)
public void registerVerbHandlers(StorageService.Verb verb, IVerbHandler verbHandler)
verb
- verbHandler
- handler for the specified verbpublic IVerbHandler getVerbHandler(StorageService.Verb type)
type
- for which the verb handler is sought
public java.lang.String sendRR(Message message, java.net.InetAddress[] to, IAsyncCallback cb)
message
- message to be sent.to
- endpoint to which the message needs to be sent
public void addCallback(IAsyncCallback cb, java.lang.String messageId)
public java.lang.String sendRR(Message message, java.net.InetAddress to, IAsyncCallback cb)
message
- message to be sent.to
- endpoint to which the message needs to be sentcb
- callback interface which is used to pass the responses or
suggest that a timeout occurred to the invoker of the send().
suggest that a timeout occurred to the invoker of the send().
public java.lang.String sendRR(Message[] messages, java.net.InetAddress[] to, IAsyncCallback cb)
messages
array is sent to the ith element in the to
array.This method assumes
there is a one-one mapping between the messages
array and
the to
array. Otherwise an IllegalArgumentException will be thrown.
This method also informs the MessagingService to wait for at least
howManyResults
responses to determine success of failure.
messages
- messages to be sent.to
- endpoints to which the message needs to be sentcb
- callback interface which is used to pass the responses or
suggest that a timeout occured to the invoker of the send().
public void sendOneWay(Message message, java.net.InetAddress to)
message
- messages to be sent.to
- endpoint to which the message needs to be sentpublic IAsyncResult sendRR(Message message, java.net.InetAddress to)
public void stream(java.lang.String file, long startPosition, long endPosition, java.net.InetAddress from, java.net.InetAddress to)
file
- name of file to stream.startPosition
- position inside the fileendPosition
- to
- endpoint to which we need to stream the file.public static void waitFor() throws java.lang.InterruptedException
java.lang.InterruptedException
public static void shutdown()
public static void receive(Message message)
public static IAsyncCallback getRegisteredCallback(java.lang.String key)
public static void removeRegisteredCallback(java.lang.String key)
public static IAsyncResult getAsyncResult(java.lang.String key)
public static long getRegisteredCallbackAge(java.lang.String key)
public static long getAsyncResultAge(java.lang.String key)
public static void validateMagic(int magic) throws java.io.IOException
java.io.IOException
public static int getBits(int x, int p, int n)
public static java.nio.ByteBuffer packIt(byte[] bytes, boolean compress)
public static java.nio.ByteBuffer constructStreamHeader(boolean compress)
public static int incrementDroppedMessages(StorageService.Verb verb)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |