| | |
| | | |
| | | private BrokerReader reader; |
| | | |
| | | /** |
| | | * A "person" entry |
| | | */ |
| | | /** A "person" entry. */ |
| | | private Entry personEntry; |
| | | |
| | | private int replServerPort; |
| | |
| | | { |
| | | int count; |
| | | |
| | | /** |
| | | * Creates a new Stress Test Reader |
| | | */ |
| | | /** Creates a new Stress Test Reader. */ |
| | | public BrokerWriter(int count) |
| | | { |
| | | this.count = count; |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void run() |
| | | { |
| | |
| | | private Boolean finished = false; |
| | | |
| | | /** |
| | | * Creates a new Stress Test Reader |
| | | * Creates a new Stress Test Reader. |
| | | */ |
| | | public BrokerReader(ReplicationBroker broker) |
| | | { |
| | | this.broker = broker; |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void run() |
| | | { |
| | |
| | | } |
| | | |
| | | /** |
| | | * wait until the thread has finished its job then return the number of |
| | | * Wait until the thread has finished its job then return the number of |
| | | * received messages. |
| | | */ |
| | | public int getCount() |