替代JMS队列浏览器以实现跨过ActiveMQ？
我的ActiveMQ消息传递实例(Amazon MQ上的ActiveMQ 5.16.2)使用STOMP。Icannot useJMS QueueBrowser，无法取消确认消息。一旦有使用者从队列中取出该消息，即标记为文档here中所述的未使用。 假设代理不能更改，我查看了JMS的REST API映射here，但我没有看到任何模仿ActiveMQ管理页面(JSP)的端点，该端点能够浏览队列、
..
activemq相关内容
ActiveMQ死信信箱.queue-消息直接送到那里吗？
使用JMS发布者/订阅者元素运行我的JMeter测试计划时，它似乎运行成功，将跟踪数据发送到网页。我可以在JMeter中看到响应数据正常。但是，不会显示任何轨迹。因此，在JMS浏览器中查看时，消息似乎直接发送到ActiveMQ DLB队列。 是否有问题可能在哪里的线索？ 推荐答案 您能够发送邮件这一事实并不一定意味着收件人会收到它们。 遗憾的是，我们没有足够的心灵感应能力，
..
ActiveMQ未找到连接的IConnectionFactory实现
我已经在服务器上安装了ActiveMQ 5.13.0版本，并尝试使用C#客户端访问代理。我创建了一个控制台应用程序并安装了Apache.NMS.ActiveMQ version1.7.1Nuget包。当我尝试访问代理时： Line 1 Uri uri = new Uri("tcp://192.168.110.136:61616"); Line 2 NMSConnectionFactory
..
代理不能使用Serializable类：在ActiveMQ中查看消息时抛出java.lang.ClassNotFoundException
我希望查看已在ActiveMQ队列中排队的消息内容。 我打开web-console.(http://localhost:8161/admin/queues.jsp)，点击队列消息的message-id。它在“消息详细信息”窗口中显示以下错误，而不是提供消息内容。 “javax.jms.JMSException：无法从内容构建正文。 代理无法使用可序列化的类。原因： java.lang.Cla
..
无法使用内置的 BrokerService.stop 调用关闭嵌入式 ActiveMQ 服务
我一直在使用嵌入式 ActiveMQ 服务器配置(配置与说明嵌入式 ActiveMQ 服务器/侦听器概念的示例非常相似).作为应用程序的一部分，我有一个监视目录的监视线程.我不必终止进程来关闭 activeMQ 服务器，而是引入了对“STOP"文件的检查，如果该文件存在，则服务器将关闭.我试图通过调用代理上的停止函数来完成关闭: (broker.stop()) 这似乎关闭了服务.但是，
..
如何从 Web 应用程序监听消息队列?(Tomcat，ActiveMQ)
我很高兴改进在 Apache Tomcat 上运行的 Web 应用程序.添加了一个ActiveMQ JMS 服务器来发送和接收消息. 我已经可以发送和接收消息，但需要接收方的帮助. 我的网络应用应该如何持续监听一个队列来接收消息? 新消息到达，服务器应该对它们采取行动.例如:将数据添加到数据库或发送回消息. 我已经可以发送消息了.这是代码. ActiveMQConnect
..
Apache Camel - 代理关闭时的 JMS 唯一行为
我正在使用 Camel ActiveMQ 组件生成 ActiveMQ 实例: 端点上唯一的 jms 配置是 TTL 和池连接工厂.
..
Apache Camel-消息重新传递发生在一个异常块执行之前
有如下骆驼路线. @Override公共无效配置()抛出异常{onException(java.lang.Exception.class).useOriginalMessage().beanRef("discoveryService", "updateConnection").redeliveryPolicyRef("redeliverMessagePolicy");从(ENDPOINT_URI
..
Apache Camel - 动态构建端点和端点
我有一个骆驼路由，它处理来自 process queue 的消息并将其发送到 upload queue. from("activemq:queue:process" ).routeId("activemq_processqueue").process(交换-> {SomeImpl impl = new SomeImpl();impl.process(交换)；}).to(ExchangePatte
..
将消息从 HTTP 端点发送到 JMS
..
从 Camel 路由强制 ActiveMQ 上的套接字超时?
所以下面我有 Camel(通过 Spring DSL)成功地将我的 bean 与 ActiveMQ 队列集成:
..
Camel中的消息自动过期
我有一个实现 Camel 和 ActiveMQ 的系统，用于在一些服务器之间进行通信.我想知道是否有办法在 X 段时间后自动过期并清除发送到队列的消息.由于原始服务器(填充队列)不知道是否有人在接收消息，所以我不希望我的队列增长到太大以至于崩溃.Bonus karma 指向可以提供帮助并提供 java dsl 方式来实现此功能的人. 解决方案 //2 分钟后过期消息长 ttl = Sy
..
骆驼中的动态路由使消息无限排队
我正在开发骆驼的动态路由器，通过引用 http://camel.apache.org/dynamic-router.html 以下是骆驼配置xml:
..
新手:带骆驼的ActiveMQ
我对这个话题很陌生，需要一些解释...... 我们有一个正在运行的 ActiveMQ-Server，现在应该使用 Apache Camel 路由和处理来增强它.我们的整个配置都是基于 XML 的. 我的第一种方法是在我们的 activemq.xml 末尾做一个普通的 ，但这似乎是错误的路径. 这些是当前的运输连接器:
..
Apache Camel/ActiveMQ 优先路由
我有两个具有相同消费者的 AMQ 队列.第一个队列 (Q1) 处理 97% 的消息，而另一个 (Q2) 仅处理 3%.问题是 Q2 中的消息需要在消息排队后立即处理.所以我的问题是，当第二季度有消息可用时，我需要以某种方式暂停第一条路线以获取消费者.apache骆驼路由是这样的:
..
嵌入式和独立的 activemq 代理之间的区别
我正在为我的应用程序使用 Spring.我想知道“嵌入式"ActiveMQ 和“独立"ActiveMQ 之间有什么区别.如果我运行 ActiveMQ 嵌入式，这是否意味着远程客户端仍然可以连接?我的理解是否正确，嵌入的 ActiveMQ 意味着 ActiveMQ 将在我启动 Spring 应用程序时自动启动，还是有其他含义? 例如，假设我在系统 A 中部署了一个应用程序，并在系统 B 中部署
..
用于检查 Apache Camel XML 中的字符串的 JSONPath 表达式
假设我有一个简单的 json 文件，如下所示 {“日志": {“主持人":“等等"，“严重性":“信息"，“系统":“1"}} 我正在使用 Apache Camel，它是 Spring XML 来处理和路由 json 文件.我的路由代码如下所示: $.log?(@.seve
..
如何从 ActiveMQ 延迟使用 Apache Camel 中的消息
当客户端应用在 5 秒的时间内发送超过 1000 个请求时，我需要通过整形(排队)入站流量来节流. 我遵循的解决方案是:我有一个骆驼:油门将最大请求设置为 1000，将时间跨度设置为 5 秒.当超过阈值时，我正在捕获节流异常，并且在 onException 块内，我会将节流消息发送到 ActiveMQ 请求队列以供以后进一步处理，因为 Camel 基于 1000 req/5 sec 配置过载
..
在未来的某个时间重试消息(ActiveMQ)
我正在开发一个 ActiveMQ 系统，我真的不希望丢失消息.我的问题是重试消息导致我的消费者阻塞(而不是处理他们可以处理的消息).我想给失败的消息几天重试(例如，我的一个潜在目的地是我将通过 SFTP 访问的另一台服务器，该服务器可能已关闭)，但我不希望消费者阻塞几天 -- 我希望它继续处理其他消息. 有没有办法告诉代理稍后重新发送消息?现在我正在考虑将消息从队列中取出并延迟放入，但我想知
..
Apache Camel:收到未知相关 ID 的回复
在其他两个软件组件之间有一个middleware.在 middleware 中，我通过 Apache Camel 路由 Apache ActiveMQ 消息. 这就是它的工作原理: 1stComponent 使用middleware 向3rdComponent 发送消息 3rdComponent 回复消息并将其发送回1st(使用middleware). 1stComponent
..