org.objectweb.tribe.adapters
Class MulticastRequestAdapterTest

java.lang.Object
  extended byorg.objectweb.tribe.adapters.MulticastRequestAdapterTest
All Implemented Interfaces:
MessageListener, MulticastRequestListener

public class MulticastRequestAdapterTest
extends java.lang.Object
implements MessageListener, MulticastRequestListener

This class defines a MulticastRequestAdapterTest

Version:
1.0
Author:
Emmanuel Cecchet

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

channel1

private ReliableGroupChannelWithGms channel1

channel2

private ReliableGroupChannelWithGms channel2

discovery

private UdpDiscoveryService discovery

gms

private GroupMembershipService gms

gid1

private final GroupIdentifier gid1

msg1

private final java.lang.String msg1
See Also:
Constant Field Values

msg2

private final java.lang.String msg2
See Also:
Constant Field Values

adapter1

private MulticastRequestAdapter adapter1

adapter2

private MulticastRequestAdapter adapter2
Constructor Detail

MulticastRequestAdapterTest

public MulticastRequestAdapterTest()
                            throws java.lang.Exception
Creates a new MulticastRequestAdapterTest object

Throws:
java.lang.Exception - if an error occurs
Method Detail

initializeChannels

private void initializeChannels()
                         throws java.lang.Exception
Throws:
java.lang.Exception

sendMessages

public void sendMessages()
Test the group join/send/receive/quit primitives


close

public void close()
Quit the group and closes the channels.


receive

public void receive(java.io.Serializable msg)
Specified by:
receive in interface MessageListener
See Also:
MessageListener.receive(java.io.Serializable)

main

public static void main(java.lang.String[] args)
Main method

Parameters:
args - command line arguments

handleMessageSingleThreaded

public java.lang.Object handleMessageSingleThreaded(java.io.Serializable msg,
                                                    Member sender)
Specified by:
handleMessageSingleThreaded in interface MulticastRequestListener
See Also:
MulticastRequestListener.handleMessageSingleThreaded(java.io.Serializable, org.objectweb.tribe.common.Member)

handleMessageMultiThreaded

public java.io.Serializable handleMessageMultiThreaded(java.io.Serializable msg,
                                                       Member sender,
                                                       java.lang.Object handleMessageSingleThreadedResult)
Specified by:
handleMessageMultiThreaded in interface MulticastRequestListener
See Also:
MulticastRequestListener.handleMessageMultiThreaded(java.io.Serializable, org.objectweb.tribe.common.Member, java.lang.Object)


Copyright © 2004 - ObjectWeb Consortium - All Rights Reserved.