Consumer changed as DefaultConsumer.

This commit is contained in:
Samet Yılmaz 2020-05-01 20:50:13 +03:00 committed by GitHub
parent e65cfc7bd0
commit 44cb3a230a
1 changed files with 1 additions and 1 deletions

View File

@ -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,