|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.tribe.adapters.MulticastRequestAdapterTest
This class defines a MulticastRequestAdapterTest
Field Summary | |
private MulticastRequestAdapter |
adapter1
|
private MulticastRequestAdapter |
adapter2
|
private ReliableGroupChannelWithGms |
channel1
|
private ReliableGroupChannelWithGms |
channel2
|
private UdpDiscoveryService |
discovery
|
private GroupIdentifier |
gid1
|
private GroupMembershipService |
gms
|
private java.lang.String |
msg1
|
private java.lang.String |
msg2
|
Constructor Summary | |
MulticastRequestAdapterTest()
Creates a new MulticastRequestAdapterTest object |
Method Summary | |
void |
close()
Quit the group and closes the channels. |
java.io.Serializable |
handleMessageMultiThreaded(java.io.Serializable msg,
Member sender,
java.lang.Object handleMessageSingleThreadedResult)
|
java.lang.Object |
handleMessageSingleThreaded(java.io.Serializable msg,
Member sender)
|
private void |
initializeChannels()
|
static void |
main(java.lang.String[] args)
Main method |
void |
receive(java.io.Serializable msg)
|
void |
sendMessages()
Test the group join/send/receive/quit primitives |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
private ReliableGroupChannelWithGms channel1
private ReliableGroupChannelWithGms channel2
private UdpDiscoveryService discovery
private GroupMembershipService gms
private final GroupIdentifier gid1
private final java.lang.String msg1
private final java.lang.String msg2
private MulticastRequestAdapter adapter1
private MulticastRequestAdapter adapter2
Constructor Detail |
public MulticastRequestAdapterTest() throws java.lang.Exception
MulticastRequestAdapterTest
object
java.lang.Exception
- if an error occursMethod Detail |
private void initializeChannels() throws java.lang.Exception
java.lang.Exception
public void sendMessages()
public void close()
public void receive(java.io.Serializable msg)
receive
in interface MessageListener
MessageListener.receive(java.io.Serializable)
public static void main(java.lang.String[] args)
args
- command line argumentspublic java.lang.Object handleMessageSingleThreaded(java.io.Serializable msg, Member sender)
handleMessageSingleThreaded
in interface MulticastRequestListener
MulticastRequestListener.handleMessageSingleThreaded(java.io.Serializable,
org.objectweb.tribe.common.Member)
public java.io.Serializable handleMessageMultiThreaded(java.io.Serializable msg, Member sender, java.lang.Object handleMessageSingleThreadedResult)
handleMessageMultiThreaded
in interface MulticastRequestListener
MulticastRequestListener.handleMessageMultiThreaded(java.io.Serializable,
org.objectweb.tribe.common.Member, java.lang.Object)
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |