From 2bad94abcf533cb3fde3f64fe660b9d9103b0f48 Mon Sep 17 00:00:00 2001
From: xiangwb <xiangwb@drore.com>
Date: Wed, 9 May 2018 16:43:36 +0800
Subject: [PATCH] merge

---
 .../src/main/java/com/xwbing/rabbit/RabbitConfig.java        | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/boot-service/src/main/java/com/xwbing/rabbit/RabbitConfig.java b/boot-service/src/main/java/com/xwbing/rabbit/RabbitConfig.java
index 011b4f8..7e6235a 100644
--- a/boot-service/src/main/java/com/xwbing/rabbit/RabbitConfig.java
+++ b/boot-service/src/main/java/com/xwbing/rabbit/RabbitConfig.java
@@ -1,6 +1,5 @@
 package com.xwbing.rabbit;
 
-import com.alibaba.fastjson.JSONArray;
 import lombok.Data;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -56,7 +55,7 @@ public class RabbitConfig {
     @Bean
     public RabbitTemplate rabbitTemplate() {
         RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory());
-//        rabbitTemplate.setEncoding("UTF-8");
+        rabbitTemplate.setEncoding("UTF-8");
         rabbitTemplate.setMandatory(true);
         //相应交换机接收后异步回调
         rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> {
@@ -68,8 +67,6 @@ public class RabbitConfig {
         });
         //无相应队列与交换机绑定异步回调
         rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> {
-            byte[] body = message.getBody();
-            JSONArray jsonArray = new JSONArray();
             String msg = new String(message.getBody());
             logger.error("消息:{} 发送失败, 应答码:{} 原因:{} 交换机:{} 路由键:{}", msg, replyCode, replyText, exchange, routingKey);
         });