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."
"Each log is a confession of the machine.”
Interaction:
pushToQueue
cleanQueue
cleanQueues
Asserts:
seeQueueIsEmpty
seeQueueIsNotEmpty
seeCountMessagesInQueueExactly
seeMessagesContainJson
seeMessagesHaveEqualJson
seeMessagesContainText
seeMessagesHaveEqualText
Get data:
grabMessagesFromQueue
readMessagesFromQueue
getQueueMessageCount
Configs:
.withMaxConsumeMessages
.withConsumerTimeoutMs
.withAwaitMs
Interactions
pushToQueue
(String queueName, String textMessage)
Push message to queue
attach: message
cleanQueue
(String queueName)
Clean queue
(by consumer)
cleanQueues
(String... queuesNames)
Clean list of queues
(by consumer)
Asserts
seeQueueIsEmpty
(String queueName)
Assert that queue is empty
seeQueueIsNotEmpty
(String queueName)
Assert that queue is not empty
left messages in queue
seeCountMessagesInQueueExactly
(String queueName, int expectedCount)
Assert number of messages in queue
left messages in queue
seeMessagesContainJson
(String queueName, String expectedJsonPart)
Assert that at least message in topic contains JSON (part OR equal)
attach: messages list/expectedJsonPart
seeMessagesHaveEqualJson
(String queueName, String expectedJson)
Assert that at least one of message in queue equal expected JSON
attach: messages list/expectedJson
seeMessagesContainText
(String queueName, String expectedPart)
Assert that at least one of messages in queue contains string
attach: messages list
seeMessagesHaveEqualText
(String queueName, String expectedText)
Assert that at least one of messages in queue equal to string
attach: messages list
Get Data
grabMessagesFromQueue
(String queueName)
Grab (consume) messages to list
return AssertableStringList
grab only last messages (dafault value or setter)
await first message
attach: messages
readMessagesFromQueue
(String queueName)
Grab (read) messages to list (left in queue)
return AssertableStringList
attach: messages
getQueueMessageCount
(String queueName)
Get count of all messages in queue
return int
Configs
.withMaxConsumeMessages
(int awaitMs)
Overrides the maxConsumedMessages default
max count of messages from end that will be consumed before break
.withConsumerTimeoutMs
(int maxMessages)
Overrides the consumerTimeoutMs default
max ms timeout for consumer
.withAwaitMs
(int consumerTimeoutMs)
Overrides the awaitMs default
ms wait for first message