| | |
|---|
| | | // receiver.sendMessageWithId(QUEUE_NAME, message, messageId); // 调用 sendMessageWithId 方法发送消息
|
|---|
| | | receiver.sendMessageWithId("hangzhou2", "Hello RabbitMQ!", "1");
|
|---|
| | | receiver.sendMessageWithId("hangzhou2", "Another message", "2");
|
|---|
| | | receiver.sendMessageWithId("hangzhou2", "Yet another message", "1"); // 这条消息会打印重复消息的错误信息
|
|---|
| | | receiver.sendMessageWithId("hangzhou2", "Another message", "3");
|
|---|
| | | receiver.sendMessageWithId("hangzhou2", "Another message", "4");
|
|---|
| | | receiver.sendMessageWithId("hangzhou2", "Another message", "5");
|
|---|
| | | // receiver.sendMessageWithId("hangzhou2", "Yet another message", "1"); // 这条消息会打印重复消息的错误信息
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | }
|
|---|
