public class JGroupsTransport extends ReceiverAdapter implements RtTransport
Modifier and Type | Field and Description |
---|---|
protected JChannel |
ch |
protected boolean |
dont_bundle |
protected Log |
log |
protected boolean |
oob |
protected RtReceiver |
receiver |
protected View |
view |
Constructor and Description |
---|
JGroupsTransport() |
Modifier and Type | Method and Description |
---|---|
List<Address> |
clusterMembers()
Returns the addresses of all cluster members.
|
Address |
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 |
receive(Message msg)
Called when a message is received.
|
void |
receive(MessageBatch batch)
Called when a batch of messages is received
|
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.
|
void |
viewAccepted(View view)
Called when a change in membership has occurred.
|
protected JChannel ch
protected RtReceiver receiver
protected View view
protected boolean oob
protected boolean dont_bundle
protected final Log log
public String[] options()
RtTransport
options
in interface RtTransport
public void options(String... options) throws Exception
RtTransport
RtTransport.start(String...)
is called,
but may also be called at runtime.options
in interface RtTransport
options
- The optionsException
public void receiver(RtReceiver receiver)
RtTransport
RtReceiver.receive(Object,byte[],int,int)
callback will be invoked whenever a
message is receivedreceiver
in interface RtTransport
public Address localAddress()
RtTransport
localAddress
in interface RtTransport
public List<Address> clusterMembers()
RtTransport
clusterMembers
in interface RtTransport
public void start(String... options) throws Exception
RtTransport
start
in interface RtTransport
options
- Options passed to the transport at startup time. May be nullException
public void stop()
RtTransport
stop
in interface RtTransport
public void send(Object dest, byte[] buf, int offset, int length) throws Exception
RtTransport
send
in interface RtTransport
dest
- The destination addressbuf
- The bufferoffset
- The offset at which the data startslength
- The length (in bytes) of the data to sendException
public void receive(MessageBatch batch)
MessageListener
receive
in interface MessageListener
receive
in class ReceiverAdapter
public void receive(Message msg)
MessageListener
receive
in interface MessageListener
receive
in class ReceiverAdapter
public void viewAccepted(View view)
MembershipListener
JChannel.connect(String)
returns.viewAccepted
in interface MembershipListener
viewAccepted
in class ReceiverAdapter
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.