activemq

    5热度

    2回答

    我正面临连接ActiveMQ网络的问题。 我有两个方案: S1:我的应用程序连接到第一ActiveMQ的 “A”。这个activeMQ“A”连接到一个ActiveMQ“B” - 这是导致我一些问题的场景。 S2:我的应用程序直接连接到ActiveMQ“B”。 在这两种情况下,我们都发送数据到同一队列,当然我们发送完全相同的数据。 预期结果:当ActiveMQ“B”接收到数据时,它应该在同一队列中响

    -2热度

    2回答

    我已经搜索了一段时间寻找一步一步的教程来解释ActiveMQ与Camel的设置和集成,但几乎没有成功找到基本教程。 我已经有一个正在运行和配置的ActiveMQ服务器,但我无法启动并运行Camel组件。它总是创建一个独立的代理,我不能让骆驼连接到现有的代理实例。 任何提示,我可以找到关于如何整合骆驼和更好地理解这两个如何一起工作的基本教程? 请不要参考骆驼网站,因为这与ActiveMQ的文档一起,

    -1热度

    1回答

    我有JSF应用程序 我曾试图获取消息从ActiveMQ的其他应用程序, 这是碎片从我代码 @ResourceAdapter("activemq") public class Listener implements MessageListener { @Override public void onMessage(Message message) { String msg = n

    0热度

    1回答

    创建连接下方,然后创建一个会话,然后从队列中获取一定量的消息。 public class Consumer { public static void main(String[] args) throws JMSException { Consumer consumer = new Consumer(); // creates a connection and session

    0热度

    1回答

    背景: 我有一个标准的生产者消费者队列,消费者缓慢,而生产者速度很快。期望是每当生产者完成所请求的消息时,它就认可该消息,并且生产者将假定与消息相关的任务完成。由于生产者速度很快,我不希望生产线等待,相反,只要消息被确认,就应该调用回调。由于JMS在这方面受到限制,并且我尽可能直接使用了像ActiveMQMessageProducer这样的ActiveMQ类。 问题: 消息正在自动确认,即使Con

    0热度

    1回答

    有谁知道如何将activeMQ的日志作为事件写入Windows事件日志(或者甚至可能)吗? 谢谢

    0热度

    1回答

    我正在使用Hibernate和ActiveMQ的atomikos。我的交易涉及消息被提交给数据库并发送到队列。 JMS reveiver然后读取消息并调用db获取。 有些情况下,Atomikos已经对Queue进行了提交,但是hibernate提交仍在进行中,同时从receiver中触发了get查询。我试图找到是否有办法在XA事务中指定提交顺序,似乎没有阅读this。 所以我在想有没有一种方法可以

    0热度

    2回答

    我通过org.springframework.jms.core.JmsTemplate将org.springframework.messaging.support.GenericMessage发送到ActiveMQ中的队列。在ActiveMQ中,我看到这条消息: Cannot display ObjectMessage body. Reason: Failed to build body from

    1热度

    1回答

    我尝试将消息写入JMS队列,我在下一步中将其写入数据库。第一部分应该是第二个异步同步。 JMS部分非常慢(1分钟内1100个项目到队列中)。 这就是我的工作。 @Bean public Job multiThreadedStepJob() { Flow flow1 = new FlowBuilder<Flow>("subflow1").from(step()).end();

    0热度

    1回答

    我有一个正在运行的GlassFish服务器(版本4.1)。现在我有兴趣使用jms和独立消息客户端创建一个简单的消息服务。 (这应该在单独的JVM中的远程机器上运行。)不幸的是,当我尝试初始化QueueConnectionFactory时,仍然收到NameNotFoundException。 这是我的代码: import java.util.Properties; import javax.nam