1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70
|
@Configuration public class MqBeanConfig {
@Bean("container") RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter test1ListenerAdapter, MessageListenerAdapter test2ListenerAdapter, MessageListenerAdapter test3ListenerAdapter, MessageListenerAdapter test4ListenerAdapter, MessageListenerAdapter test5ListenerAdapter) { RedisMessageListenerContainer container = new RedisMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.addMessageListener(test1ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST1)); container.addMessageListener(test2ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST2)); container.addMessageListener(test3ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST3)); container.addMessageListener(test4ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST4)); container.addMessageListener(test5ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST1)); container.addMessageListener(test5ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST2)); container.addMessageListener(test5ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST3)); container.addMessageListener(test5ListenerAdapter, new PatternTopic(Constant.MQ_TOPIC_TEST4)); return container; }
@Bean MessageListenerAdapter test1ListenerAdapter(ReceiverRedisMessage receiver) { return new MessageListenerAdapter(receiver, "test1Listener"); }
@Bean MessageListenerAdapter test2ListenerAdapter(ReceiverRedisMessage receiver) { return new MessageListenerAdapter(receiver, "test2Listener"); }
@Bean MessageListenerAdapter test3ListenerAdapter(ReceiverRedisMessage receiver) { return new MessageListenerAdapter(receiver, "test3Listener"); }
@Bean MessageListenerAdapter test4ListenerAdapter(ReceiverRedisMessage receiver) { return new MessageListenerAdapter(receiver, "test4Listener"); }
@Bean MessageListenerAdapter test5ListenerAdapter(ReceiverRedisMessage receiver) { return new MessageListenerAdapter(receiver, "test5Listener"); } }
|