org.mactor.brokers.jms
Class JmsMessageBroker

java.lang.Object
  org.mactor.brokers.AbstractMessageBroker
      org.mactor.brokers.jms.JmsMessageBroker

All Implemented Interfaces:

MessageBroker

public class JmsMessageBroker
extends AbstractMessageBroker

A message broker for JMS (it should work with any JMS implementation - just add the client JMS libraries from the particular JMS product to the MActor class path)

Author:

Lars Ivar Almli

Field Summary

Fields inherited from class org.mactor.brokers.AbstractMessageBroker

config, log

Constructor Summary

JmsMessageBroker(MessageBrokersConfig.MessageBrokerConfig config)

Method Summary

void	createSubscriber(MessageBrokersConfig.MessageBrokerConfig.ChannelConfig channelConfig)
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, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JmsMessageBroker

public JmsMessageBroker(MessageBrokersConfig.MessageBrokerConfig config)

Method Detail

onFirstSubscribe

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

Specified by:

onFirstSubscribe in class AbstractMessageBroker

Throws:

MactorException

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)

createSubscriber

public void createSubscriber(MessageBrokersConfig.MessageBrokerConfig.ChannelConfig channelConfig)
                      throws MactorException

Throws:

MactorException

onLastSubscribe

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

Specified by:

onLastSubscribe in class AbstractMessageBroker

Throws:

MactorException

terminate

public void terminate()

Specified by:

terminate in interface MessageBroker

Overrides:

terminate in class AbstractMessageBroker