java.lang.Object
org.activemq.usecases.BecksNetworkTest.SimulationState
- Enclosing class:
- BecksNetworkTest
- private static final class BecksNetworkTest.SimulationState
- extends java.lang.Object
INITIALIZED
public static final int INITIALIZED
- See Also:
- Constant Field Values
RUNNING
public static final int RUNNING
- See Also:
- Constant Field Values
FINISHED
public static final int FINISHED
- See Also:
- Constant Field Values
m_stateLock
private final java.lang.Object m_stateLock
m_state
private int m_state
m_numExpectedMessages
private final int m_numExpectedMessages
m_messagesProduced
private final java.util.Set m_messagesProduced
m_messagesConsumed
private final java.util.Set m_messagesConsumed
BecksNetworkTest.SimulationState
public BecksNetworkTest.SimulationState(int numMessages)
getState
public int getState()
setState
public void setState(int newState)
waitForSimulationState
public void waitForSimulationState(int state)
throws java.lang.InterruptedException
onMessageProduced
public void onMessageProduced(java.lang.String producerId,
java.lang.String messageBody)
onMessageConsumed
public void onMessageConsumed(java.lang.String consumerId,
java.lang.String messageBody)
toString
public java.lang.String toString()
- Description copied from class:
java.lang.Object
- Convert this Object to a human-readable String.
There are no limits placed on how long this String
should be or what it should contain. We suggest you
make it as intuitive as possible to be able to place
it into System.out.println() 55
and such.
It is typical, but not required, to ensure that this method
never completes abruptly with a java.lang.RuntimeException.
This method will be called when performing string
concatenation with this object. If the result is
null, string concatenation will instead
use "null".
The default implementation returns
getClass().getName() + "@" +
Integer.toHexString(hashCode()).