我需要在与创建会话不同的会话中确认消息。如果在给定时间内未确认已使用的消息,则应将其添加回队列中。是否可以使用JMS(计划使用ActiveMQ作为代理)。 解决方案如下: 我认为不可能。 如果消息已被消耗,则应由使用者会话对其进行确认(可以是自动或客户端确认)。确认是保证消息传递和事务处理机制的关键。 JMS服务器确保使用确认成功发送/使用消息。 关于超时问题,如果JMS服务器在给定时间段内未收到确认,则通常将在设置JMSRedelivered标志的情况下重新发送该消息。我不认为它将被添加回队列,然后可以被同一会话…

2020年11月11日 0条评论 38点热度 阅读全文

遇到错误, org.springframework.integration.MessageDeliveryException: Dispatcher has no subscribers for channel 'org.springframework.web.context.WebApplicationContext:.myGatewayChannel'. Caused by: org.springframework.integration.MessageDispatchingException: Dispatc…

2020年10月25日 0条评论 29点热度 阅读全文

无法通过jmx-exporter从activemq抓取指标 我将jmx导出器下载到我的虚拟机,并按照说明运行命令,如下所示: java -javaagent:./jmx_prometheus_javaagent-0.12.0.jar=8980:config.yaml -jar /usr/local/tomcat/apache-activemq/apache-activemq-5.8.0_56/bin/activemq.jar 我得到一些关于activemq的输出信息。然后我尝试将其卷曲:curl http://lo…

2020年10月24日 0条评论 35点热度 阅读全文

我在本地计算机上运行ActiveMQ 5.9.0发行版以用于开发目的(Windows 7)。我使用AMQP作为协议,使用Apache qpid作为客户端来使用来自activeMQ代理(AMQP 1.0协议)的消息(发布订阅)。重复日志:警告传输连接到tcp:<ip>失败:java.net.SocketException:连接重置 虽然我注释掉了所有的协议除了在activemq.xmlamqp,还是周期性我看到在代理日志下面的消息(标准输出): WARN: Transport Connect to tcp…

2020年10月19日 0条评论 39点热度 阅读全文

是否有人找到解决方法或看到管理控制台在ActiveMQ 5.4.1和5.4.0中不起作用的问题? 我正在使用开箱即用的配置。我打开调试级别的日志记录,但是当我转到http:// [myIp]:8161 / admin时,我看不到任何码头启动错误 HTTP错误:503 问题访问/。原因: Service Unavailable 该请求的日志条目Jetty输出为 2010-10-01 14:20:11,599 |调试| 在以下位置请求/favicon.ico org.eclipse.jetty.server.nio.S…

2020年10月17日 0条评论 60点热度 阅读全文

我有一个消费者收到的activemq消息,如下所示: 0327700000260000460000010000047000108Full TalkValue Offer! Get talkvalue of Rs.62 on Recharge of Rs.62.Yourlast Call Charge is 1.000.Your Main Balance is Rs 47.000.00001500001291965355668000001800001604952312808659f9 我必须使用java将消息解码为以…

2020年10月15日 0条评论 21点热度 阅读全文

我想知道如何在Active MQ中正确使用连接池。 目前,我有一个连接工厂,每次我要发送消息时都会创建一个新的连接。 我希望能够合并连接数,这样就不会产生每次连接的开销。 解决方案如下: 您需要使用activemq-pool模块和PooledConnectionFactory。 有关该主题的更多信息,请参见http://activemq.apache.org/spring-support.html

2020年10月2日 0条评论 41点热度 阅读全文

建立 我有一个名为Dispatcher的Spring Boot应用程序。它在1台计算机上运行,​​并具有嵌入式ActiveMQ Broker: @Bean public BrokerService broker(ActiveMQProperties properties) throws Exception { BrokerService broker = new BrokerService(); broker.setPersistent(false); broker.addConnector(properties.…

2020年9月26日 0条评论 33点热度 阅读全文

我有一个有点单片的Java应用程序,它围绕Spring @Service bean构建用于我的业务服务层。通常,我的每个业务服务方法都具有Spring Security批注(例如@PreAuthorize),以对该操作实施适当的授权规则。 在主要的Web应用程序流程中,这非常有效;每个Web请求都暗含通过 session cookie等处理的身份验证。 但是,当涉及到与其他“内部”系统的各种集成点时,我认为解决方案并不明确。 例如,我将使用JMS队列中的方法,该队列已经在代理中定义了自己的身份验证和授权规则,因此我…

2020年9月13日 0条评论 24点热度 阅读全文

Apache ActiveMQ代理支持discovery和IP multicast。此功能在默认的“演示”配置中激活(请参见下文)。我想用其他语言(Delphi / Free Pascal)实现发现功能。网络上是否有一些最小的代码示例或简介页,显示了如何使用Java来实现? 如果我理解正确,则多播将触发消息代理的答案,其中包含有关消息代理的IP和端口的信息。但是我无法弄清楚客户端需要指定哪个端口(ActiveMQ documentation)。 但是,我看不到多播客户端应使用哪个端口。 <!-- Create…

2020年9月11日 0条评论 30点热度 阅读全文