org.mactor.framework
Class TestEngine.MessageWaiter

java.lang.Object
  org.mactor.framework.TestEngine.MessageWaiter

All Implemented Interfaces:

MessageSubscriber

Enclosing class:

TestEngine

public static class TestEngine.MessageWaiter
extends java.lang.Object
implements MessageSubscriber

Constructor Summary

TestEngine.MessageWaiter(java.lang.String channel)

Method Summary

java.lang.String	getChannel()
TestEngine.IncomingMessage	getMessage()
Message	onMessage(Message message) Invoked by the message broker when a message has been received (and accepted by the)
void	start(int maxTimeoutSeconds, int minMessageCount, int maxMessageCount, boolean blockUntilTimeout)
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestEngine.MessageWaiter

public TestEngine.MessageWaiter(java.lang.String channel)

Method Detail

getChannel

public java.lang.String getChannel()

stop

public void stop()

start

public void start(int maxTimeoutSeconds,
                  int minMessageCount,
                  int maxMessageCount,
                  boolean blockUntilTimeout)

onMessage

public Message onMessage(Message message)

Description copied from interface: MessageSubscriber

Invoked by the message broker when a message has been received (and accepted by the)

Specified by:

onMessage in interface MessageSubscriber

Returns:

null or a response message - when dealing with synchrounous protcols (the output from the message_respond node inside the message_receive node..).

getMessage

public TestEngine.IncomingMessage getMessage()
                                      throws MessageTimoutException

Throws:

MessageTimoutException