|
@@ -1,5 +1,6 @@
|
|
package com.free.mq;
|
|
package com.free.mq;
|
|
|
|
|
|
|
|
+import com.fasterxml.jackson.annotation.JsonInclude;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.Logger;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
@@ -12,7 +13,6 @@ import org.springframework.stereotype.Service;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import com.free.entity.TransferApply;
|
|
import com.free.entity.TransferApply;
|
|
-import com.free.service.system.CustomerService;
|
|
|
|
import com.free.utils.Utils;
|
|
import com.free.utils.Utils;
|
|
|
|
|
|
@Service
|
|
@Service
|
|
@@ -33,6 +33,7 @@ public class MqService {
|
|
public void sendMsg(String ex, String queue, Map msg) throws JsonProcessingException {
|
|
public void sendMsg(String ex, String queue, Map msg) throws JsonProcessingException {
|
|
String strMsg = null;
|
|
String strMsg = null;
|
|
ObjectMapper mapper = new ObjectMapper();
|
|
ObjectMapper mapper = new ObjectMapper();
|
|
|
|
+ mapper.setSerializationInclusion(JsonInclude.Include.NON_NULL);
|
|
strMsg = mapper.writeValueAsString(msg);
|
|
strMsg = mapper.writeValueAsString(msg);
|
|
rabbitTemplate.convertAndSend(ex, queue, strMsg);
|
|
rabbitTemplate.convertAndSend(ex, queue, strMsg);
|
|
}
|
|
}
|