org.mactor.brokers.tibrv
Class TibcoRvMessageBroker

java.lang.Object
  org.mactor.brokers.AbstractMessageBroker
      org.mactor.brokers.tibrv.TibcoRvMessageBroker

All Implemented Interfaces:

MessageBroker

public class TibcoRvMessageBroker
extends AbstractMessageBroker

A message broker for Tibco Rendezvous (suitable for TIBCO BusinessWorks projects). (Add the tibrvj.jar library from your version of TIBCO Rv to the MActor classpath)

Author:

Lars Ivar Almli

See Also:

MessageBroker

Field Summary

Fields inherited from class org.mactor.brokers.AbstractMessageBroker

config, log

Constructor Summary

TibcoRvMessageBroker(MessageBrokersConfig.MessageBrokerConfig config)

Method Summary

protected void	finalize()
protected void	onFirstSubscribe(java.lang.String channel)
protected void	onLastSubscribe(java.lang.String channel)
void	publish(java.lang.String channel, Message message) Publish a message to a channel
Message	publishWithResponse(java.lang.String channel, Message message) Publish a message and expect a reponse (when dealing with synchrounous protcols)
void	terminate()

Methods inherited from class org.mactor.brokers.AbstractMessageBroker

raiseOnMessage, subscribe, unsubscribe

Methods inherited from class java.lang.Object

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

Constructor Detail

TibcoRvMessageBroker

public TibcoRvMessageBroker(MessageBrokersConfig.MessageBrokerConfig config)
                     throws MactorException

Throws:

MactorException

Method Detail

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

terminate

public void terminate()

Specified by:

terminate in interface MessageBroker

Overrides:

terminate in class AbstractMessageBroker

publish

public void publish(java.lang.String channel,
                    Message message)
             throws MactorException

Description copied from interface: MessageBroker

Publish a message to a channel

Parameters:

channel - the channel

message - the message

Throws:

MactorException - if some problem occures (this will cause the test to fail)

publishWithResponse

public Message publishWithResponse(java.lang.String channel,
                                   Message message)
                            throws MactorException

Description copied from interface: MessageBroker

Publish a message and expect a reponse (when dealing with synchrounous protcols)

Parameters:

channel - the channel

message - the message

Returns:

the response message

Throws:

MactorException - if some problem occures (this will cause the test to fail)

onFirstSubscribe

protected void onFirstSubscribe(java.lang.String channel)
                         throws MactorException

Specified by:

onFirstSubscribe in class AbstractMessageBroker

Throws:

MactorException

onLastSubscribe

protected void onLastSubscribe(java.lang.String channel)
                        throws MactorException

Specified by:

onLastSubscribe in class AbstractMessageBroker

Throws:

MactorException