Merge pull request #9210 from smtylmzx/patch-1

Consumer changed as DefaultConsumer.
2020-05-24 15:36:44 +03:00
parent dc4e33dd78 dcf9bb9cff
commit 4f104e62a8
1 changed files with 1 additions and 1 deletions
--- a/rabbitmq/src/main/java/com/baeldung/consumer/Receiver.java
+++ b/rabbitmq/src/main/java/com/baeldung/consumer/Receiver.java
@@ -17,7 +17,7 @@ public class Receiver {

        channel.queueDeclare(QUEUE_NAME, false, false, false, null);

-        Consumer consumer = new DefaultConsumer(channel) {
+        DefaultConsumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag,
                                       Envelope envelope, AMQP.BasicProperties properties,