com.metamatrix.common.messaging
Class VMMessageBus

java.lang.Object
  com.metamatrix.common.messaging.VMMessageBus

All Implemented Interfaces:

MessageBus

public class VMMessageBus
extends java.lang.Object
implements MessageBus

Constructor Summary

VMMessageBus(ChannelProvider channelProvider, java.lang.String clusterName)

Method Summary

void	addListener(java.lang.Class eventClass, EventObjectListener listener)
java.io.Serializable	export(java.lang.Object object, java.lang.Class[] targetClasses)
java.lang.Object	getRPCProxy(java.lang.Object object)
void	processEvent(java.util.EventObject obj)
void	removeListener(java.lang.Class eventClass, EventObjectListener listener)
void	removeListener(EventObjectListener listener)
void	shutdown()
void	unExport(java.lang.Object object)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

VMMessageBus

public VMMessageBus(ChannelProvider channelProvider,
                    java.lang.String clusterName)
             throws MetaMatrixComponentException

Throws:

MetaMatrixComponentException

Method Detail

addListener

public void addListener(java.lang.Class eventClass,
                        EventObjectListener listener)
                 throws MessagingException

Specified by:

addListener in interface MessageBus

Throws:

MessagingException

shutdown

public void shutdown()
              throws MessagingException

Specified by:

shutdown in interface MessageBus

Throws:

MessagingException

removeListener

public void removeListener(java.lang.Class eventClass,
                           EventObjectListener listener)
                    throws MessagingException

Specified by:

removeListener in interface MessageBus

Throws:

MessagingException

removeListener

public void removeListener(EventObjectListener listener)
                    throws MessagingException

Specified by:

removeListener in interface MessageBus

Throws:

MessagingException

processEvent

public void processEvent(java.util.EventObject obj)
                  throws MessagingException

Specified by:

processEvent in interface MessageBus

Throws:

MessagingException

export

public java.io.Serializable export(java.lang.Object object,
                                   java.lang.Class[] targetClasses)

Specified by:

export in interface MessageBus

getRPCProxy

public java.lang.Object getRPCProxy(java.lang.Object object)

Specified by:

getRPCProxy in interface MessageBus

unExport

public void unExport(java.lang.Object object)

Specified by:

unExport in interface MessageBus