Notifies interested listeners about message arrival and important test stats, the number of messages
remaining in the test, and the messages send timestamp.
PingAsyncTestPerf is a performance test that outputs multiple timings from its test method, using the timing controller
interface supplied by the test runner from a seperate listener thread.
PingLatencyTestPerf is a performance test that outputs multiple timings from its test method, using the timing
controller interface supplied by the test runner from a seperate listener thread.
PingPongTestPerf is a full round trip ping test, that has been written with the intention of being scaled up to run
many times simultaneously to simluate many clients/producer/connections.
PingTestPerf is a ping test, that has been written with the intention of being scaled up to run many times
simultaneously to simluate many clients/producers/connections.
Sends the specified number of pings, asynchronously outputs timings on every batch boundary, and waits until
all replies have been received or a time out occurs before exiting this method.
Sends the specified number of pings, asynchronously outputs timings on every batch boundary, and waits until all
replies have been received or a time out occurs before exiting this method.
This flag is used to indicate that the user should be prompted to a kill a broker, in order to test
failover, immediate after committing a transaction.
This flag is used to indicate that the user should be prompted to kill a broker, in order to test
failover, immediately before committing a transaction.
This id generator is used to generate ids to append to the queue name to ensure that queues can be unique when
creating multiple ping producers in the same JVM.
Holds a monitor which is used to synchronize sender and receivers threads, where the sender has elected
to wait until the number of unreceived message is reduced before continuing to send.