com.metamatrix.common.messaging.jgroups
Class JGroupsMessageBus

java.lang.Object
  com.metamatrix.common.messaging.jgroups.JGroupsMessageBus

All Implemented Interfaces:

MessageBus

public class JGroupsMessageBus
extends java.lang.Object
implements MessageBus

Field Summary

static java.lang.String	MESSAGE_KEY
static int	REMOTE_TIMEOUT

Constructor Summary

JGroupsMessageBus(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

Field Detail

MESSAGE_KEY

public static final java.lang.String MESSAGE_KEY

See Also:

Constant Field Values

REMOTE_TIMEOUT

public static final int REMOTE_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

JGroupsMessageBus

public JGroupsMessageBus(ChannelProvider channelProvider,
                         java.lang.String clusterName)
                  throws org.jgroups.ChannelException

Throws:

org.jgroups.ChannelException

Method Detail

unExport

public void unExport(java.lang.Object object)

Specified by:

unExport in interface MessageBus

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

processEvent

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

Specified by:

processEvent in interface MessageBus

Throws:

MessagingException

See Also:

MessageBus.processEvent(java.util.EventObject)

shutdown

public void shutdown()
              throws MessagingException

Specified by:

shutdown in interface MessageBus

Throws:

MessagingException

addListener

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

Specified by:

addListener 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