diff --git a/src/main/java/com/palnet/process/message/config/MessageConfig.java b/src/main/java/com/palnet/process/message/config/MessageConfig.java index e7c30d8..5688531 100644 --- a/src/main/java/com/palnet/process/message/config/MessageConfig.java +++ b/src/main/java/com/palnet/process/message/config/MessageConfig.java @@ -7,8 +7,6 @@ import org.springframework.amqp.core.*; import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; 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.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -63,20 +61,20 @@ public class MessageConfig { .with(env.getProperty("message.websocket.routing-key")); } - @Bean - public CachingConnectionFactory cachingConnectionFactory() { - CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); - - connectionFactory.setHost(env.getProperty("spring.rabbitmq.host")); - connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port"))); - connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username")); - connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password")); - - return connectionFactory; - } +// @Bean +// public CachingConnectionFactory cachingConnectionFactory() { +// CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); +// +// connectionFactory.setHost(env.getProperty("spring.rabbitmq.host")); +// connectionFactory.setPort(Integer.parseInt(env.getProperty("spring.rabbitmq.port"))); +// connectionFactory.setUsername(env.getProperty("spring.rabbitmq.username")); +// connectionFactory.setPassword(env.getProperty("spring.rabbitmq.password")); +// +// return connectionFactory; +// } @Bean - public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { + public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory, Jackson2JsonMessageConverter converter) { RabbitTemplate rabbitTemplate = new RabbitTemplate(); rabbitTemplate.setConnectionFactory(connectionFactory);