|
|
@ -7,8 +7,6 @@ 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.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.rabbit.listener.SimpleMessageListenerContainer; |
|
|
|
|
|
|
|
import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter; |
|
|
|
|
|
|
|
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; |
|
|
|
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; |
|
|
|
import org.springframework.context.annotation.Bean; |
|
|
|
import org.springframework.context.annotation.Bean; |
|
|
|
import org.springframework.context.annotation.Configuration; |
|
|
|
import org.springframework.context.annotation.Configuration; |
|
|
@ -63,20 +61,20 @@ public class MessageConfig { |
|
|
|
.with(env.getProperty("message.websocket.routing-key")); |
|
|
|
.with(env.getProperty("message.websocket.routing-key")); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
// @Bean
|
|
|
|
public CachingConnectionFactory cachingConnectionFactory() { |
|
|
|
// public CachingConnectionFactory cachingConnectionFactory() {
|
|
|
|
CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); |
|
|
|
// CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
|
|
|
|
|
|
|
|
//
|
|
|
|
connectionFactory.setHost(env.getProperty("spring.rabbitmq.host")); |
|
|
|
// connectionFactory.setHost(env.getProperty("spring.rabbitmq.host"));
|
|
|
|
connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port"))); |
|
|
|
// connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port")));
|
|
|
|
connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username")); |
|
|
|
// connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username"));
|
|
|
|
connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password")); |
|
|
|
// connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password"));
|
|
|
|
|
|
|
|
//
|
|
|
|
return connectionFactory; |
|
|
|
// return connectionFactory;
|
|
|
|
} |
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
@Bean |
|
|
|
public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { |
|
|
|
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { |
|
|
|
RabbitTemplate rabbitTemplate = new RabbitTemplate(); |
|
|
|
RabbitTemplate rabbitTemplate = new RabbitTemplate(); |
|
|
|
|
|
|
|
|
|
|
|
rabbitTemplate.setConnectionFactory(connectionFactory); |
|
|
|
rabbitTemplate.setConnectionFactory(connectionFactory); |
|
|
|