|
@@ -6,6 +6,7 @@ import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
|
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
|
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
|
|
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
|
|
|
|
+import org.springframework.boot.autoconfigure.data.redis.JedisClientConfigurationBuilderCustomizer;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Configuration;
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
|
|
|
@@ -26,7 +27,6 @@ public class RabbitMqConfig {
|
|
@Resource
|
|
@Resource
|
|
private ProducerCallback producerCallback;
|
|
private ProducerCallback producerCallback;
|
|
|
|
|
|
-
|
|
|
|
/**
|
|
/**
|
|
* 指定序列化转换器,否则mq消息存进去
|
|
* 指定序列化转换器,否则mq消息存进去
|
|
* @return
|
|
* @return
|