iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

For Q add x-queue-type args

Browse Source
This commit is contained in:
YuCheng Hu 2019-10-13 01:50:55 -04:00
parent 2a8b557a3f
commit da581fad6e
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
spring-amqp/src/main/java/com/ossez/springamqp/simple/AMQPHelloWorldMessageApp.java
View File

@ -56,13 +56,9 @@ public class AMQPHelloWorldMessageApp {
@Bean @Bean
Queue myQueue() { Queue myQueue() {
Map<String, Object> args = new HashMap<>(); Map<String, Object> 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, false, false, args);
// return new Queue(MY_QUEUE_NAME, NON_DURABLE);
} }