1回答
我正在向AMQ队列发送XML消息。XML具有标头部分。我需要设置头的子节点作为AMQ消息的属性。我使用的是NodeJS stompit包。当前消息只显示一个属性，即JMSXDeliveryCount。
浏览 32提问于2019-08-24得票数 0
回答已采纳
1回答
有没有一个很好的例子(C#)来说明如何在RabbitMQ中直接回复？我想要做的是让X生产商发布一条信息(“我有一些工作给某人”)，我希望X的一个消费者拿起它，做这个工作，然后把回复发回。不是一个基本的Ack，而是一些数据的计算结果。当然，反应必须回到正确的生产者。Console.WriteLine(" Press [enter] to exit."); }
从最低限度<e
浏览 4提问于2016-06-28得票数 6
回答已采纳
是否可以通过Stomp订阅到ActiveMQ代理并访问JobScheduler (随后通过jobId删除预定消息)？我有一组由两个web服务器产生的队列"PROD“的预定消息，当同一个web服务器上发生事件时(注意到jobIds)，希望将它们从JobScheduler中删除，以便使用者(用Java编写并位于多个远程服务器上
浏览 8提问于2015-08-30得票数 1
回答已采纳
我编写了一个简单的ActiveMQ客户端程序来生成消息，如下所示：{ message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, 20);
message.setLongProperty(ScheduledM
浏览 1提问于2013-02-18得票数 0
回答已采纳
我正在尝试删除ActiveMQ中的计划作业，但到目前为止还没有成功。使用NMS API或Amqpnetlite在消息中创建调度( openwire lib除外，因为该库不会更新，不能在netstandard/netcore上使用) 使用NMS创建计划的示例代码，与使用AMQPMsgDeliveryMode.NonPersistent;
msg.Properties.SetString(&qu
浏览 71提问于2020-09-10得票数 1
回答已采纳
以下是属性设置 <connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory
浏览 12提问于2019-04-06得票数 0
回答已采纳
我正在使用stompit模块连接到AMQ。如果我将ssl设置为true，那么它将失败，并显示错误"Unable to verify the first certificate“。如果我将rejectUnauthorized设置为false，但是代码不从它刚连接的AMQ读取任何消息，那么它就可以工作。
我试图通过设置下面的属性来使用证书，但得到了相同的错误。
浏览 2提问于2019-10-04得票数 1
我们有一个带有队列和生产者的ActiveMQ Artemis2.17.0实例，有时会出现以下错误：AMQ219006: Channel disconnected和AMQ219016: Connection我已经阅读了有关此错误的不同资源，并且无法确定是什么导致了错误。这是否是由于队列的高吞吐量造成的呢？
浏览 9提问于2022-08-23得票数 0
1回答
com.feed.publish.PublishMessages"></bean>
我使用spring框架进行了上述设置，该框架允许我将消息发布到队列。但是，如果activemq实例在进程中途终止，我希望它将消息写入磁盘/文件，直到可以重新建立连接为止。我在activemq的网站上找到了示例代码，但是我
浏览 2提问于2012-11-06得票数 0
回答已采纳
" <from uri="amq#amq:two#amq:three#amq:four</constant> <log messag
浏览 11提问于2013-10-04得票数 1
如何在队列中设置redeliveryPolicy中的ActiveMQ？<amq:connectionFactory id="amqConnect
浏览 1提问于2011-03-16得票数 15
回答已采纳
1回答
如何在集群中与is处于故障转移模式共享配置文件？我不想在集群中的每个服务器上编辑artemis-user.properties、artemis-role.properties和broker.xml文件。群集设置：
<security-setting match="clusterQueue" roles="<e
浏览 4提问于2020-01-27得票数 0
回答已采纳
1回答
JMS消息消耗
、、
生产者(P)发送消息M1，M2，M3，M4，M5，M6，M7；假设它从时间T1发送到T7。消息使用者(L)将是绑定到主题的侦听器。主题名称: jmsTopicAMQ正在运行，L没有连接到AMQ中的jmsTopic。P将M1发送到M7到jmsTopic。如果L在时间上连接到jmsTopic，比如T8，它会收到M1到M7的消息，还是只接收在time T8之后发送给主题的<
浏览 6提问于2011-05-17得票数 1
1回答
我已经启用了调度程序，并且我设法(以编程方式)创建了计划的作业。我还设法编写了一个方法来根据作业id删除它们。我一直在使用JmsTemplate浏览队列，但只有当队列中有一些消息在等待时，它才起作用。我的问题是，我应该如何获取计划作业id？
浏览 15提问于2021-11-03得票数 0
回答已采纳
我使用的是基于php.And Stomp+activeMQ的laravel框架。在这里，我需要向mq发送一些东西，但是消息应该在180秒后使用，而不是立即使用。有没有更好的解决办法？
我已经按照李的建议设置了"AMQ_SCHEDULED_DELAY“，但是消息会立即发送，too.Maybe的延迟配置只能用于PUB/SUB，而不是PTP？我不know.Or在标题中发送'AMQ_SCHEDU
浏览 1提问于2017-04-19得票数 1
2回答
通过JMS在Grails中使用ActiveMQ，我无法理解如何设置KahaDb持久性属性。尝试过这样的方法： amq.transportConnectors() { }
amq.per
浏览 2提问于2015-04-20得票数 0
回答已采纳
2回答
现在，我正在使用一个JMS队列，该队列具有重新传递策略，即回滚五次以上的消息将被发送到死信队列。
当一条消息被发送到ActiveMQ中的死信队列时，有没有办法查看是什么异常导致了消息回滚？是否有消息属性可以设置来指定导致消息失败的原因？
浏览 0提问于2011-11-21得票数 0
我已经将AMQ配置为从Oracle接收和发送消息，如所述 ... 37 more
在那之后，消息就会丢失由于新的连接操作相当繁重，我尝试将org.sprin
浏览 9提问于2018-03-26得票数 0
所有到存储库和其他通道的通道都在重新尝试状态。当我检查下面的日志时，
AMQ9532:程序不能设置队列属性。说明:在队列管理器'SYSTEM.CLUSTER.TRANSMIT.QUEUE‘上设置队列'QMGR.SERVER6A’属性的尝试失败，原因是代码2102。操作:确保队列可用，并重试操作。操作:查看错误文件中通道程序“Channel.Coord00”
浏览 8提问于2011-03-07得票数 4
在RabbitMQ中创建自己的交易所有什么好处吗？
例如使用"amq.direct“与type=direct的"my_direct_exchange”。
浏览 0提问于2014-01-24得票数 3
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号