从别人手里拿到的代码是这样字的:@Component
public class SmsClient {
@Autowired
private SmsSendService smsSendService;
/**
* 消费者数量,默认10
*/
private static final int DEFAULT_CONCURRENT = 10;
/**
* 每个消费者获取最大投递数量,默认50
*/
private static final int DEFAULT_PREFETCH_COUNT = 5;
@Bean
public MessageConverter jsonMessageConverter(ObjectMapper objectMapper) {
return new Jackson2JsonMessageConverter(objectMapper);
}
@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
RabbitTemplate template = new RabbitTemplate(connectionFactory);
template.setMessageConverter(new Jackson2JsonMessageConverter());
return template;
}
@Bean
public SimpleRabbitListenerContainerFactory simpleRabbitListenerContainerFactory(
SimpleRabbitListenerContainerFactoryConfigurer configurer, ConnectionFactory connectionFactory) {
SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
factory.setPrefetchCount(DEFAULT_PREFETCH_COUNT);
factory.setConcurrentConsumers(DEFAULT_CONCURRENT);
factory.setAcknowledgeMode(AcknowledgeMode.MANUAL);
configurer.configure(factory, connectionFactory);
return factory;
}
@RabbitListener(queues = MqConstant.QUEUE_NAME, containerFactory = "simpleRabbitListenerContainerFactory")
@RabbitHandler
public void process(@Payload MessageBody messageBody,
@Headers Map<String, Object> headers,
Channel channel) throws Exception {....}
但这里只是监听一个队列,请问我怎样可以按照这个模式实现监听多个队列?