top of page

Rabbit

"Save your soul before compiling.”

bugreaper-no-rabbit_compr.png

Module for interaction with RabbitMQ

Interaction:

Exchanges:
declareExchange(String, String)
deleteExchange(String)
pushToExchange(String, String, String)

Queues:
declareQueue(String)
bindQueue(String, String, String)
purgeQueue(String)
deleteQueue(String)
pushToQueue(String, String)
 

Asserts:

seeQueueIsEmpty(String)
seeQueueIsNotEmpty(String)
seeCountMessagesInQueueExactly(String, int)

seeMessagesContainsJson(String, String)
seeMessagesHaveEqualJson(String, String)
seeMessagesContainsText(String, String)
seeMessagesHaveEqualText(String, String)

Get data:

getNumberOfMessagesInQueue(String)
grabMessagesFromQueue(String)
readMessagesFromQueue(String)

Configs:

​.withMaxConsumeMessages(int)

​.withConsumerTimeoutMs(int)
.withAwaitMs(int)

INFO

IN progress

Info

in progress

INFO

In progress

© 2025 BUGREAPER

bottom of page