| | |
|---|
| | | RabbitMQUtils receiver = new RabbitMQUtils();
|
|---|
| | |
|
|---|
| | | try {
|
|---|
| | | String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));
|
|---|
| | | System.out.println("Received message: " + receivedMessage);
|
|---|
| | |
|
|---|
| | | receiver.consumeMessageById("2",QUEUE_NAME);
|
|---|
| | | // String receivedMessage = receiver.consumeSelectedMessage(1,QUEUE_NAME);
|
|---|
| | | // String receivedMessage = String.valueOf(receiver.readMessages(QUEUE_NAME,false));
|
|---|
| | | // System.out.println("Received message: " + receivedMessage);
|
|---|
| | | } catch (Exception e) {
|
|---|
| | | e.printStackTrace();
|
|---|
| | | }
|
|---|
