activemq

0热度

2回答

在我们的项目中，我需要将消息推送到ActiveMQ并保持它们的持久性。当我发送新消息并且内存限制超过队列中最老的消息时，应该从队列中删除/删除或替换为新消息。我不想清除整个队列，队列就像我们产品的故障安全消息积压一样工作，所以我需要在队列中保留最后x个消息量。我试图从谷歌和目前没有运气看。这里是我的settings.xml政策 <destinationPolicy> <polic

0热度

1回答

进行java调用以确定Apache Camel条件路由

这是我的场景。我有一个现有的处理应用程序，当前正在使用camel将ActiveMQ消息从队列发送到Java应用程序进行处理，通常有多个应用程序在不同节点上运行。我需要能够只将消息路由到一个应用程序实例时，该实例有能力处理它。应用程序bean本身意识到其容量状态。 “testCapacity”方法返回一个表示可用容量的布尔值。据我已搜查，我可以试图找到一种方法，我的用作决策点到豆本身提出的“当”

0热度

1回答

Spring与ActiveMQ的集成：当队列中没有更多待处理消息时获取通知

我正在使用ActiveMQ与Spring集成。当我的队列为空时（没有更多待处理的消息），我有要求做一些处理。我已经实现了这样的事情， package my.com.spring.integration; public class MyListenerContainer extends DefaultMessageListenerContainer { @Override prot

2热度

3回答

ActiveMQ的访问此前公布的数据上订阅

我们利用当地的ActiveMQ到同时开启5个进程之间传输数据。我有一些数据我需要发送一个过程，无论是在运行时（这工作完全正常），而且在启动的默认值。事情是在流程启动时发布的，它不会被读取，因为它在数据发送时没有订阅主题。我有多个解决方案：我可能会推迟第一个发布了一会，这样的过程有时间启动（这似乎不是非常有吸引力）;或者是否有办法将所有存储的以前未处理的消息发送给刚订阅的某个进程？我编码在C＃

0热度

1回答

使用python从ActiveMQ队列接收单条消息STOMP

嗨，我使用stomp.py模块来发送和接收来自使用python的消息。虽然接收消息侦听器将读取指定的睡眠时间内的多个消息。但我只需要阅读一条消息。这是可能的在Java中。如何使用STOMP从ActiveMQ读取单个消息？下面是我测试的听者脚本， import stomp import time class SampleListener(object): def on_me

0热度

1回答

我如何将消息发送到使用JMS发件人在wso2esb

如何设置端点使用JMS发送到数据推到ActiveMQ的一个ActiveMQ的。当我给端点JMS：？/ sampleQueue transport.jms.ConnectionFactoryJNDIName =的QueueConnectionFactory & java.naming.factory.initial的= org.apache。 activemq.jndi.ActiveMQInitia

0热度

2回答

activemq-all.jar（5.14.0）不适用于Spring 4.3.6？

早些时候我使用activemq-all-4.1.2.jar从apache-activemq-5.14.0中获取/侦听。但是，这使我以下异常： - 15-05-2017 18:50:32.685|WARN |AcitveMQ Connection Worker: ssl://BDNVM4APK756V02/X.X.X.X:61616|Encountered a JMSException - rese

0热度

1回答

ActiveMQ ActiveMQ.Advisory.TempQueue越来越大

问题，在ActiveMQ出于某种原因（我不知道为什么）ActiveMQ.Advisory.TempQueue越来越大（每天1GB）。这里是一个快照： Name Producer # Consumer # Enqueue # Dequeue # Memory % Dispatch # Always retroactive Average blocked time Average enq

2热度

1回答

新手：ActiveMQ的骆驼

我很新的这个话题，需要一些解释... 我们有一个正在运行的ActiveMQ-Server，它现在应该与Apache骆驼路由和处理增强。我们的整个配置是基于XML的。我的第一种方法是在我们的activemq.xml文件末尾做一个普通的<import resource="camel.xml">，但这似乎是错误的路径。这些都是当前transortConnectors： <transportConne

0热度

2回答

找不到类[org.apache.activemq.command.ActiveMQQueue]

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.apache.org/schema/core" xmlns:context="http://www.springframework.org/sc