TIBCO-EMS:根据JMS消息头设置消息延迟
TIBCO-EMS是一种消息中间件产品，它基于JMS（Java Message Service）标准，用于在分布式系统中进行异步通信和消息传递。它提供了可靠的消息传递机制，支持高性能、可伸缩性和可靠性的消息传递。
根据JMS消息头设置消息延迟是指在发送消息时，可以通过设置消息头中的属性来延迟消息的传递。这种延迟传递的机制可以用于实现消息的定时发送或者在特定条件下延迟消息的传递。
TIBCO-EMS提供了一种称为"Delivery Mode"的消息传递模式，其中包括两种类型：持久性消息和非持久性消息。持久性消息会被持久化存储，确保即使在发送者和接收者之间出现断开连接的情况下，消息也能够被传递。非持久性消息则不会被持久化存储，如果发送者和接收者之间出现断开连接，消息将会丢失。
要设置消息延迟，可以使用TIBCO-EMS提供的消息头属性"JMS_TIBCO_PRESERVE_UNDELIVERED"和"JMS_TIBCO_MSG_DELIVERY_TIME"。"JMS_TIBCO_PRESERVE_UNDELIVERED"属性用于指定消息在发送失败时是否保留在服务器端，而"JMS_TIBCO_MSG_DELIVERY_TIME"属性用于指定消息的延迟传递时间。
应用场景方面，消息延迟功能可以在需要定时发送消息的场景中发挥作用，例如定时任务调度、延迟通知和提醒等。通过设置消息延迟，可以实现更加灵活和精确的消息传递机制。
腾讯云提供了一种类似的消息队列服务，称为腾讯云消息队列 CMQ。CMQ支持消息延迟功能，可以通过设置消息的延迟时间来实现延迟传递。您可以通过腾讯云消息队列 CMQ的官方文档了解更多关于消息延迟的详细信息和使用方法：腾讯云消息队列 CMQ。
相关·内容
我正面临着我的jms模型的一个问题。例子是:在我的mainPS中，我根据请求给出了一个employeeId，它可以通过emploeeId >=获得员工，而不是给定的。回应是员工拼贴。在mainPS中的响应操作中，我循环整个集合和id，希望将一个一个的雇员作为简单消息添加到JMS中。在每一次循环迭代中，im在if语句中设置用户定义的传输头作为msgName‘偶数’或‘奇数’取决于employeeId的出站请求。在标记的结果上，我可以看到标题已经正确地添加了。然后(仍然是针对每个员工)，我发布了我的JMS-BS，它将消息添加到队列中。当我想要在JMSConsumerPS中提取我的消息时，没有
浏览 0提问于2014-04-24得票数 0
回答已采纳
我以下列方式向队列发送消息：
我要安排时间重复我的信息。我的意思是，无论控制器中的这一行jsmClient.send(identifier);发送什么消息(如下所示)，我都想继续发送，比如发送10或100次(取决于我设置的计时器)。我的消费者(以下未显示)将继续使用相同的信息，直到我要求它停止。例如，即使我的制作人将发送消息10或100次，如果我想在第5次(如果生产者发送消息10次)或第50次(如果生产者发送消息100次)停止接收消息，我应该能够做到这一点。
由于我使用的是JMS 2和ActiveMQ (5.15.8版)，所以我无法理解以下内容：
文档在下面的部分中讨论了AMQ_SCHEDUL
浏览 0提问于2019-02-25得票数 0
回答已采纳
在我的骆驼Router.java，我有下一个路线
from("jms:topic:test.source.topic?asyncConsumer=true")
.log("Message: ${body}")
.to("kafka:testing?brokers=192.168.0.100:9092");
from("kafka:testing?brokers=192.168.0.100:9092")
.log("Message received f
浏览 1提问于2020-09-18得票数 1
回答已采纳
我在玩Camel，作为一个简单的测试案例，我想向传入的消息添加一个头部，并将其存储在JMS队列(activemq)中。这是使用REST dsl的代码：
rest("/query-set")
.id("queryset-route")
.get("{id}")
.route()
.process((exchange) -> {
exchange.getIn().setHeader("myHeader", constant(UUID.randomUUID()))
浏览 2提问于2018-03-21得票数 2
我有一个应用程序，它使用Solace作为消息代理。应用程序正在工作--消息在队列上接收，然后正确放置在主题上--但是当创建消息时，将引发以下错误消息。我想弄清楚为什么会发生这种事。
03:31:12.479 [taskExecutor-8] WARN o.s.i.jms.DefaultJmsHeaderMapper - failed to map Message header 'JMS_Solace_TopicSequenceNumber' to JMS property
java.lang.IllegalArgumentException: Property SOLACE_
浏览 3提问于2013-10-06得票数 0
我们正在尝试使用Mule ESB和JBoss消息来构建简单的事务jms到jms路由器。当我们使用配置如下的应用程序运行Mule ESB时，我们会观察到奇怪的行为。
大约有10条消息从队列test1路由到test2。
40秒内什么也没发生。
后藤1
当我们开始测试时，队列test1被大约500条消息填充。我们使用Mule 3.2和JBoss 5.1。
如果从下面的代码中删除事务运行良好，那么所有消息都会立即发送到test2队列中。而且，如果我将事务从xa更改为jms --将xa事务标记替换为jms:transaction，则一切都很好。
我不知道是什么导致了ESB上消息处理的
浏览 6提问于2012-05-07得票数 2
回答已采纳
如果我通过指定sessionTransacted=true或transactionManager=jmsTransactionManager在DefaultMessageListenerContainer上启用事务管理，则每当MDP中发生异常时，就会回滚事务，并将消息放回队列中。然后导致消息被再次处理，事务一次又一次地回滚，因此它创建了一个无限循环。
我想我的问题是。这里我漏掉了什么？如果只是意味着消息将被一遍又一遍地处理，为什么要让消息回到队列中呢？
<!-- jms connection factory -->
<bean name="jmsConnectionF
浏览 0提问于2011-07-01得票数 2
回答已采纳
我们需要使用SI服务为GUI提供服务。图形用户界面通过JMS队列与后端通信，并将在jms replyTo标头属性中指定的tmp队列上等待响应。
因此，可能有10个gui向后端发出查询，并在它们各自的tmp队列上接收消息。
因此，我使用入站网关编写了一个SI服务，如下所示
<int:channel id="inChannel" />
<int:channel id="outChannel" />
<int-jms:inbound-gateway id="jmsSampleService" request-dest
浏览 5提问于2015-03-05得票数 1
下面是使用Spring和Webphere进行消息传递的配置。
我需要为场景实现重试逻辑，其中我从队列接收消息，并将消息数据放到弹性搜索服务器(搜索服务器是非事务性的)，如果搜索服务器关闭，则必须再次将消息回滚到队列中，并在某个时间间隔(例如:30秒)后处理消息。这个重试必须做5次。消息被放入死信队列5次后，.we使用Tomcat作为服务器。
我们使用spring集成jms:消息驱动-通道适配器来接收消息。
如何使用spring和Websphere MQ实现此行为？
我已经爬过许多站点，我可以找到对Active MQ的支持，但不支持IBM。
<bean id="mqConnecti
浏览 0提问于2015-12-17得票数 3
回答已采纳
我刚刚开始对Kafka的探索，我无法理解kafka中什么是键值的需要，因为我们也可以直接发送消息，像JMS这样的单个字符串。通过指定键可以从记录中获取值吗？(我正在将它与JMS中的选择器进行比较，因此我们可以在此基础上过滤消息)。
我们如何通过消息传递标头？是否有可能只发送带有标题而不是键值对的消息？
浏览 3提问于2019-09-22得票数 0
回答已采纳
我们目前正在通过JMS使用IBM MQ，但似乎处理的消息超过了它的处理能力-奇怪的是，这个问题似乎是间歇性的。
消息是价格，因此不需要保证，只需快速发送即可。
由于IBM有一个，我想知道这是不是更好的解决方案-但它似乎没有JMS，或者至少不容易看到。
任何人都知道Low Latency产品中是否有JMS api，或者它拥有的“独特”API是否类似于JMS……
或者，用于MQ调优的指针也会受到欢迎……:)
浏览 0提问于2009-10-09得票数 5
回答已采纳
1回答
在spring集成中使用出站网关时，我试图在JMS报头中发送应答Q详细信息。我了解到JIRA #INT-97中的增强功能在发送到JMS目的地之前将spring消息头复制到JMS头部。
在将消息发送到出站网关之前，请将消息头设置如下。message.getHeader().setAttribute(JmsTargetAdapter.JMS_REPLY_TO，myReplyDestination);
但我无法在任何SI jars中找到JmsTargetAdapter类。
有人能帮我拿开这门课的罐子吗？
另外，我下面的理解是否正确？
使用JMSReplyTo属性充实消息头，该属性有一个MQQue
浏览 3提问于2015-11-09得票数 0
回答已采纳
在GlassFish中的MDB池上接收消息时，我遇到了死锁情况。如果我收到多条同时尝试更新同一组行的消息，MDB就会抛出LockAcquisitionException。不幸的是，GlassFish JMS提供程序立即重新传递消息，导致同样的异常再次发生。我希望将JMS提供程序配置为在延迟后重新交付，但似乎不支持这一点。有什么办法可以解决这个问题吗？
浏览 2提问于2011-04-05得票数 0
2回答
我正在用webMethods构建一些JMS触发器。
我希望根据消息有效负载中的某些条件来过滤我的消息，该有效负载是JMS消息正文字符串的一部分。据我所知，JMS消息选择器不会进行这种过滤。我正在尝试看看Xquery是否能够为我做到这一点。
您知道Xquery是否可以提取隐藏在XML (位于JMS消息正文字符串中)中的字段的值？
浏览 0提问于2015-07-24得票数 3
1回答
我需要实现中描述的"ActiveMq request response“。发送方使用ruby编写，使用STOMP，接收方使用java编写，使用JMS (camel)。
发送者订阅一个临时队列，并将消息发送到另一个(静态)队列，其JMSReplyTo头设置为临时队列的名称(参见)。
接收方获得此消息(带有头部)，JMSReplyTo=queue:///temp-queue/fdc68b92-efe2-4d6f-b239-0539c4705e57)，对其进行处理，并将结果放入回复队列中。但是，STOMP客户端不会收到任何内容。如果我使用“普通”队列，一切都会正常工作。
如何让它正常工作？
浏览 6提问于2018-02-05得票数 0
我正在使用简单的Spring发送消息到JmsTemplate。
<beans:bean id="myJMSTemplate" class="org.springframework.jms.core.JmsTemplate">
<beans:property name="connectionFactory">
<beans:ref bean="cachedConnectionFactory" />
</beans:property>
<be
浏览 0提问于2016-06-24得票数 4
我可以找到在生产者的供应和消费者的消费之间造成延迟的方法。
但我想知道是否有任何可能的方法在每个message.Say上造成延迟，我希望我的消费者每2秒只挑选一条消息，但我希望我的生产者以其最佳性能速度生产，因为我的消费者没有生产者效率高。那么，有没有一种方法可以在消息从队列发送到消费者之前控制其延迟呢？
我在producer上试用了weblogic.jms.extensions.WLMessageProducer producer = (weblogic.jms.extensions.WLMessageProducer)queueSender;
和
浏览 1提问于2013-10-09得票数 0
我有一个tibco队列，在这里我们接收来自生产者的消息，而骡子流正在消耗这些消息。在jms:连接器中，我将numberOfConsumers设置为20。有些时候，当负载很高时，我的消息就会在流中按顺序接收。我希望我的流能够按顺序接收消息，而不会使其单线程化。
下面是流开头的带有记录器的流：
<flow name="some name" doc:name="ServiceId-8" initialState="started">
<jms:inbound-endpoint queue="${queue1}"
浏览 2提问于2018-05-14得票数 0
1回答
当我通过JMS在MQ队列中写入消息时，RFH报头也会添加消息作为其属性。
财产，包括
Jms传递模式
JMS目的地
JMS时间戳
Mcd.msd
有人能解释一下它的用途和意义吗？
浏览 5提问于2018-05-30得票数 1
我使用Spring jms将jms消息发送到websphere mq，在目标解析器上使用目标客户端as 1。但是，这会导致删除我为jms消息设置的所有自定义标头。当我将目标客户端设置为0时，它工作得很好，但出于其他原因，我需要将它保持在1。谁能解释一下这里发生了什么，以及一个可能的解决方案。谢谢。
浏览 2提问于2016-05-18得票数 1
我有一条jms消息，报头中有一个名为id的属性。
在我的监听器中，当此jms消息被转换为消息时
@JmsListener(id = "cis-listener", destination = "${amiga.service.jms.cis-listener.destination-fqdn}",
containerFactory = "containerFactoryListener")
public void receiveMessage(Message<Object> event) throws UnknownMes
浏览 0提问于2021-03-18得票数 0
我试着在apache-camel路线上读取jms头文件。下面是我阅读body & header的路径。
String endPointTopic = "activemq:topic:geoLoc";
String endPointTopicOut = endPointTopic + "_outbox";
from(endPointTopic)
.log("Message from Topic is ${body} & header is ${header.Action}")
浏览 2提问于2015-12-30得票数 1
回答已采纳
我正在尝试将消息在队列中延迟几秒钟。但是当我使用camel延迟选项时，它不是在队列中延迟，而是立即被消耗，并在路由路径中延迟。我们如何延迟消息，使它们在队列中停留几秒钟？
我的带有驼峰配置的弹簧如下所示。
<bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>
&
浏览 3提问于2015-11-05得票数 0
我想要延迟消息传递的特定时间，这将是不同的每条消息。
我推荐了推荐使用javax.jms.Message.getIntProperty("JMS_BEA_DeliveryTime")的。
但是，我不知道如何将JMS_BEA_DeliveryTime设置为INTEGER。我还以为是long呢。
我找不到任何关于这个属性JMS_BEA_DeliveryTime的文档来解压它，以及如何设置和使用它。谁能举例说明如何设置所需的交付时间或链接到此属性的使用文档。
我的代码看起来像Spring JMS模板的典型用法：
jmsTemplate.send(destination, new M
浏览 1提问于2012-11-20得票数 1
回答已采纳
我是IBM Websphere MQ服务器的新手，在使用它时遇到的问题很少。我正在使用MQQueueConnectionFactory向队列发送消息。这是我的代码。
MQQueueConnectionFactory connectionFactory = null;
QueueConnection queueConn = null;
QueueSession queueSession = null;
QueueSender queueSender = null;
TextMessage message = null;
try
{
connectionFactory = new MQQ
浏览 2提问于2016-01-29得票数 0
我正在尝试设置一个camel上下文，该上下文轮询weblogic jms队列，使用消息并将其发送到webservice端点。如果事务中出现任何错误或目标系统不可用，我需要重新传递相同的消息，而不会丢失顺序/排序。 我已经设置了一个单消费者的camel jms路由，并根据https://camel.apache.org/transactional-client.html启用了事务属性，并将重新交付设置为无限制。 当事务因延迟而失败时，将回滚来自weblogic队列的jms消息消耗，并在weblogic中将messageA标记为重新传递(状态字符串标记为messageA )。但在此期间，如果另一
浏览 26提问于2019-06-14得票数 0
回答已采纳
即使使用JNDI连接工厂，Spring JMStemplate也需要大约200到240毫秒的时间来发布消息。
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/mvc"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:beans="http://www.springframework.
浏览 1提问于2014-06-11得票数 0
我在JBoss 4.x上将遗留的EJB2.x迁移到了WildFly 17.x上的JPA/ EJB 3。我的应用程序依赖于JMS重传计数来执行特定的消息传递顺序。
在JMS4.x中，我经常通过来自JBoss消息的JMS_JBOSS_REDELIVERY_COUNT属性查询重发计数。
在WildFly中，没有关于的信息。WildFly如何跟踪重发计数，是否有通过属性或其他方式访问它的规定？
浏览 5提问于2019-12-12得票数 1
回答已采纳
failover:(tcp://localhost:61616)? jms.useAsyncSend=false&jms.redeliveryPolicy.redeliveryDelay=14400000")
我已经定义了上面的队列url，将重发延迟设置为4小时。但是，当出现预期异常时，消息将立即重新尝试5次，并从队列中退出队列。有什么想法吗？
浏览 1提问于2015-04-17得票数 0
回答已采纳
2回答
我正在使用JMS连接器连接到IBM MQ。如果我使用IBM MQ Connector，我可以选择(targetClient="NO_JMS_COMPLIANT")禁用消息中的RFH头。如何使用JMS连接器实现相同的功能。我的JMS配置如下所示 <jms:config name="JMS_Config" doc:name="JMS Config" doc:id="b675becf-06f3-4847-bb95-4f468d5353ea" >
<jms:generic-connection specific
浏览 21提问于2020-01-18得票数 0
回答已采纳
2回答
我正在向一个我无法控制的远程队列发送消息。
我发送了一个xml文件作为消息，但是当应用程序读取消息时，它会得到一个消息头，如下所示
<mcd><Msd>jms_text</Msd></mcd> \0\0\0l<jms><Dst>queue:///TEST</Dst><Tms>1281475843707</Tms><Cid></Cid><Dlv>1</Dlv></jms>
我不希望这个消息头出现，我发送这个消息的代码如下：
Pr
浏览 0提问于2010-08-16得票数 5
回答已采纳
在Tibco世界中有这样的情况:消息(Soap/ JMS)被发送到队列中，消息最终通过一个主题返回。
点到点场景通过Loadrunner提供的JMS函数轻松工作
在这种情况下(发布-订阅)，在输入消息(队列)->输出消息(主题)的情况下，不能将主题转换为队列jms_set_message_property("JMSReplyTo“、"JMSReplyTo”、"TopicName")；
jms_send_message_queue (“发送JMS消息.”)；
在com.mercury.ws.jms.SessionManagerImpl.get
浏览 0提问于2015-12-05得票数 0
回答已采纳
2回答
我们有支持JMS2.0的IBM MQ8.0。除了使用JMS模板的set传递延迟之外，是否有一种方法可以设置消息的传递延迟？特别是在消息头中，比如在active MQ中。
浏览 5提问于2016-06-01得票数 2
回答已采纳
我们尝试使用JMS模板发送MAP (java.util)，但在客户端我们无法读取消息，在服务器启动期间，spring boot @JMS侦听器抱怨以下消息，这适用于WAS 7，但不适用于WAS Liberty 8.5.5，iam还包括代码片段以及我们为不同版本的服务器接收的不同消息格式。在in中有什么改变吗？
是LIBERTY -7-
at org.springframework.messaging.handler.invocation.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:116) ~[spring-messagi
浏览 23提问于2019-07-11得票数 1
回答已采纳
因此，我使用spring集成的jms:outbound-channel-adapter，在将消息传递到消息传递系统之前，需要设置消息的优先级。
现在，在简单的JMS中，我有两种方法来实现它。
或者在MessageProducer上设置优先级
this.producer.setPriority(i);
或者在发送方法本身上：
channel.send(message, DeliveryMode.PERSISTENT, 5, 1000);
由于通道适配器将我从这些细节中抽象出来，这些选项都不再适合我。
设置消息本身的优先级只在spring集成的内存中工作，并在我将其放入实际队列后立即失效。结果，设
浏览 3提问于2015-10-19得票数 2
回答已采纳
有没有一种方法可以拆分大的消息负载并通过Spring JmsTemplate发送？
IBM MQ支持通过属性JMSX_GROUPID和JMS_IBM_LAST_MSG_IN_GROUP拆分大型有效负载，但是现在似乎有方法(无法找到任何资源)来通过JMS发送大型文件。
我的队列最大大小设置为4Mb，并且我必须以ByteMessage的形式发送超过100Mb的消息。
浏览 0提问于2017-10-24得票数 0
1回答
通过ESB仅执行基于JMS的消息传递。ESB有一个专用的请求队列，客户端使用SOAP包装器发送服务请求。包装器被解释为服务名称和版本、注册表查找、到服务队列的路由。服务在专用ESB应答队列上响应ESB。然后需要关联到正确的存储请求，以便将回复发送回其TMP队列上的客户端。我不知道如何使用服务发送的消息ID作为关键字将原始JMS请求的TMP队列保存到某种缓存中，以便检索原始请求、消息ID和TMP队列？
所以有两个问题。如何访问代理配置中的jms msg头。如何设置某种类型的缓存或存储要用于响应的数据，以便将它们与请求相关联并设置回复。文档中根本没有纯JMS示例。
浏览 1提问于2013-02-15得票数 0
1回答
如何将JWT附加到JMS消息？
、、、、
我们需要在每个JMS消息旁边发送一个JWT令牌。除了将其打包到有效负载本身之外，我不确定在JMS和/或ActiveMQ消息结构中是否可以使用附件或标头。
查看了ActiveMQMessage，但没有找到附件或标头。
浏览 0提问于2019-08-06得票数 0
回答已采纳
2回答
我正在从事移民项目。我想在jms消息文本上设置过滤器。在这里，JMS消息文本内容具有xml消息。在jms中是否有任何方法可以在xpath或某些文本内容上添加筛选器，或者提供这种功能的任何工具？
浏览 1提问于2015-02-04得票数 0
回答已采纳
我们需要在WebSphere 7中创建一个JMS队列，该队列在消息中指定的日期之前不会将消息传递给MDB。如何制作这样的自定义队列或队列处理器？到目前为止，我还没有找到任何相关的信息。
我们更喜欢使用内部JMS提供程序，但如果这不可能，我们希望尝试使用WebSphere MQ。
谢谢
浏览 2提问于2014-08-02得票数 0
我想轮询队列中不超过30分钟的消息。
如何使用jms:message-driven-channel-adapter实现这一点？请帮帮忙。
浏览 1提问于2017-08-29得票数 0
对于我的测试用例，我需要向ActiveMQ发送完整的消息(带有头和属性)，并使用JMS-publisher采样器获得JSON文件格式的消息。
如何将JSON文件(或任何格式的文件)从JMS-publisher采样器发送到ActiveMQ？
或者，我如何从JMS-publisher采样器向ActiveMQ发送完整的消息？
提前谢谢。
浏览 0提问于2018-06-20得票数 0
1回答
有一个请求队列，应答队列由客户机服务器实例创建，并固定在每个实例上，而不是使用临时队列。
用例需要获得入站jms消息，然后将该消息发送到异步进程。一旦从服务接收到异步回复消息，我需要获取这些结果并回复到原始消息的jmsReplyTo。在此实例AFAIK>中，Jms网关无法工作。
我使用jms消息驱动的通道适配器来处理进程外调用和异步回复，其中包含一系列通道和服务激活器。我正在尝试使用DynamicDestinationResolver，但没有效果。此外，我试图通过编程设置出站目的地地址，但无法找到一个好的方法来做到这一点。
这似乎是一种常见的模式，但我找不到一个完全断开连接的异步请求响应
浏览 1提问于2015-07-17得票数 2
回答已采纳
我有一个JMS客户端，它正在向具有优先级的Weblogic队列发送消息。为了简单起见，我们有2个优先级设置为0和9。
在服务器端，我们在该队列上部署了Spring Application (带有Spring MDP消息驱动的Pojo)。下面是Spring Bean声明：
<bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
<property name="concurrentConsume
浏览 2提问于2012-03-26得票数 0
回答已采纳
我有一个jms:message-driven-channel-adapter，在它的下游有一个jms:outbound-gateway.每当我在一个线程中的通道适配器中得到消息时，这个问题就会发生，如下所示
在另一种情况下，org.springframework.jms.listener.DefaultMessageListenerContainer**#1-4**和网关响应如下：
org.springframework.jms.listener.DefaultMessageListenerContainer**#3-5**.
我有个奇怪的例外：
org.springframework.int
浏览 2提问于2014-11-25得票数 0
回答已采纳
我使用以下代码来创建int-jms:message-driven-channel-adapter，但是，它似乎是基于轮询的，因为它以1秒的间隔返回数据，而不是响应滴答。
我定义的流程如下：
jms.listen(requestDestinationName = "myTopic", connectionFactory = connectionFactory).additionalAttributes(requestPubSubDomain = true) --> ...
问题是，如何让它成为消息驱动的？
浏览 2提问于2012-06-29得票数 0
1回答
有没有办法监控ActiveMQ JMS主题中的消息，最重要的是删除较旧的消息，例如删除一个月前的消息。
我正在使用Apache Camel来构建ActiveMQ连接和JMS主题。
浏览 0提问于2013-09-25得票数 4
1回答
在ActiveMQ中，我浏览我的que“帐户”。当我点击它时，我可以看到不同的消息都有一个消息ID，“我的计算机名-一些数字”(我认为它们是由ActiveMQ设置的)。
我想让骆驼从que中读取数据，并将数据写入一个名为“My-computername-some named s.xml”的文件中。现在，我的输出文件仅为".xml“。
我的代码：
from("jms:accounting")
.log("### Read jms:accounting ###")
.to("file:src/main/resources/data/work_in_
浏览 2提问于2017-10-23得票数 0
回答已采纳
我想按序列1、2、3....执行setJMSMessageID。同时在HornetQ中发送JMS消息。但是每当我尝试将我的自定义MessageID设置为JMS消息时，在消费者端，相同JMS消息的MessageID是不同的。
在这样做的过程中，我发现JMS MessageID有一些特定的格式。那么我该如何设置我的自定义MessageID呢？
浏览 2提问于2013-05-06得票数 0
1回答
设想情况：
JMS队列中的许多消息
MDB将它们传递给远程HTTP服务器
远程服务器可以关机
需要不阻塞整个服务器的重试机制。
送货周期为几天，每1小时一次。
我的想法是，当新消息到达JMS队列时，MDB尝试立即重发，但限制在每1分钟5次。然后将消息从JMS队列中删除并放入数据库。另一个(@调度) EJB将每1小时从DB接收未发送的消息，并在自己的线程中发送它们。
有更简单的方法吗？
浏览 0提问于2013-02-15得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
