嵌入式经纪人ActiveMQ的配置

Question

这是我将消息发送到嵌入式经纪人的配置。另外，第一个BEAN方法仅用于创建和启动代理。它不会返回任何实例。此代码会启动经纪人吗？我已经使用了JMS模板的发送方法将消息发送到下面提到的主题中。我已经编写了CreateBrokerService，以创建和运行经纪人。

@Configuration
@EnableJms
public class JMSConfig {
    public static final String DEFAULT_BROKER_URL = "tcp://localhost:61616";
    public static final String COMMENT_QUEUE = "comment-queue";
    @Bean
    public void createBrokerService() throws Exception {
        BrokerService broker = new BrokerService();
        TransportConnector connector = new TransportConnector();
        connector.setUri(new URI("tcp://localhost:61616"));
        broker.addConnector(connector);
        broker.start();
    }
    @Bean
    public ActiveMQConnectionFactory connectionFactory(){
        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory();
        connectionFactory.setBrokerURL(DEFAULT_BROKER_URL);
        return connectionFactory;
    }   
    @Bean
    public JmsTemplate jmsTemplate(){
        JmsTemplate template = new JmsTemplate();
        template.setConnectionFactory(connectionFactory());
        template.setDefaultDestinationName(COMMENT_QUEUE);
        template.setPubSubDomain(true);
        template.setSessionTransacted(true);
        return template;
    }

Answer 1

   @Bean
public void createBrokerService() throws Exception {
    BrokerService broker = new BrokerService();
    TransportConnector connector = new TransportConnector();
    connector.setUri(new URI("tcp://localhost:61616"));
    broker.addConnector(connector);
    broker.start();
}

这是不正确的，@bean应该返回经纪人，然后您使用应用程序中某个地方的代理实例来启动它。