我使用Spring JMS和ActiveMQ通过ActiveMQ主题(发布/订阅)将消息从发送者发送到多个监听器。到目前为止,所有的监听器都可以接收来自发送者的消息。但是我想添加一个功能,当一个特定的监听器,比如listener1,收到消息时,listener1会向发送者发送一个回执确认。我遵循中的注释,在发送者中创建了一个TemporaryQueue,并在发送者和接收者中使用ReplyTo来获取从侦听器到发送者的确认消息。
我的发件人类是:
public class CustomerStatusSender {
private JmsTemplate jmsTemplate;
在试图将邮件发送到队列时,我得到了以下错误:
Exception in thread "main" org.springframework.jms.UncategorizedJmsException: Uncategorized exception occured during JMS processing; nested exception is javax.jms.JMSException: Could not connect to broker URL: http://localhost:8161. Reason: java.io.IOException: Failed
我面临的一个问题是,Acpache ActiveMQ中的消息在控制台中被排除队列,但是消费者方法没有被调用,它有@JmsListener,尽管使用者的数量显示了7。
配置代码:
@Configuration
@EnableJms
public class JMSConfiguration {
private static final String DEFAULT_BROKER_URL = "tcp://localhost:61616";
private static final long DEFAULT_RECEIVE_TIMEOUT = 1000L;
我正在尝试在我的应用程序中使用activemq,但是当我试图连接到localhost时,仍然会出现错误。
log4j:WARN No appenders could be found for logger (org.springframework.core.env.StandardEnvironment).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Excep