ActiveMQ在Android中不起作用
我正在android App中开发ActiveMQ消费者，并且在项目中包含了 activemq-all-5.9.0.jar 并设置了配置生成路径，但是我的应用程序根本无法使用我。下面是我的代码。 ActiveMQConnectionFactory connectionFactory = null; MessageConsumer消费者= null; Session session
..
activemq相关内容
通过JMX访问Apache ActiveMQ会抛出Exception Broker Not Found 5.10
我正在使用全新的ActiveMQ 5.10.0安装，在队列中有一条称为“测试”的消息。我还替换了bin / activemq中的ACTIVEMQ_SUNJMX行以启用JMX： ACTIVEMQ_SUNJMX_START =“-Dcom.sun.management.jmxremote。 port = 1099 -Dcom.sun.management.jmxremote.authentic
..
wso2esb中的等待线程问题
您好，我正在研究wso2esb并将Active MQ用于消息队列。 使用大约3周后，ESB服务器挂起，并借助对ESB的JMX监视我发现它们中有大量处于等待状态的Java线程。 [EsbMonitoring] ******* ********** java线程属性********************* [EsbMonitoring]线程数：8873 [EsbMonitori
..
活动MQ连接问题
您好，我正在研究wso2 esb并将Active MQ用于消息队列。 我有一个简单的服务来放置一条消息，在该消息中它将调用自定义Java类。创建一个tcp连接并将消息放入队列中。 Java代码如下所示 包in.esb.custommediators; import javax.jms。*; 导入org.apache.activemq.ActiveMQConnecti
..
Apache Camel-消息重新交付发生在onexception块执行之前
具有以下骆驼路线。 @Override public void configure（）引发异常{ onException（java.lang.Exception.class）.useOriginalMessage（） .beanRef（“ discoveryService”，“ updateConnection”） .redeliveryPolicyRef（“ redeliv
..
在分布式系统中设计合理的消息消耗
我们有一个分布式应用程序，可以代表多个客户端工作。现在，随着工作的到来，消息被放在一个队列中。 在某些情况下，我们会为单个客户端获取数千条消息，而这些消息随后占用了队列中的前1000多个广告位。这意味着在处理这些消息之前，其他任何客户端都无法完成（或很少）工作，这使较小的客户端感到饥饿。 我的想法是，在我们之前每次从客户端队列中获取消息之前，都要先查阅客户端列表，然后我们先查看该消息以
..
jconsole连接到apachemq
activemq：apache-activemq-5.14.0 使用jdk1.7的jconsole 我已经开始码头服务器随附的activemq。启用jmx的较小更改是通过更改activemq.xml managementContext createConnector =“ true” ---默认为false 启动时，我看到消息 JMX控制台可以连接到service：jmx
..
ActiveMQ：一条待处理消息，但队列为空-ActiveMQ 5.12.0
我遇到了与此处所述相同的问题： ActiveMQ：一条待处理消息，但队列为空。 Active MQ显示队列的待处理消息，但是当我单击时，它为空。 其他客户： 具有相同的行为 我的Java用户 不消耗任何东西 重启后，继续消耗 我们不是在默认的kaha db中而是在Oracle DB中保留消息。我可以在表ACTIVEMQ_MSGS中的数据库中看到待处理的消息。
..
在ActiveMQ队列上侦听的所有JMS使用者的油门消耗率
使用骆驼节流阀组件，您可以定义每个时间段内已使用消息的速率的上限，例如： from （“ activemq：queueA”）。throttle（10）.to（“ direct-vm：bla”） 我认为不理想的是，骆驼节流器在节流器阻塞的情况下将交换保持在内存中。因此，如果您有100个队列使用方，并且由于任何原因“ direct-vm：bla”运行缓慢（例如，调用外部慢速服务
..
跨平台实时数据
我正在为特定类型的应用程序设计一个新平台。这些应用程序将主要存在于iOS和Android设备上。 这些应用程序的主要要求之一是同步实时数据并且安全。我的想法直接涉及到使用套接字的某种排队协议。 服务器的限制是必须使用Java或PHP编写。但是，客户端不受限制。就像我提到的那样，主要是iOS（Objective-C）和Android（Java）设备。 我应该实现ActiveMQ还是Tibc
..
如何启用或验证ActiveMQ的REST接口？
出于开发目的，我在Windows 2003虚拟服务器上设置了ActiveMQ 5.8.0。我知道应该有一个REST接口，用于读取和写入队列等。但是，我似乎无法确切地找到执行方法。端口8161可用于访问管理控制台，但是我从Firefox Poster尝试的每个URL都返回404。我尝试了以下URL： http：// localhost：8161 / queues
..
JMS / ActiveMQ：发送带有对象作为类成员的对象
我正在使用ActiveMQ（带有Spring）将消息发送到远程OSGi-Container。 这很好用，但是有一个问题。 我有两个实现Serializable的类。一个类是另一个类的类成员，例如： public类成员实现Serializble { private int someValue; private static final long serialVersionUID
..
无法在Fuse服务组合中安装activemq-web-console
“执行命令时出错：URL [mvn：org.apache.activemq / activemq-web-console / 5.4.0 / war]无法解决。” 当我执行功能时被抛出：使用保险丝4.3安装activemq-web-console i am 解决方案 删除了来自features：removeUrl的activemq的旧网址，并添加了新的 mvn：org.apach
..
Apache Camel inOut路由，与jaxb交换交换封送/取消封送
我们有这个apache骆驼路线， from（commandDrop）.marshal（jaxbDataFormat）.to（jmsQueue）; from（jmsQueue）.inOut（“ jms：doCommand？requestTimeout = 500000”）; from（“ jms：doCommand”）。unmarshal（jaxbDataFormat）.beanRe
..
经纪人的ActiveMQ网络：具有rebalanceClusterClients和updateClusterClients的随机连接
我有一个具有以下配置的经纪人网络
..
ActiveMQ-如何设置kahadb db.data文件的最大大小
我将ActiveMQ代理的SystemUsage属性设置如下： SystemUsage systemUsage = new SystemUsage（）; StoreUsage storeUsage = new StoreUsage（）; storeUsage.setLimit（1L）; systemUsage.setStoreUsage（storeUsage）; M
..
无法连接到RMI注册表
我正在Ubuntu 12.04上运行activemq-5.9，可以说我是主动MQ的新手。 我怀疑我正在排队记录和而不是让它们出队，因此我正在研究使用JMX连接到我的活动MQ代理，并查看发生了什么。 Jconsole失败。 这很困难，因为有关如何执行此操作的大多数文档都已过时，但是我终于开始运行activemq列表了。当我这样做时，它会抛出一个相当长的堆栈跟踪： 连接到JMX UR
..
Activemq关闭失败，然后终止进程
我正在实现复制的leveldb activemq设置。我在同一个盒子上运行了3个activemq实例。我正在更改配置文件中的rmiPort，amqpport和openwire端口。 config就像lookslie这样：
..
我可以使用C＃代码从ActiveMQ队列中删除消息吗？
我想为消息头中的每条消息设置唯一的GUID，然后根据需要删除特定的消息。 NMS中是否有任何api可以帮助我删除邮件？我正在使用ActiveMQ 5.9.0和NMS 1.6.1 解决方案 非常有可能直接从C＃和NMS库中进行单个删除 我在C＃项目中使用NuGet的NMS 18.0作为我们的支持和维护工具 Nodinite ，这是来自许多
..
在骆驼中使用Polling Consumer创建持久订户
我正在尝试使用轮询使用者创建持久的订户。 URI是正确的，因为在骆驼路线中使用相同的uri并正确创建了持久订户。 由于某种原因，PollingConsumer无法创建持久订户，而是创建普通订户。 是否不可能使用轮询使用者来创建持久订户？ p> 公共类OutQWaitingProcesser实现处理器{ @Override 公共无效过程（交换）抛出异常{ Endpoint端
..