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