R |
Transport.createReceiver(java.net.URI uri) |
Create a new receiver for the provided URI.
|
S |
ClientTransport.createSender(java.net.URI uri,
boolean synchronous) |
Create a new sender for the provided URI.
|
void |
ClientTransport.dispatchMessage(PlatformMessage msg,
S sender) |
Asynchronously send a message via the provided sender with no expected return.
|
void |
MultiRegionTransport.dispatchMessage(PlatformMessage msg,
S sender) |
Asynchronously send a message via the provided sender with no expected return.
|
PlatformMessage |
MessageEmitter.emit(PlatformMessage msg,
boolean synchronous,
java.net.URI srcURI) |
send a message to the internal URI.
|
void |
MultiRegionTransport.emitMessage(MessageList messageList,
java.net.URI uri) |
Emit a message to the Attivio internal routing and processing system for multi-region
replication messages.
|
S |
ClientTransport.getSender(java.net.URI uri) |
Get a Sender or null if it doesn't not exist.
|
void |
SyncronousMessageHandle.handleReplyMessage(PlatformMessage msg) |
Handle the reply message from the bus.
|
void |
Transport.prepareReceiver(R receiver) |
Prepares receiver to accept messages.
|
SyncronousMessageHandle |
ManagedTransport.receiveMessage(R receiver) |
Receive a message waiting indefinitely until a message is received.
|
SyncronousMessageHandle |
ManagedTransport.receiveMessage(R receiver,
long timeout) |
Receive a message waiting up to the timeout period.
|
PlatformMessage |
ClientTransport.sendMessage(PlatformMessage msg,
S sender) |
Synchronously send a message via the provided sender.
|
PlatformMessage |
MultiRegionTransport.sendMessage(PlatformMessage msg,
S sender) |
Synchronously send a message via the provided sender.
|
void |
ClientTransport.shutdown() |
Closes down any transport related resources
|
void |
Transport.stopReceiver(R receiver) |
Stop/shutdown a receiver and free up any associated resources.
|
void |
ClientTransport.stopSender(S sender) |
Stop/shutdown a sender and free up any associated resources.
|