|
CoCoME TestDriver for Reference Implementation | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.cocome.tradingsystem.testdriver.UpdateReceiver
public class UpdateReceiver
This is the base for all classes implementing the IUpdateReceiver. The idea is to listen on a specified channel and keep only messages of certain types.
Field Summary | |
---|---|
private boolean |
isNewMessage
A flag indicating if this is a new message or if this has been read before. |
private java.io.Serializable |
lastRelevantMessage
The last message (of those we are interested in) received. |
private java.lang.Class<?>[] |
relevantMessages
The array of message types we are interested in. |
Constructor Summary | |
---|---|
UpdateReceiver(javax.jms.TopicSubscriber subscriber,
java.lang.Class<?>... relevantMessageClasses)
Creates a new update receiver. |
Method Summary | |
---|---|
protected void |
expectMessage(java.lang.Class<? extends java.io.Serializable> messageType)
Signals that the next expected message should be of the given type. |
protected java.io.Serializable |
getLastRelevantMessage()
Returns the last relevant message received. |
void |
onMessage(javax.jms.Message message)
|
void |
waitForUpdate(int maxMilliseconds)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private java.io.Serializable lastRelevantMessage
private boolean isNewMessage
private final java.lang.Class<?>[] relevantMessages
Constructor Detail |
---|
public UpdateReceiver(javax.jms.TopicSubscriber subscriber, java.lang.Class<?>... relevantMessageClasses) throws javax.jms.JMSException
subscriber
- the subscriber to get the messages from.relevantMessageClasses
- the classes of messages we are interested in.
javax.jms.JMSException
Method Detail |
---|
public void waitForUpdate(int maxMilliseconds) throws java.util.concurrent.TimeoutException
waitForUpdate
in interface org.cocome.tradingsystem.systests.interfaces.IUpdateReceiver
java.util.concurrent.TimeoutException
protected void expectMessage(java.lang.Class<? extends java.io.Serializable> messageType)
messageType
- the type of the message expected.protected java.io.Serializable getLastRelevantMessage()
public void onMessage(javax.jms.Message message)
onMessage
in interface javax.jms.MessageListener
|
CoCoME TestDriver for Reference Implementation | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |