如何确保如果JMS队列中的消息未被使用，它应该在特定时间后被删除？
在云计算领域中，确保JMS队列中的消息在特定时间后被删除可以通过以下步骤实现：
- 首先，需要使用JMS提供的消息过期机制来设置消息的过期时间。消息过期时间可以通过设置消息的Time-to-Live属性来实现。Time-to-Live属性表示消息在JMS队列中的存活时间，超过该时间后消息将被认为已过期并被删除。
- 其次，需要确保JMS队列的消费者能够及时处理消息。如果消息在特定时间内没有被消费者处理，那么消息将会过期并被删除。因此，消费者的处理速度需要足够快，以确保消息能够在过期之前被处理。
- 此外，可以使用定时任务来定期检查JMS队列中是否存在过期的消息，并将其删除。定时任务可以使用后端开发技术实现，例如使用Java的定时任务框架或者使用云原生的定时任务服务。
- 另外，可以考虑使用消息监听器来监听JMS队列中的消息，并在消息到达时立即进行处理。这样可以避免消息在队列中滞留过长时间而导致过期。
总结起来，确保JMS队列中的消息在特定时间后被删除的关键是设置消息的过期时间，并确保消费者能够及时处理消息。此外，可以使用定时任务和消息监听器来辅助实现消息的及时删除和处理。腾讯云提供了一系列与消息队列相关的产品，例如腾讯云消息队列 CMQ，可以满足不同场景下的消息传递需求。具体产品介绍和使用方法可以参考腾讯云官方文档：腾讯云消息队列 CMQ。
相关·内容
2回答
如何正确排空与快速生产者的队列？
、、、、
我遇到了需要排出JMS (特别是Tibco )队列的情况。用例是，如果我们要经历一次大的中断，队列就会堆积起来，而处理它将花费太长的时间。因此，我们希望耗尽队列，并执行一个coldstart类型例程来获取当前状态。
到目前为止，我要做的代码如下：
int count = 0;
Message msg = null;
while ((msg = connection.receive(timeout)) != null) {
count++;
}
System.out.println(count + " msgs removed from
浏览 5提问于2014-02-14得票数 0
2回答
有人能给我介绍一个教程或类似的代码吗?在这些代码中，web应用程序使用JMS来执行长时间运行的后台进程？(而不是使用线程)，我非常熟悉JMS消息传递的概念，但从未使用过任何JMS或代理(我正在学习Apache ActiveMQ)
我希望能够:向队列提交一条消息以运行进程，在任意时间检查该进程的状态(进度
谢谢!
浏览 3提问于2010-08-12得票数 5
回答已采纳
如果我通过指定sessionTransacted=true或transactionManager=jmsTransactionManager在DefaultMessageListenerContainer上启用事务管理，则每当MDP中发生异常时，就会回滚事务，并将消息放回队列中。然后导致消息被再次处理，事务一次又一次地回滚，因此它创建了一个无限循环。
我想我的问题是。这里我漏掉了什么？如果只是意味着消息将被一遍又一遍地处理，为什么要让消息回到队列中呢？
<!-- jms connection factory -->
<bean name="jmsConnectionF
浏览 0提问于2011-07-01得票数 2
回答已采纳
1回答
我需要在与创建消息的会话不同的会话中确认消息。如果消费的消息在给定时间内不是ACKed，则应该将其添加回队列。是否可以使用JMS(计划使用ActiveMQ作为代理)。
浏览 0提问于2010-08-16得票数 0
回答已采纳
1回答
我试图开发一个“消息驱动Bean”来处理所有本地ActiveMQ消息，但这是我第一次尝试这样做。
我找到的大部分材料解释了如何使用JBOSS服务器编写MDB，在本例中有一个包含一些队列信息的xml文件，但在所有通配符教程中都没有提到任何类似的配置。
我有以下情况：
一个简单的java项目，比如消息生成器。
运行本地的ActiveMQ实例
部署到Wildfly 10中的EJB项目
我的生产者项目能够向ActiveMQ队列发送消息，这部分可以工作，但是我的TestMDBHandle项目只有一个名为TestMDBHandle的类，带有@MessageDriven注释。这是否足以接
浏览 2提问于2017-10-05得票数 0
我有一个Camel路由，它从一个ActiveMQ JMS队列中读取，进行一些处理，并将结果传递到一个远程目的地。如果此进程的通信部分失败，我希望无限期地重试(直到目标“向上”)。我可以通过创建路由transacted和设置redeliveryPolicy来处理这个问题。在Camel (通过camel.processor.RedeliveryPolicy重新尝试路由的失败部分)和ActiveMQConnectionFactory (通过org.apache.activemq.RedeliveryPolicy重新尝试整个路由)中都设置了重发。
我还有一个要求，就是我们应该能够从JMS中删除一个条目
浏览 2提问于2017-05-19得票数 2
2回答
我们使用IBM作为WebSphere提供者和Spring MDP (消息驱动POJO)。
在JMS中，我们是否可以在消息中配置与时间相关的属性，以便仅在特定的定义时间使用消息？
例如，如果我向队列M1、M2和M3发送三条消息。在那里，我可以配置M2消息属性，比如凌晨3点而消费者方面，消费者只能在凌晨3点选择此消息。如果未定义时间，则应该以JMS接收方使用的方式使用消息。
浏览 3提问于2013-07-12得票数 2
1回答
从JMS队列中获取批处理
、、、
我需要实现以下工作流：
每N毫秒从队列中获取所有可用消息，但不超过K项完成处理后执行的所有消息都是
我感兴趣的是如何正确地使用JMS实现步骤1。
我试过的是：
BlockingQueue.Every 在 MessageListener的onMessage方法中创建一个大小的K，将消息放入N毫秒，排出消息，处理消息，并确认消息。<code>G 220</code>
它看起来不错，但问题是，如果在处理批处理过程中在onMessage中获取了一些消息，那么在批处理完成后，它也会在BlockingQueue中并且尚未被处理()时被添加。因此，如果我的应用程序崩溃，消息将根本不会
浏览 2提问于2021-08-12得票数 1
回答已采纳
3回答
我已经设置了一个ActiveMQ代理和一个消费者。使用者收到一条消息，表示他无法处理，因为它所依赖的服务有一个bug (一旦修复，就可以了)。因此，消息一直被重新传递(使用者重传)--我们使用JMS会话。使用我们目前的配置，它将继续每10分钟重发一次，为期1天。这显然会导致问题，因为其他消息没有被消耗。
为了解决这个问题，我通过JMX访问了队列，并尝试删除该消息，但它并不存在。我想它是缓存在消费者身上的，而在代理上是不可见的。除了重新启动应用程序之外，还有其他方法删除此消息吗？
是否可以配置重发机制，以便将这样的消息(最终导致活动锁)放在队列的末尾，以便可以处理其他消息？
为期10分钟的1天退
浏览 6提问于2014-11-11得票数 3
回答已采纳
1回答
我正在研究一种方法，要求我向SQS发送一条消息。我不希望它成为一条新消息，因为它将重置代码所需的approximateRecieveCount参数。
请注意，I不能将NACK发送到队列中，因为我将它作为一批10条消息读取，因此我希望在某些情况下手动将其发送回单个消息，而不是批处理.。
我试图使用的代码
我试过设置JMSMessageId，但根据文档，这是不可能的-
发送消息后，Amazon为每条消息设置以下标题和属性：
JMSMessageID
JMS_SQS_SequenceNumber (只适用于FIFO队列)
我现在使用的代码是
defaultJmsTemplate.send(
浏览 2提问于2020-04-13得票数 1
是否可以将JMS消息发送到Message Broker中的JMS队列，以便在没有消息存储库的情况下由消息处理器进一步处理？
例如：
<resource methods="PUT" uri-template="/{itemName}">
<inSequence>
<property name="transport.jms.ContentTypeProperty" value="Content-Type" scope="axis2"/>
浏览 1提问于2017-12-21得票数 0
我有一个带有JMS请求-应答块的Mule(3.5)流。我看到所有来回复队列的消息都会自动被消耗掉。我想处理到jms回复队列的消息。到目前为止，我已经尝试了jms:selector和jms请求者模块，但没有成功。有办法做到这一点吗？
代码：
<mule>
<flow name="main" doc:name="main">
<http:inbound-endpoint exchange-pattern="request-response" host="localhost" path=&
浏览 2提问于2014-08-19得票数 0
回答已采纳
今天我注意到了一个很奇怪的问题，消息被收到了，但从未被处理过。在下面的配置中，我有5个侦听器配置为从JMS队列中读取，我的窃听记录器打印接收到JMS消息，但是任务执行器线程没有处理它的跟踪，其余的处理运行良好。只是在某个时候发生了很少的消息。我有以下提供的所有相关配置；任何帮助，以纠正它将不胜感激。
<jms:message-driven-channel-adapter
id="IN1"
浏览 1提问于2015-02-25得票数 1
回答已采纳
1回答
我有一个应用程序，它读取来自HornetQ的JMS消息。
<int-jms:message-driven-channel-adapter
id="myJmsChannelAdapter"
channel="myJmsChannel"
connection-factory="myCredentialsConnectionFactory"
destination-name="${my.jms.topic}"
p
浏览 2提问于2016-02-26得票数 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
我的骆驼路线如下
<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring" >
<route>
<from uri="bean:SendClass?method=send" />
<to uri="jms:MyQueue" pattern="InOnly" />
</route>
<route>
<
浏览 1提问于2010-10-02得票数 2
回答已采纳
1回答
首先:我对WSO2产品非常陌生，但我花时间阅读了一些关于我的问题的文章。
我使用什么产品：WSOE6.1.1
我想要实现的：建立到TIBCO (MOM)的JMS连接，订阅给定的主题并将接收到的消息写成xml文件。给定的文件夹是一个挂载的网络驱动器，进一步的应用程序将查找给定文件夹中的新文件，这是由于遗留代码造成的，我不希望(没有时间)更改文件夹查找，例如soap调用。
我已经做了什么：，我已经阅读了最新的文档，并找到了一个：
经过一些尝试和错误之后，我想我已经成功地为TIBCO设置了JMS侦听器。一开始，我收到了很多连接和错误，现在都是固定的，所以我认为到tibco服务器的一般连接是可以工作的
浏览 0提问于2017-11-10得票数 0
1回答
技术：
Jave EE，Weblogic 10.3，JMS
场景：
一个EJB模块，比如Module_1，有3个不同的消息驱动Bean (MDB)类，监视着3个不同的Java队列(JMS)。消息不断地添加到这些bean中。
问题：
每天一次，在特定的时间，我需要重新启动整个Weblogic，而不会丢失任何消息。另外，在这个服务器上部署了另一个模块，比如Module_2，我需要确保Module_2在Module_1之前启动。
如果任何一个MDB在预定义的关闭时正在处理任何消息，那么我想我将不得不等待它完成。不过不太确定。
有人能提出任何标准的方法/配置来达到这个目的吗？
另外，如果Weblogi
浏览 1提问于2011-12-08得票数 2
回答已采纳
我使用Spring的JMS (v.3.1.2) listener-container，它的JMS connectionFactory来自WebSphere 7的JNDI设置。应用程序正确地处理消息(put/get)，但是MQ队列管理器中设置的备份设置似乎不起作用。
要使消息消耗失败，我对setRollbackOnly()使用spring事务，并且它确实增加了属性“退出计数”，因为我可以看到，随着指向远程队列的"WebSphere MQ资源管理器“，这个数量在增加。
通过阅读一些IBM文档，它描述了IBM客户端需要将坏消息移动到备份队列中。Spring的listener-containe
浏览 2提问于2014-10-03得票数 3
回答已采纳
我正在处理一个独立的MQ JMS应用程序，我们的应用程序需要“意识到”客户端已经使用了放在队列中的消息生产者。因为客户端app不是我们负责的。所以我们不能让他们自己写"msg.acknowledge();“之类的东西(在我的情况下，msg.acknowledge()不是正确的方法)。我在堆栈溢出中搜索历史答案。查找以下内容与我想要的内容完全相同：
我的问题是，是否有其他方法可以将其归档到MQ API或JMS API中？我只需要在msg产生端做编码，它可以是队列或主题。
另一个问题是JMS中的确认模式CLIENT_ACKNOWLEDGE，那是不是无关紧要呢？我一直认为这种模式可以在调
浏览 2提问于2012-01-06得票数 3
回答已采纳
1回答
我目前正在向类似于服务器的应用程序框架中添加JMS支持。JMS将由HornetQ (服务器类路径上的独立代理、hornetq )实现，但既没有JBoss、spring，也没有提供MDB的其他任何东西。
下一步是将消息侦听器添加到xa队列，该队列将允许对传入消息进行并行处理。有些消息会包含长时间运行的任务，因此基本思想是从onMessage方法生成工作线程。
在我穿越互联网的漫长旅途中，我遇到了，其中一位参与者提到他不会这么做，而是为任务使用额外的内部队列:然后(单线程)消息侦听器只会从入站队列中获取消息并为内部队列创建新消息，在内部队列的另一端，一些工作线程会为传入的消息进行竞争。入站消息一旦
浏览 1提问于2012-12-18得票数 6
回答已采纳
1回答
我有一个非常标准的网页应用在EAP 7.2上。请求通过servlet传入，servlet向JMS队列发送消息，然后由MDB处理。在生产者发送消息时，可能有50%的时间MDB上的onMessage()方法从未被调用过。服务器日志文件中没有错误。以下是基本设置：
jboss配置：
<jms-queue name="HIFWebHookQueue" entries="HifWebHookQueue java:jboss/exported/jms/queue/HifWebHookQueue"/>
Servlet侧：
@WebServlet(name = &#
浏览 10提问于2022-11-07得票数 0
回答已采纳
我有一个MDB，当部署在glassfish上时，它可以使用ActiveMQ建议消息。
但是当我在tomEE上部署时，这个MDB不使用任何建议消息。有什么我需要打开的吗？
@MessageDriven(mappedName = "ActiveMQ.Advisory.Consumer.Queue", activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
浏览 0提问于2013-04-18得票数 0
回答已采纳
3回答
低延迟消息队列
、、、、
基本上，我有一个主节点，它在工作节点之间分发任务。工人的数量可以改变，这意味着工人不能在服务器端硬编码。Master向队列提交一个任务，其中一个workers接受该任务，对其进行处理并返回结果。最关键的方面是低延迟。工作节点上的典型进程时间约为100-300毫秒，这意味着消息传递系统不会对进程时间造成明显的延迟。
目前，我正在考虑请求-响应JMS模式。这意味着主节点将任务提交到共享队列，工人将从队列中获取任务并将结果提交给主节点监听的另一个队列。Master会将响应与请求关联起来。
我担心JMS会给系统带来延迟，这是不可接受的。也许我应该看看其他的解决方案？例如RabbitMQ、JGroups
浏览 1提问于2012-09-21得票数 4
我目前在使用jms同步请求/回复方法时遇到了一个问题，这就是发生的事情：
1.)ProgramA创建一个jms消息，一个临时队列，并将其设置为replyTo。
2.)ProgramB有一个监听器监听从ProgramA创建的消息，处理该消息并回复它。但ProgramB需要与第三方web服务通信，有时需要10秒以上的时间才能响应，这就是我将消费者设置为侦听5000 (5秒)的问题，当然，之后会超时。所以消息不会被接收到。
我的观察结果: 1.)即使ProgramA已经完成读取(还没有回复，在那一刻我尝试删除临时队列)。它不能，ProgramB仍然能够写入应答队列，但没有人会读取该消息(为时已晚)。
浏览 0提问于2013-02-15得票数 1
<SubscriberSampler guiclass="JMSSubscriberGui" testclass="SubscriberSampler" testname="JMS Subscriber" enabled="true">
<stringProp name="jms.jndi_properties">false</stringProp>
<stringProp name="jms.initial_contex
浏览 0提问于2019-09-11得票数 0
回答已采纳
我有一个简单的Spring应用程序(SpringBootVersion1.5.3.RELEASE)，用于从ActiveMQ(Version5.14.5)队列中消费JMS消息。
我希望在JMS事务中使用这些消息。如果在消息消耗过程中出现异常，我希望事务将被回滚，而消息不会被退出队列(从消息队列中删除)。在Spring中，我可以看到事务正在回滚，但是消息仍然从ActiveMQ队列(经过六次重传尝试)中退出队列。
任何指示都将不胜感激。
以下是应用程序代码：
@SpringBootApplication
public class SpringJmsDemoApplication {
public
浏览 1提问于2017-05-24得票数 3
回答已采纳
我创建了一个从ActiveMQ读取消息的MDB
@MessageDriven(name = "MessageReaderEJB",
activationConfig = {
@ActivationConfigProperty(propertyName = "acknowledgeMode",
propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName =
浏览 3提问于2017-05-18得票数 0
回答已采纳
我有一个web应用程序，在服务器内部，我创建了一个MessageDrivenBean，以便通过JMS接收消息。
@MessageDriven(activationConfig = {
@ActivationConfigProperty(propertyName = "destinationType", propertyValue = javax.jms.Queue"),
@ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/toServer&
浏览 0提问于2011-10-27得票数 0
回答已采纳
1回答
我正在学习Spring认证，我对的工作方式和Spring如何处理它有一些疑问。
因此，我知道JMS核心组件是：
消息
目的地
连接
会话
MessageProducer
MessageConsumer
据我所知，TextMessage，ObjectMessage，消息是与其他实体(必须使用此数据的其他产品)发送和共享的消息，消息可以具有不同的形状：StreamMessage. MapMessage、BytesMessage和StreamMessage.。
好的，据我所了解，JMS组件的目标组件定义了接收消息的人和发送消息的逻辑。
所以我知道我有两种目的地：
浏览 1提问于2015-03-05得票数 0
回答已采纳
我需要关于JMS队列和消息处理的帮助。
我有一个场景，其中消息需要为特定的属性组同步处理，但可以在不同的属性组之间并发处理。
我对每个属性的消息组和队列有了一些了解。我的想法是，我想要进行特定于属性组的同步处理，这样可能会有7000个或更多的属性组。
我绝对不能有7000个队列。请提供任何建议。
谢谢
浏览 12提问于2018-02-15得票数 1
5回答
如何延迟JMS消息发送或继续不确定的时间？
我使用的是Weblogic，如您所知，在JMS发送之后，接收方将异步处理消息，但是，此时或者有时外部资源对接收方没有准备好，因此，我希望有一些检查逻辑来延迟发送或处理消息。我猜例如:我将消息放入挂起队列，然后频繁地检查资源可用性，然后发送或处理消息？
每个人都知道Weblogic支持它吗?或者如何实现它？
浏览 15提问于2014-01-25得票数 3
如果我们在STOMP中使用，是否可以为队列或地址设置过期时间？
默认情况下，Artemis会自动删除自动创建的队列，但“持久”订阅队列将永远保留。我已经尝试设置expiry-delay address-setting，如果没有定义expiry-address，它将删除消息。但是，Artemis无论如何都会保留订阅队列，这会导致服务器内存不足。我必须每3天删除Docker中的容器。正如您可以想象的那样，这一点也不好。
不幸的是，当客户端在没有取消订阅的情况下关闭浏览器时，通常会发生这种情况。
以下是broker.xml的相关部分
<address-setting match="#&
浏览 4提问于2020-09-08得票数 0
1回答
我们目前遇到了Weblogic JMS的问题，Tibco端收到的一些消息是空白的，但是，我们的日志表明消息是完整发送的(我们在将消息发送到队列之前进行了记录)。我们计划将jms消息存储几天，并验证这是WebLogic端还是tibco端的问题。
我知道JMS中有一个持久化存储，但是一旦消息被发送到客户端，它就会清除消息。我们是否有一个功能可以让我们在一段时间内存储消息？
环境: Weblogic 8.1集成
谢谢。
浏览 10提问于2014-06-20得票数 0
2回答
我有8个Weblogic实例，分布在4台机器上。这8个实例被分组到一个集群中。
这8个实例非常适合EJB容器，但我还有8个Weblogic JMS服务器实例。因此，我的所有JMS消息都被分派到这8个实例上……
我的音量太小，不需要这么多JMS服务器。我希望每台机器只有一个JMS Weblogic实例。
是否可以在某些实例上禁用JMS消息传递？
浏览 2提问于2011-04-12得票数 3
回答已采纳
2回答
我找到了以下链接，用于读取JMS队列中的消息及其工作。
现在，我想以编程的方式阅读JMS队列统计数据，比如消息数量、挂起消息数量和消息在/退出时间等。在、weblogic 或weblogic中是否可以为此目的提供任何API？
请帮帮忙。
浏览 5提问于2016-12-23得票数 5
2回答
调度MDB
、、
我正在寻找一种安排MDB的方法。我的要求是将MDB设置为为公司的系统提供数据。这个系统每天晚上都要出去维护，但其他系统并不知道它，可能会一直试图满足它。持久队列很棒，因为在系统重新联机之前，我的消息可以被填充。
我怎么能做到这一点？我已经遇到过这样的情况：，但它使用的是Java7，最糟糕的是，如果服务器重启，消息就会丢失(消息从JMS队列中取出并保存在内存中，直到定时器处理它)。
它的另一个用途是实现一个“重试”队列。在出错的情况下，我想重试处理我的消息，但不是立即处理，只在一定的时间后。
有什么办法可以让我的MDB离线一段时间吗？
浏览 0提问于2012-08-14得票数 0
回答已采纳
我使用了ActiveMQ 5.10.0，并配置了相同的接收器和代理: tcp://localhost:61666?jms.prefetchPolicy.queuePrefetch=0&jms.redeliveryPolicy.maximumRedeliveries=5&jms.redeliveryPolicy.initialRedeliveryDelay=5000&jms.redeliveryPolicy.useExponentialBackOff=true&jms.redeliveryPolicy.backOffMultiplier=2.0&jms.n
浏览 0提问于2015-01-06得票数 0
我有一个jms生产者，它每秒生成许多消息，这些消息被发送到amq持久队列，并由单个消费者消费，这需要按顺序处理它们。但似乎生产者比消费者快得多，我有性能和内存问题。获取消息的速度非常慢，消费似乎是按时间间隔进行的(消费者以轮询方式“请求”消息，这很奇怪吗？！)
基本上，所有事情都是通过spring集成来实现的。下面是生产者端的配置。第一批消息来自stakesInMemoryChannel，从那里，它们被过滤掉，抛出filteredStakesChannel，然后它们进入jms队列(使用executor，所以发送将在单独的线程中发生)
<bean id="stakesQue
浏览 0提问于2012-11-21得票数 1
我们使用的是JBoss EAP6.4。
有一个JMS队列，它有一个消费者，它会立即使用放到队列中的所有内容。
我想检查放在队列中的是什么，但是对于我的工具(Hermes JMS)，队列总是空的。
我尝试为"org.hornetq“类别配置精细级别的日志记录，但放入队列的消息在任何调试级别都不会被记录。
有没有一种方法可以在队列被立即消耗时查看放置在队列中的内容？
谢谢,
Valery
浏览 21提问于2019-08-12得票数 0
我正在使用弹簧，数字用户线，弹簧靴的solace集成。我的一个订阅者的应用程序每秒能够轮询大约80条消息，4个订阅者每秒能够轮询大约125条消息。我希望每秒至少处理500条消息。我的JMS流程陈述如下-
public @Bean IntegrationFlow defaultJmsFlow()
{
return IntegrationFlows.from(
//read JMS topic
Jms.messageDrivenChannelAdapter(this.connectionFactory).destination(th
浏览 17提问于2018-07-20得票数 0
3回答
我有一个Java应用程序，其中包含许多通过JMS (ActiveMQ)进行通信的组件。目前，应用程序和JMS Hub在同一台服务器上，尽管我们最终计划拆分组件以实现可伸缩性。目前，我们在性能方面有很大的问题，似乎都是围绕着JMS，最值得注意的是，这个问题的焦点是将消息发布到主题所需的时间。
我们有大约50个动态创建的主题，用于应用程序组件之间的通信。一个组件从表中读取记录，并一次处理一个记录，该处理涉及创建一个JMS对象消息并将其发布到其中一个主题。此处理无法跟上向源表写入记录的速率~23/秒，因此我们更改了处理，以创建JMS对象消息并将其添加到队列中。创建了一个新线程，该线程从该队列读取并将
浏览 1提问于2010-11-02得票数 1
1回答
JMS MQ绑定问题
、、、
在使用MDB的MQ队列上绑定JMS有一个奇怪的问题
消息驱动的EJB：CrbEventMessageAsynchronousService无法连接到queue.contratto.crb.input.publicQueue目的地。错误是：
javax.jms.JMSException：MQJMS1017：对接收或browsing>无效的非本地MQ队列
我检查了QueueManager，mq队列被定义为本地队列，而不是异常所说的远程队列。
浏览 6提问于2011-01-25得票数 2
回答已采纳
3回答
我有一个队列，队列中全天都有高优先级的JMS消息，我想让它们快速离开。该队列也被周期性地以大批量的低优先级消息加载。在繁忙的日子里，我看到的问题是，队列前面总是有足够多的高优先级消息，在该卷下降之前，不会选择任何低优先级的消息。通常他们会坐在队列上直到半夜。该应用程序分布在多个服务器上，但CPU并不紧张，JMS似乎是瓶颈所在。
我的直觉是实现某种老化算法，提高队列中已存在很长时间的消息的优先级，但当然，这就是中间件应该为我做的事情。我无法想象JMS提供者(IBM )或应用服务器(TIBCO BusinessWorks)没有某种工具来处理这种情况。所以在我写一些代码之前，我想我会问，有没有办法让
浏览 23提问于2014-12-12得票数 0
我们在weblogic A服务器中配置了一个桥，它从另一个weblogic服务器B队列中挑选消息，并将其放入Weblogic A队列中。
然而，突然我们在wevblogic日志中得到以下异常，并且桥无法从Weblogic Server B队列中挑选消息。
<May 16, 2018 9:30:54 AM IST> <Warning> <MessagingBridge> <BEA-200026>
<Bridge "AAA" encountered problems in one of its adapters or under
浏览 4提问于2018-05-17得票数 0
卡夫卡在经纪人那里没有任何过滤器的概念，可以确保--被消费者接收到的信息符合某些标准。过滤必须发生在使用者(或应用程序)上。-因此，在这种情况下，客户/消费者的处理时间增加了。
对于JMS，如果您的消息传递应用程序需要过滤它接收到的消息，您可以使用JMS消息选择器，它允许消息使用者指定它感兴趣的消息。消息选择器将过滤消息的工作分配给JMS提供者，而不是分配给应用程序。-因此，在这种情况下，JMS提供程序的处理时间会增加
在保持代码整洁和提高性能方面，上述两种方法中哪一种证明更好？
浏览 0提问于2018-11-13得票数 0
3回答
我正在编写一段将消息发送到JMS队列的Java代码。我使用"QueueSender.send()“来做这件事。
JMS queue itsels是sonicMQ，但这不是重点。
我的问题是，有时JMS队列已满，尝试向队列发送消息的线程会耗尽资源。
有没有办法让我在发送消息之前知道队列是否已满？在这种情况下，我更喜欢打印日志中的异常。
顺便说一句，JMS队列代码本身超出了我的能力范围。我只能更改客户端代码。
谢谢。
浏览 5提问于2010-01-30得票数 3
回答已采纳
如果Rabbit MQ使用者从具有手动确认的队列中接收到一条消息，但是该消息以某种方式丢失(从未被确认或被确认)，那么有没有一种方法可以在消息被自动重新排队之前设置时间？
浏览 0提问于2016-10-27得票数 0
1回答
如何在取消部署之前停止消息处理？
、、、、
Given:
JMS消息队列。
定期(从数据库)将消息放入队列的计时器服务。
从队列中读取的JEE6消息驱动bean。
计时器服务和消息驱动bean是不同部署单元的一部分。
问题：
只要消息在进程中工作，消息驱动的bean就不能被卸载，而不会破坏工作流状态。因此，我们首先停止计时器服务，然后等待所有消息完成。
有办法使这种行为自动化吗？或者，如果计时器服务仍在运行，是否有可能阻止取消部署？我们目前正在使用JBoss 4.2.3。
Non-Solutions:
重构部署单元，因为它将涉及多个部门。
我知道系统崩溃不会被覆盖，防弹解决方案应该包括恢复策略。
浏览 2提问于2011-04-26得票数 2
回答已采纳
1回答
在MQ中，如果您有一个现有队列管理器的实例，比如您的应用程序可以访问的queuemanager1。您可以通过queuemanager1创建一个指向另一个队列管理器queuemanager2的队列来发送消息。之所以这样做，是因为应用程序可能无法直接访问queuemanager2，但托管queumanager1的MQ服务器可以。
代码看起来像这样：
null destQueue = queuemanager1.accessQueue("queFromAnotherMngr"，CMQC.MQOO_OUTPUT | CMQC.MQOO_FAIL_IF_QUIESCING，"qu
浏览 2提问于2012-02-29得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
