rabbit 配置

src/main/java/com/uas/ps/message/rabbit/BaseMessageListener.java

@@ -74,7 +74,7 @@ public abstract class BaseMessageListener implements ChannelAwareMessageListener
             AMQP.BasicProperties.Builder builder = new AMQP.BasicProperties.Builder();
             builder.expiration(RabbitConstants.DELAY_TIME);
 
-            channel.basicPublish(RabbitConstants.AMQ_DIRECT, dalayQueueName, builder.build(), messageJson.getBytes());
+            channel.basicPublish("", dalayQueueName, builder.build(), messageJson.getBytes());
             logger.info("发送延时消息[RabbitMessageListener.sendDelayMessage].正常,messageJson:{},queueName:{}", messageJson, queueName);
         } catch (IOException e) {
             logger.error("发送延时消息[RabbitMessageListener.sendDelayMessage].异常,messageJson:{},queueName:{}", messageJson, queueName, e);

src/main/java/com/uas/ps/message/rabbit/RabbitConfig.java

@@ -28,13 +28,11 @@ public class RabbitConfig {
 
     @PostConstruct
     public void init() {
-        amqpAdmin.declareExchange(new DirectExchange(RabbitConstants.AMQ_DIRECT, true, false, null));
 
         Map<String, Object> args = new HashMap<String, Object>();
-        args.put("x-dead-letter-exchange", RabbitConstants.AMQ_DIRECT);
+        args.put("x-dead-letter-exchange", "");
         args.put("x-dead-letter-routing-key", RabbitConstants.DEAD_LETTER_ROUTING_KEY);
         amqpAdmin.declareQueue(new Queue(RabbitConstants.INQUIRY_MESSAGE + RabbitConstants.DELAY_QUEUE_NAME_SUFFIX, true, false, false, args));
-        amqpAdmin.declareBinding(new Binding(RabbitConstants.INQUIRY_MESSAGE + RabbitConstants.DELAY_QUEUE_NAME_SUFFIX, Binding.DestinationType.QUEUE, RabbitConstants.AMQ_DIRECT, RabbitConstants.DEAD_LETTER_ROUTING_KEY, null));
     }
 
 

src/main/java/com/uas/ps/message/rabbit/RabbitConstants.java

@@ -17,15 +17,11 @@ public class RabbitConstants {
      */
     public static final String INQUIRY_MESSAGE = "inquiry_message";
 
-    /**
-     * direct exchange name
-     */
-    public static final String AMQ_DIRECT = "amq.direct";
 
     /**
      * 死信队列路由key
      */
-    public static final String DEAD_LETTER_ROUTING_KEY = "message_delay";
+    public static final String DEAD_LETTER_ROUTING_KEY = "inquiry_message";
 
     /**
      * 延时时间，单位：毫秒