Java test helper
"The worst bugs are those that compile without warning."
"The system does not punish. It only compiles the truth."
"The purest release is the one that needs no comment."
"Save your soul before compiling.”
Interaction:
Exchanges:
declareExchange
deleteExchange
pushToExchange
Queues:
declareQueue
bindQueue
purgeQueue
deleteQueue
pushToQueue
Asserts:
seeQueueIsEmpty
seeQueueIsNotEmpty
seeQueueMessageCountIsExactly
seeMessagesContainJson
seeMessagesHaveEqualJson
seeMessagesContainText
seeMessagesHaveEqualText
Get data:
getQueueMessageCount
grabMessagesFromQueue
readMessagesFromQueue
Configs:
.withMaxConsumeMessages(int)
.withConsumerTimeoutMs(int)
.withAwaitMs(int)
Interactions
declareExchange
(String exchange, String exchangeType)
Declare exchange
deleteExchange
(String exchange)
Delete exchange
pushToExchange
(String exchange, String routingKey, String message)
Push message to exchange with routing-key
declareQueue
(String queue)
Declare queue with default parameters
durable=false, exclusive=false, autoDelete=false, arguments=null
declareQueue
(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
Declare queue with parameters
pushToQueue
(String queue, String message)
Push message to queue
attach: message
bindQueue
(String queue, String exchange, String routingKey)
Bind queue to exchange by routing-key
purgeQueue
(String queue)
Purge queue
remove all messages from queue
deleteQueue
(String queue)
Delete queue
INFO
IN progress
Info
in progress
INFO
In progress