RabbitMQ (1)

@Override public void configureMessageBroker(MessageBrokerRegistry registry) { registry.setPathMatcher(new AntPathMatcher(".")); registry.setApplicationDestinationPrefixes("/pub"); registry.enableStompBrokerRelay("/queue", "/topic", "/exchange", "/amq/queue"); }

@Configuration @EnableRabbit public class RabbitConfig { // Queue 등록 @Bean public Queue queue() { return new Queue(queueName, true); } // Exchange 등록 @Bean public TopicExchange exchange() { return new TopicExchange(exchangeName); } // Exchange와 Queue바인딩 @Bean public Binding binding(Queue queue, TopicExchange exchange) { return BindingBuilder.bind(queue).to(exchange).with(routingKey); } // RabbitMQ와의 메시지 통신을 담당하는 클래스 @Bean public RabbitTemplate rabbitTemplate() { RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory()); rabbitTemplate.setMessageConverter(jackson2JsonMessageConverter()); return rabbitTemplate; } // RabbitMQ와의 연결을 관리하는 클래스 @Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory factory = new CachingConnectionFactory(); factory.setHost(rabbitmqHost); factory.setPort(rabbitmqPort); factory.setUsername(rabbitmqUsername); factory.setPassword(rabbitmqPassword); factory.setVirtualHost("/"); return factory; } }