DTS运单数据同步

performance-web/src/main/java/com/clx/performance/config/RabbitBeanConfig.java

@@ -91,4 +91,12 @@ public class RabbitBeanConfig {
         return BindingBuilder.bind(orderOnDeadQueue()).to(orderOnDeadExchange()).with(RabbitKeyConstants.ORDER_ON_ROUTE_KEY);
     }
 
+/*    *//**
+     * 运单同步队列
+     *//*
+    @Bean
+    public Queue orderChildQueue() {
+        return new Queue(RabbitKeyConstants.CLX_PERFORMANCE_ORDER_CHILD_QUEUE, true);
+    }*/
+
 }

performance-web/src/main/java/com/clx/performance/listener/OrderChildDtsListener.java

@@ -16,12 +16,11 @@ public class OrderChildDtsListener  {
 
 
     @RabbitHandler
-    public void dealMessage(byte[] message) {
+    public void dealMessage(String message) {
         try {
-            String msg = new String(message);
-            log.info("DTS消息同步开始, database:order_service, msg:{}", msg);
+            log.info("DTS消息同步开始, database:order_service, msg:{}", message);
 
-            JSONObject object = JSON.parseObject(msg);
+            JSONObject object = JSON.parseObject(message);
 
             JSONObject beforeMap = object.getJSONObject("beforeMap");
             JSONObject afterMap = object.getJSONObject("afterMap");