org.jboss.jrunit.communication
Class MessageBus

java.lang.Object
  extended by org.jboss.jrunit.communication.MessageBus

public class MessageBus
extends java.lang.Object

Author:
Tom Elrod, Clebert Suconic

Constructor Summary
MessageBus()
           
 
Method Summary
 void addReceiver(MessageBusListener listener)
           
 java.io.Serializable getCache()
          Called on the coordinator to obtains its cache
 int getNumberOfMembers()
           
 void handleNotification(java.io.Serializable n)
           
 void memberJoined(Address mbr)
           
 void memberLeft(Address mbr)
           
 boolean removeReceiver(MessageBusListener listener)
           
 void sendMessage(java.io.Serializable msg)
           
 void setMememberChangeListener(RemoteMemberListener listener)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageBus

public MessageBus()
           throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

start

public void start()
           throws java.lang.Exception
Throws:
java.lang.Exception

stop

public void stop()

addReceiver

public void addReceiver(MessageBusListener listener)

removeReceiver

public boolean removeReceiver(MessageBusListener listener)

handleNotification

public void handleNotification(java.io.Serializable n)

getCache

public java.io.Serializable getCache()
Called on the coordinator to obtains its cache


memberJoined

public void memberJoined(Address mbr)

memberLeft

public void memberLeft(Address mbr)

getNumberOfMembers

public int getNumberOfMembers()

sendMessage

public void sendMessage(java.io.Serializable msg)

setMememberChangeListener

public void setMememberChangeListener(RemoteMemberListener listener)


JRunit, a JUnit extension for distributed client/server tests.