Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq.usecases
Class BecksNetworkTest.SimulationState  view BecksNetworkTest.SimulationState download BecksNetworkTest.SimulationState.java

java.lang.Object
  extended byorg.activemq.usecases.BecksNetworkTest.SimulationState
Enclosing class:
BecksNetworkTest

private static final class BecksNetworkTest.SimulationState
extends java.lang.Object


Field Summary
static int FINISHED
           
static int INITIALIZED
           
private  java.util.Set m_messagesConsumed
           
private  java.util.Set m_messagesProduced
           
private  int m_numExpectedMessages
           
private  int m_state
           
private  java.lang.Object m_stateLock
           
static int RUNNING
           
 
Constructor Summary
BecksNetworkTest.SimulationState(int numMessages)
           
 
Method Summary
 int getState()
           
 void onMessageConsumed(java.lang.String consumerId, java.lang.String messageBody)
           
 void onMessageProduced(java.lang.String producerId, java.lang.String messageBody)
           
 void setState(int newState)
           
 java.lang.String toString()
          Convert this Object to a human-readable String.
 void waitForSimulationState(int state)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

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
Constructor Detail

BecksNetworkTest.SimulationState

public BecksNetworkTest.SimulationState(int numMessages)
Method Detail

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()).