From da581fad6e8111615e733115dd64fef948b4aa2b Mon Sep 17 00:00:00 2001 From: YuCheng Hu Date: Sun, 13 Oct 2019 01:50:55 -0400 Subject: [PATCH] For Q add x-queue-type args --- .../ossez/springamqp/simple/AMQPHelloWorldMessageApp.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java b/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java index 63c46fac1a..9ccef845a2 100644 --- a/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java +++ b/spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java @@ -56,13 +56,9 @@ public class AMQPHelloWorldMessageApp { @Bean Queue myQueue() { Map args = new HashMap<>(); -// // set the queue with a dead letter feature -// args.put("x-queue-type", "classic"); + args.put("x-queue-type", "classic"); return new Queue(MY_QUEUE_NAME, NON_DURABLE, false, false, args); -// return new Queue(MY_QUEUE_NAME, NON_DURABLE); - - }