当前位置: 首页 > 知识库问答 >
问题:

Apache Camel-浏览SEDA队列的交换

章兴发
2023-03-14

我正在开发一个使用Apache Camel和JMX活动的小应用程序。非常简单地说,我有一个使用SEDA组件的路由--只有一个消费者--简而言之,它创建自己的线程,并在路由繁忙时对传入的交换进行排队。

我想知道Camel中是否有一些现成的东西允许我这样做,或者我忽略了Hawtio或JConsole中的一些东西。

提前谢了。

共有1个答案

袁宜
2023-03-14

您可以在SedaEndpointmbean上看到队列中有多少消息。您可以在hawtio或普通JMX的endpoint树中找到它们。

@ManagedAttribute(description=“current queue size”)public int getCurrentQueueSize(){return queue.size();}

 类似资料:
  • 我无法连接到具有SEDA队列的骆驼路线。在服务器端,我有以下配置: 我正在尝试从这样的独立客户端访问此路由: 但我的制作人无法连接到seda队列。无法按我的路线排队。无法在我的bean属性中添加camelContext。我正在获取“bean类的属性'camelContext'无效”。如果我将正文发送到SEDA队列,则消息将发送到那里,但不会发送到路由的下一个元素

  • 我的ActiveMQ消息传递实例(Amazon MQ上的ActiveMQ 5.16.2)使用STOMP。我不能使用JMS队列浏览器,也没有办法“解锁”消息。一旦有消费者从队列中提取该消息,即标记为“未消费”,如这里的文档所述。 假设代理无法更改,我在这里查看的是 JMS 的 REST API 映射,但我没有看到任何模仿 ActiveMQ 管理页面 (JSP) 的endpoint,该endpoint

  • 我需要使用驼峰路由浏览来自活动mq的消息,而不使用这些消息。 JMS队列中的消息将被读取(仅浏览而不使用)并移动到数据库中,同时确保原始队列保持完整。 公共静态无效检查ReceivedOrders(){ }

  • 目前我有一个Weblogic 10R3开发的Java EE应用程序主机,我有兴趣测试1个消息驱动Bean。问题是我无法访问Bean正在侦听的外部JMS服务器,以下是MDB代码: 我的计划是,Bean将通过JNDI查找队列,并且我确实可以访问Weblogic托管服务器。因此,我可以删除外部JMS服务器,然后添加一个本地JMS队列和包含确切JNDI名称的connectionFactory。因此,隔离外

  • 我们有内部服务总线安装。我可以使用QPID AMQP 1.0 0.24客户端发布和订阅/读取消息。然而,队列浏览不起作用,当队列中没有更多消息时,对hasMoreElements()的调用将无限期挂起。堆栈跟踪是: 代码: ConnectionFactory ConnectionFactory=(ConnectionFactory)上下文。查找(“MS\U SERVICE\U BUS”);连接=连

  • 我正在尝试查看ActiveMQ(5.11.1)中队列中的所有消息。为此,我使用Hawtio(1.4.51)。我在ActiveMQ中的队列包含790条消息。 我的步骤到现在: 默认情况下,hawtio在ActiveMQ队列中最多显示400条消息。所以我去了我的broker.xml设置并添加了: 这给了我401条信息。 所以我尝试将maxBrowsePageSize=“401”更改为“-1”。令我惊讶