Java连接多个mq,springboot整合mq(多个队列)

1.添加mq的依赖，这里使用的是activemq

org.springframework.boot

spring-boot-starter-activemq

2.配置yml

spring.activemq.broker-url=tcp://172.16.154.27:61616

spring.activemq.user=admin

spring.activemq.password=123456

spring.activemq.in-memory=true

spring.activemq.pooled=false

3.添加配置文件整合mq

@Configuration

public class ActiveMQConfig {

@Bean

public JmsListenerContainerFactory> queueListenerFactory(@Qualifier("activeMQConnectionFactory") ActiveMQConnectionFactory connectionFactory) {

DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();

SimpleMessageListenerContainer container=new SimpleMessageListenerContainer();

container.setConcurrentConsumers(3);

container.setConnectionFactory(connectionFactory);

factory.