public interface RtTransport
RoundTrip
testModifier and Type | Method and Description |
---|---|
List<? extends Object> |
clusterMembers()
Returns the addresses of all cluster members.
|
Object |
localAddress()
Returns the local addres of this member.
|
String[] |
options()
Prints the accepted options, e.g.
|
void |
options(String... options)
Sets options on this transport.
|
void |
receiver(RtReceiver receiver)
Sets the receiver whose
RtReceiver.receive(Object,byte[],int,int) callback will be invoked whenever a
message is received |
void |
send(Object dest,
byte[] buf,
int offset,
int length)
Sends a message
|
void |
start(String... options)
Starts the transport, e.g.
|
void |
stop()
Stops the transport, e.g.
|
String[] options()
void options(String... options) throws Exception
start(String...)
is called,
but may also be called at runtime.options
- The optionsException
void receiver(RtReceiver receiver)
RtReceiver.receive(Object,byte[],int,int)
callback will be invoked whenever a
message is receivedreceiver
- Object localAddress()
List<? extends Object> clusterMembers()
void start(String... options) throws Exception
options
- Options passed to the transport at startup time. May be nullException
void stop()
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.