Consumer changed as DefaultConsumer.

2020-05-01 20:50:13 +03:00
parent 30bb6adc14
commit dcf9bb9cff
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,