使用骆驼 JMS 流式传输
我有一个将消息放入 JMS 队列的应用程序.消息大小可以达到 150 mb.JMS 消息包含带有附加元数据的字节数组数据作为 xml，一旦将消息放入队列中，骆驼路由应用程序就会选择消息并使用消息调用外部 java api.我想使用骆驼 jms 从 JMS 队列中流式传输消息零件.你能告诉我是否可以使用骆驼来实现它.目前我正面临堆错误问题. JMS 消息示例如下.
..
hornetq相关内容
如何在确保每个实体 FIFO 的同时并行处理消息?
假设您的系统中有一个实体，例如“Person"，并且您想要处理修改各种 Person 实体的事件.重要的是: 以先进先出的顺序处理同一个人的事件 多个 Person 事件流由不同的线程/进程并行处理 我们有一个使用共享数据库和锁来解决这个问题的实现.线程竞争获取一个 Person 的锁，然后在获取锁后按顺序处理事件.我们希望移动到消息队列以避免轮询和锁定，我们认为这会减少数据库的负载
..
哪个嵌入式消息传递系统 ->ActiveMQ 或 HornetQ
我希望能就这两个消息传递系统中的哪一个提供一些一般性的指示和意见 更易于管理 需要了解和避免的陷阱或魔法的东西更少 总体依赖较少 使用起来很简单. 解决方案 更易于管理 hornetQ 有一个清晰的管理 API，并且非常容易使用. 需要知道和避免的陷阱或魔法的东西更少 hornetQ 是为嵌入式外壳制作的.将它集成到您的代码中非常非常容易.事实上，你可
..
在 hornetq 中是否可以有多个客户端消费者?
在我的客户端应用程序中，我创建了多个消费者，但他们无法同时处理队列.始终只有一个消费者处理队列消息.我不知道为什么. Hashtableenv = new Hashtable();env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory");env.put(Context.URL_PKG_P
..
您如何在确保每个实体的 FIFO 的同时并行处理消息?
假设您的系统中有一个实体，例如“Person"，并且您想要处理修改各种 Person 实体的事件.重要的是: 按 FIFO 顺序处理同一个人的事件 多人事件流由不同的线程/进程并行处理 我们有一个使用共享数据库和锁来解决这个问题的实现.线程竞争获取Person 的锁，然后在获取锁后按顺序处理事件.我们想转移到消息队列以避免轮询和锁定，我们认为这会减少数据库的负载并简化消费者代码的实现
..
JMS 拓扑(具有多个消费者的队列)和消息组
这是我们设置的简化/示意图拓扑 [前端服务器1(消息生产者)] [前端服务器n(消息生产者)]|||________________ ________________|||[消息服务器(HornetQ)]||________________||________________||【任务服务器1(消息驱动Bean)】【任务服务器n(MDB)】 每个节点(服务器)都是一个独立的(无集群)jbos
..
使用骆驼 JMS 进行流式传输
我有一个将消息放入 JMS 队列的应用程序.消息大小可达 150 mb.JMS 消息包含带有额外元数据的字节数组数据作为 xml，一旦消息被放入队列中，骆驼路由应用程序就会选择消息并使用消息调用外部 java api.我想使用骆驼 jms 从 JMS 队列流式传输消息成分.你能告诉我我是否可以用骆驼来实现它.目前我正面临堆错误问题. 示例 JMS 消息如下.
..
如何在 HornetQ 2.2.5 核心客户端中持久化队列?
我想在核心 hornetQ 客户端中创建持久队列.问题是当我停止服务器时，队列和数据将被破坏.如何使队列持久化?我的代码是: import java.util.Date;导入 org.hornetq.api.core.TransportConfiguration;导入 org.hornetq.api.core.client.ClientConsumer;导入 org.hornetq.api.co
..
JBoss HornetQ:为慢速消费者设置消费者窗口大小
我想将设置为0.这似乎是另一个问题的答案(具有多个使用者的JMS队列)，并在此
..
如何在cmake上使用FIND_JNI
我正在尝试为我的项目编写一个构建，以替换自动构建，并且需要正确使用FIND_JNI。 我可以制作一个简单的构建，但是找不到正确的jni.h 而且我需要找到一种正确的方法（没有技巧）来定义Java包含，因为这需要可移植到其他用户。 解决方案 以下代码对我有用。在您的根 CMakeLists.txt 文件中，添加： find_package（JNI） if（JNI_
..
我应该还是应该不将CachingConnectionFactory与hornetq 2.4.1一起使用
基于有关将hornetq与JMSTemplate一起使用的长期信息，我们在连接到服务器时一直在使用CachingConnectionFactory。这是一个示例配置，与我们正在使用的配置非常相似：
..
在ArtemisMQ 2.x上的消息重新分发不起作用
我想在具有静态主机的2节点群集上启用消息重新分发.但这似乎行不通. 1)我有10个生产者，它们写入节点1上的队列"MyTestQueue"(但没有消费者). 2)我在节点2上有1个使用者(但没有生产者)，它使用了来自节点2的消息. 我希望节点1将消息重新分发到使用方存在的节点2，但事实并非如此.节点1上的邮件数仍然等于发送到节点1的邮件数. 我的broker.xml中具有以下配
..
JMS消息优先级不适用于消息
我需要设置消息优先级，以便在接收方接收低优先级消息之前先消耗高优先级消息。 首先，我尝试使用message.setJMSPriority（）方法进行设置优先级，但是它在HornetQ和ActiveMQ中不起作用，所以最后我使用setPriority（）方法设置了消息产生器的优先级，现在它可以正常工作。 为什么不是' •Messsge.setJMSPriority（）可在任何JMS供应商
..
超过了JMS Mule max重新交付
我有一个非常简单的设置，用于从HornetQ队列中读取MULE并将对象保存到数据库: 以下设置:
..
HornetQ核心API和JMS
关于HornetQ，我有几个问题: HornetQ核心API和JMS API有什么区别? 使用其中一种有什么优点或缺点? 是说我是否使用核心API，然后决定 更改我的Messaging Bus(比方说ActiveMQ)，然后我必须 更改我所有的代码? 解决方案 HornetQ Core API是HornetQ的专有API，而JMS API是Java Community
..
Spring JMS侦听器容器仅停止侦听器的一半
我对JMS侦听器容器有奇怪的问题.如果禁用了侦听器容器，一半的消息将由侦听器传递和处理.这是我的Spring配置:
..
HornetQ JMS主题到主题的桥梁
我正在尝试在两个主题之间架起一座桥梁.这个想法是这样的: 通知被发布到HornetQ服务器A上的某个主题 此通知已发送到HornetQ服务器B上的某个主题(通过 桥?) 客户端应用从服务器B获取通知. 我需要这样做的原因是，如果服务器B关闭，我们仍然希望该主题启动，并最终传递给订阅服务器. 我需要的是一个演示hornetq-configuration.xml和hornetq-
..
使用骆驼JMS流式传输
我有一个将消息放入JMS队列的应用程序.消息大小最大为150 mb. JMS消息包含带有附加元数据作为xml的字节数组数据，一旦将消息放入队列中，骆驼路由应用程序选择了该消息，并使用该消息调用外部Java api.我想使用骆驼jms从JMS队列中流式传输消息零件. 你能告诉我我能不能用骆驼来实现. 目前，我面临堆错误问题. 示例JMS消息如下.
..
到JMS队列的JBoss7远程MDB连接-已检测到连接失败
我正在尝试开发一个MDB来侦听JBoss7中的远程队列，但我没有从队列中接收消息. 我在服务器日志中收到警告: 11:32:41,882 WARN [org.hornetq.core.protocol.core.impl.RemotingConnectionImpl] (hornetq-failure-check-thread) Connection failure has been
..
HornetQ-java.lang.NoClassDefFoundError:Lorg/hornetq/core/logging/Logger;
我正在尝试从书中运行一个简单的HornetQ示例(《 HornetQ消息传递开发人员指南》)，但会收到错误消息.我没有使用过maven，因为我想紧紧抓住书中给出的例子. HornetQ独立服务器在命令行中正常启动.我只是想向HonretQ服务器发送消息. package chapter01; import javax.jms.JMSException; import javax.namin
..