org.mactor.brokers.soap
Class SoapMessageBroker

java.lang.Object
  org.mactor.brokers.AbstractMessageBroker
      org.mactor.brokers.soap.SoapMessageBroker

All Implemented Interfaces:

MessageBroker

public class SoapMessageBroker
extends AbstractMessageBroker

A SOAP message broker that supports both incoming operations (MActor working as a SOAP-server) and outgoing operations (MActor working as a SOAP-client)

Author:

Lars Ivar Almli

See Also:

MessageBroker

Field Summary

Fields inherited from class org.mactor.brokers.AbstractMessageBroker

config, log

Constructor Summary

SoapMessageBroker(MessageBrokersConfig.MessageBrokerConfig config)

Method Summary

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

SoapMessageBroker

public SoapMessageBroker(MessageBrokersConfig.MessageBrokerConfig config)

Method Detail

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

terminate

public void terminate()

Specified by:

terminate in interface MessageBroker

Overrides:

terminate in class AbstractMessageBroker