ApacheActiveMQ Artemis持久订阅TTL
我希望配置持久主题，但我希望配置Apache ActiveMQ Artemis为该主题的非活动持久订阅者保留消息的时间。 例如，类似“为非活动的持久订阅者保存持久消息最多30秒”。如果订阅者在30秒内未变为活动状态，则当他们处于活动状态时，该消息将不再可用。 这是可以做到的吗？如果不是，Artemis或JMS是否提供替代方法来实现这一点或类似的事情。 推荐答案 Active
..
jms相关内容
使用来自IBM MQ的所有消息
我要使用来自MQ的所有消息。 public static void main(String[] args) { JMSContext context = null; Destination destination = null; JMSConsumer consumer = null; JmsFactoryFactory FF = JmsFactoryFactory.getIns
..
结合JMS传输的Spring集成散集模式
我需要实现以下架构： 我有必须使用JMS发送到系统(某些外部应用程序)的数据。 根据您只需要发送到必要系统的数据(例如，如果系统数为4，则可以从1发送到4) 需要等待收到消息的系统响应，收到所有应答后，需要处理接收到的数据(或至少处理一个超时) 相关ID包含在传出和传入JMS消息的标头中 每个新的此类进程都可以异步并行启动 现在我只在Spring JMS的帮助下
..
如何在Spring JMS侦听器中从JMS消息中获取自定义属性
我知道您可以使用如下内容访问Spring JMS侦听器中的标准标头： public void receive(String in, @Header(JmsHeaders.MESSAGE_ID) String messageId) 是否有用于访问自定义属性的类似批注？ 推荐答案 完全相同. 使用@Header注释(请参阅方法listen) 或 使用封装消息头
..
为什么com.ibm.jms.JMSTextMessage类型的变量打印截断的内容和省略号(.)？
我想了解为什么输出com.ibm.jms.JMSTextMessage类型的变量时带有截断的内容和省略号(.)转换为字符串时。 我在JMeter的JSR223采样器中有此代码： import com.ibm.msg.client.jms.JmsConnectionFactory import com.ibm.msg.client.jms.JmsFactoryFactory import
..
代理不能使用Serializable类：在ActiveMQ中查看消息时抛出java.lang.ClassNotFoundException
我希望查看已在ActiveMQ队列中排队的消息内容。 我打开web-console.(http://localhost:8161/admin/queues.jsp)，点击队列消息的message-id。它在“消息详细信息”窗口中显示以下错误，而不是提供消息内容。 “javax.jms.JMSException：无法从内容构建正文。 代理无法使用可序列化的类。原因： java.lang.Cla
..
如何控制Spring从队列接收的速率？
我正在使用Spring的消息驱动POJO框架(特别是DefaultMessageListenerContainer)来侦听几个队列和主题。 对于一个特定的队列，需要减慢我排出队列的速度，大约是每五分钟一条消息。消息的实际处理是次秒级操作，但我希望侦听器在消息之间空闲一段时间。 我创建了一些黑客攻击，但它显然不是最优的：我所做的是将最大并发设置为1，并在处理每条消息之后添加Thread.slee
..
MDP JMS事务回滚，然后在无限循环中重新处理消息
如果通过指定sessionTransacted=true或transactionManager=jmsTransactionManager在DefaultMessageListenerContainer上启用事务管理，则只要MDP中发生异常，事务就会回滚，消息就会放回队列。这会导致消息被再次处理，事务一次又一次地回滚，从而创建一个无限循环。 我想我的问题是..。我错过了什么吗？如果消息只是意
..
如果使用消息后出现错误，如何将消息保存在JMS消息队列中？
我的场景是-我将消息发布到队列中，一旦消息被使用，我就将其发送到第三方中间件应用程序。如果中间件应用程序关闭，那么我发布的消息就会被丢弃。如果中间件应用程序关闭，我不想丢失该消息，相反，我希望它处于等待状态或在队列中等待。请建议如何处理此场景？ 推荐答案 您应该这样创建会话： Session session = connection.createSession(false,
..
消息队列、EventBus和发布/订阅之间的区别是什么？
我混淆了消息队列的概念(例如ActiveMQ、RabbitMQ、ZeroMQ)和EventBus(例如Guava Event Bus、Akka EventBus) 我认为MQ和eventBus都使用发布/订阅模式。与芭乐相比，MQ似乎更强大、更笨重。 但真正的区别是什么呢？EventBus是否与MQ相同？ 推荐答案 消息通常用于进程间通信和机器之间的消息发送。您可以将事件封
..
JMS和AMQP-RabbitMQ
我想了解什么是JMS，以及它是如何与AMQP术语联系在一起的。 我知道JMS是一个API，而AMQP是一个协议。 以下是我的假设(以及问题) RabbitMQ使用AMQP协议(而不是实现AMQP协议) Java客户端需要使用AMQP协议客户端库来连接/使用RabbitMQ JMS API在这里发挥什么作用？JMS API应使用AMQP客户端库连接RabbitMQ？ 我们通常使用J
..
多个目的地和消费者的 Spring 配置
我正在使用具有一个目的地和一个消费者(消息侦听器)的消息侦听器容器:
..
如何从 Web 应用程序监听消息队列?(Tomcat，ActiveMQ)
我很高兴改进在 Apache Tomcat 上运行的 Web 应用程序.添加了一个ActiveMQ JMS 服务器来发送和接收消息. 我已经可以发送和接收消息，但需要接收方的帮助. 我的网络应用应该如何持续监听一个队列来接收消息? 新消息到达，服务器应该对它们采取行动.例如:将数据添加到数据库或发送回消息. 我已经可以发送消息了.这是代码. ActiveMQConnect
..
如何在 Oracle AQ 中清除队列
我是第一次测试 Oracle AQ.我已经设法在我创建的队列中创建了 2000 行测试插入. 现在，我想清除这些.在自学时，我将到期时间设置为一个月.我不能等那么久.而且我认为我不应该将它们从队列表中删除. 最好的方法是什么? 解决方案 您可以使用 DBMS_aqadm.purge_queue_table 过程. 解决方案 SQL 看起来像这样: -- 清除队列宣
..
Glassfish V3.x 和远程独立客户端
作为独立客户端连接到 ActiveMQ 绝对没有问题.您唯一需要做的就是添加 activemq-all-5.4.1.jar 就可以了... ...prop.put(Context.SECURITY_AUTHENTICATION , "系统");prop.put(Context.SECURITY_CREDENTIALS,"经理");prop.put(Context.INITIAL_CONTEXT_
..
如何将 MQ 服务器回复消息与正确的请求相匹配
我正在连接到 IBM Websphere MQ.我希望能够将回复消息与正确的请求消息相匹配.我翻了数百页才得到这个，但没有运气. 我有一个类 - MQHandler - 它向一个定义的队列发送消息，并从另一个队列读取请求.这很好用，但是，如果多个用户同时使用该应用程序，消息就会混淆. 我似乎无法在接收器上找到一种方法来指示要匹配的 CorrelationID.比如…… consu
..
如何创建一个临时 jms 队列并通过名称连接到它?
我需要为响应创建一个临时队列，但我需要知道是否可以在不通过消息的 setJMSReplyTo 方法发送响应队列对象的情况下连接到临时队列，因为回复线程根本没有得到该对象. 解决方案 我使用 InitialContext 对象将我的临时队列绑定到 jndi，这样我就可以从需要使用我的临时队列的线程中查找我的临时队列. jndiContext = new InitialContext();c
..
Apache Camel——Websphere MQ 集成
我有一个使用 apache-camel 解决方案的应用程序，想通过 jms 向 Websphere MQ 服务器发送消息，将 jms 属性 JMS_IBM_MQMD_MsgId 转换为 MQMD 字段 MQMD.MsgId，以便我通过骆驼在消息上设置此值 exchange.getIn().setHeader(WMQConstants.JMS_IBM_MQMD_MSGID, "XXXXXXXXXX
..
Apache Camel - 代理关闭时的 JMS 唯一行为
我正在使用 Camel ActiveMQ 组件生成 ActiveMQ 实例: 端点上唯一的 jms 配置是 TTL 和池连接工厂.
..
使用骆驼 JMS 流式传输
我有一个将消息放入 JMS 队列的应用程序.消息大小可以达到 150 mb.JMS 消息包含带有附加元数据的字节数组数据作为 xml，一旦将消息放入队列中，骆驼路由应用程序就会选择消息并使用消息调用外部 java api.我想使用骆驼 jms 从 JMS 队列中流式传输消息零件.你能告诉我是否可以使用骆驼来实现它.目前我正面临堆错误问题. JMS 消息示例如下.
..