RabbitMQ instance is created at cloudamqp.com
- Exchange of type
direct
is created. - Queue is created and bound to mentioned exchange with specific routing key.
- 10 messages are published to the exchange with mentioned routing key.
- Messages are consumed from the queue (with fake processing using timeout), number of messages and content of each message are verified. Basic acknowledgement is used (
autoAck = false
). - Exchange and queue are deleted.
Passed test console output:
Received messages:
Queue Message
Queue Message
Queue Message
Queue Message
Queue Message
Queue Message
Queue Message
Queue Message
Queue Message
Queue Message
- Two queues are created: one for sending message, one for receiving.
- Server is created with the following processing: income message is converted to upper case.
- Client is created, sent message to server and received response, response is verified (that it's in upper case).
- Queues are deleted.
Passed test console output:
Initial message: rpc queue message
Processed message: RPC QUEUE MESSAGE
Official RabbitMQ tutorials were used (see below).
- Rabbit MQ Tutorials: https://www.rabbitmq.com/getstarted.html