如何使用Java获取ActiveMQ中的队列长度(发送到队列的未消耗消息的数量)？解决方法:您必须使用JMX,因为Queue接口不提供此类信息. 检索特定队列大小的示例：// connection String url = "service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi"; JMXConnector connector = JMXConnectorFactory.connect(new JMXServiceURL(url)); MBeanServerConnection connection = connector.getMBeanServerConnection(); // get queue size Objec...
我有一个使用JAX-RS和jersey开发的Restful服务API.我已在TOMCAT 7中部署了相同的内容.现在我想实现Activemq,以便将所有请求保留在队列中并处理请求资源.如何做到这一点并与tomcat7集成.如何将ActiveMq与Tomcat7或我的其他服务webapp集成.如何调用该服务. 重要： – 在Rest Api中,我使用FilterChaining概念来解决安全问题,在验证主叫方之后,我只是将请求转发给资源.为此,我在web.xml中添加了. 谢谢 这是我的班级： – public class ...
在我们的应用程序中,我们使用下面的普通java代码创建队列,但有时这会导致跟随错误失败. 我已经知道它失败了jar的原因但是我已经放置了所有最新的jar但仍然失败了.现在我不知道该怎么办？ Activemq启动代码：qconFactory = new ActiveMQConnectionFactory("My.Queue"); qcon = qconFactory.createConnection(); //error occurs heresession = qcon.createSession(false, Session.AUTO_ACKNOWLEDGE);destination = session.cr...
可能有一个愚蠢的简单答案,但我正在尝试使用ActiveMQ在生产者和消费者之间传递消息.我将有许多生产者和许多消费者,但我希望每个消息只在消费者中传递一次.这似乎意味着我不能使用主题,因为它们会向正在收听的所有消费者传递消息,并且我只希望一个消费者接收每条消息. 我的问题是我能够接收消息,但消息没有出列.因此,如果我重新启动我的消费者流程,则会重新处理所有消息. This answer似乎是相关的,但似乎并不适用,因为我无法创建持久...
我想编写用于从Activemq中提取消息的代码.我不想一次从Activemq中提取所有消息,因为我的要求是每当我的Java应用程序从Activemq收到1条消息时,基于消息体我将找到相应的HTTP链接并转发到该链接.对于这整个逻辑,我写了2个.java文件名 MessageConsumer.java MyListener.java MessageConsumer.java文件仅用于连接建立.相应的代码如下.package PackageName;import java.io.IOException;import javax.servlet.ServletException;import ja...
我正在尝试使用事务会话来支持回滚的JMS-ActiveMQ实现.我是ActiveMQ的新手,我已经使用它的Java库进行了第一次实现. 当我运行我的应用程序时,我看到消息已成功入队并出列.我还可以看到相应的DLQ是自动生成的.但是,我不确定我是否正确配置了redeliverypolicy.截至目前它已在生产者上配置,但有些examples将重新传递策略与监听器容器联系起来,所以我不能完全确定在我的情况下(如果有的话)是否会将有毒消息放在DLQ上.摘要中包含详细注释...
使用本网站作为指南： http://activemq.apache.org/how-do-i-use-ssl.html 我执行了以下操作(我在esite中找到了一些keytool命令)keytool -genkey -alias broker -keyalg RSA -keystore /home/amq/broker.ks -dname "CN=server, O=IBM, C=GB" -keypass passw0rd -storepass passw0rdkeytool -export -alias broker -keystore /home/amq/broker.ks -file /home/amq/broker_cert -storepass passw0rdkeytool -genkey -alias client -k...
使用具有大量持久性队列的ActiveMQ(250)1000持久性TextMessages10KB时出现问题. 一个场景要求这些消息在很长时间(几天)内保留在存储中,直到它们被消耗为止(大量数据被分阶段供许多消费者分发,可能在某些天离线). 持久存储充满这些消息后,在代理重启后,我们可以浏览/使用一些队列,直到30秒后#checkpoint调用. 此调用使代理使用所有可用内存,并且永远不会将其释放用于其他任务,例如队列浏览/使用.在内部,MessageCursor似乎决定,没有足...
我在android中使用MQTT与ActiveMQ服务器通信.我用这个例子来实现android mqtt客户端：http://dalelane.co.uk/blog/?p=1599.当我第一次打开Android应用程序时,它连接到ActiveMQ,一切正常.当我关闭应用程序时,删除应用程序数据并重新打开android以尝试重新连接到ActiveMQ我在ActiveMQ中收到以下错误：2013-09-29 19:25:50,064 | WARN | Transport Connection to: tcp://192.168.0.108:54395 failed: java.io.EOFException | org.apa...
我正在使用ActiveMQ 5.8与在camel路由中配置的通配符使用者. 我使用默认的ActiveMQ配置,所以我有如下默认值prefetch = 1 dispatch policy= Round Robin现在我启动一个消费者jvm,每个消费者有2个队列,每个消费者有2个.队列具有相同类型的消息和相同数量的消息. 消费者除了打印消息之外什么都不做(所以没有数据库阻塞或消费者问题缓慢) 编辑我为每个队列设置了preFetch为1 我观察到的是其中一个排队比其他排队更快. 我所期待的是队列...
我已配置MDB以侦听外部ActiveMQ代理上的队列.它工作正常,但MDB从队列中获取一条消息,并且仅在延迟2分钟后才开始处理.我没有配置任何超时,但它看起来真的有一种延迟处理的属性.有人可以建议我如何调整此延迟并切换到立即处理？解决方法:这是Glassfish中的一个老虫很长一段时间了. 这里记录了一个错误,但现在这个网站也关闭了.http://java.net/jira/browse/GLASSFISH-1429 添加System.exit(0)(在finally块中),它关闭所有线程.try{ co...
我正在使用ActiveMQ模拟Java中的服务器重载.主要是好的,但是当我收到超过600个请求时,就会发生WTF！ 我认为瓶颈是我的主服务器,这是下面这个人.我已经在重用连接并创建各种会话以使用来自客户端的消息.就像我说的,我每个连接使用大约50-70个会话,重用连接和队列.我知道下面我可以重用/优化我的组件/监听器吗？ 该架构如下： * =各种各样 客户—> JMS MasterQueue —> *大师—> JMS SlavaQueue —> * SlaveQueue 主要是我为每个Mast...
尝试使用JNDI运行ActiveMQ以下(http://activemq.apache.org/jndi-support.html)并且我在jboss / server / node / lib文件夹中拥有所有必需的activeMQ jar并且我的jndi.properties看起来像：java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory# use the following property to configure the default connector java.naming.provider.url = vm://localhost# use the following property to spe...
为了更好地理解ActiveMQ和Camel,我正在为事务回滚编写单元测试.它似乎不适合我,这意味着我做错了什么！这是代码：public class MyTest extends CamelTestSupport { @Override protected JndiRegistry createRegistry() throws Exception {JndiRegistry reg = super.createRegistry();DataSourceTransactionManager txMgr = new DataSourceTransactionManager();SpringTransactionPolicy txPolicy = new SpringTransactionPolicy();...
使用ActiveMQ 5.9.0,我有以下代理配置：<amq:broker id="broker" useShutdownHook="false" persistent="true"><amq:persistenceAdapter><amq:jdbcPersistenceAdapter dataSource="#dataSource"></amq:jdbcPersistenceAdapter></amq:persistenceAdapter><amq:transportConnectors><amq:transportConnector uri="${broker.url}" /></amq:transportConnectors> </amq:broker>如果在启动代理时数据库中已有消息,则会出现异常：java.lan...