|
@@ -3,11 +3,14 @@ package com.example.common.common;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
+import com.fasterxml.jackson.databind.ObjectMapper;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.slf4j.LoggerFactory;
|
|
import org.springframework.amqp.core.*;
|
|
import org.springframework.amqp.core.*;
|
|
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
|
|
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
|
|
import org.springframework.amqp.rabbit.connection.CorrelationData;
|
|
import org.springframework.amqp.rabbit.connection.CorrelationData;
|
|
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.MessageConverter;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.context.annotation.Bean;
|
|
import org.springframework.stereotype.Component;
|
|
import org.springframework.stereotype.Component;
|
|
@@ -61,7 +64,6 @@ public class RabbitMQConfig {
|
|
return rabbitTemplate;
|
|
return rabbitTemplate;
|
|
}
|
|
}
|
|
|
|
|
|
-
|
|
|
|
@Bean
|
|
@Bean
|
|
public Queue queue(){
|
|
public Queue queue(){
|
|
return new Queue(MailConstants.MAIL_QUEUE_NAME);
|
|
return new Queue(MailConstants.MAIL_QUEUE_NAME);
|
|
@@ -74,4 +76,9 @@ public class RabbitMQConfig {
|
|
public Binding binding(){
|
|
public Binding binding(){
|
|
return BindingBuilder.bind(queue()).to(directExchange()).with(MailConstants.MAIL_ROUTING_KEY_NAME);
|
|
return BindingBuilder.bind(queue()).to(directExchange()).with(MailConstants.MAIL_ROUTING_KEY_NAME);
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ @Bean
|
|
|
|
+ public Jackson2JsonMessageConverter messageConverter() {
|
|
|
|
+ return new Jackson2JsonMessageConverter();
|
|
|
|
+ }
|
|
}
|
|
}
|