WebSphere MQ中怎么处理队列中超时未处理的消息?

在使用MQ工具时,队列中会堆积一些已经超过响应时限的消息,这时程序已经不会再读取这些消息,MQ本身有处理这些超时消息的机制么?
使用的场景是这样的:
A,B两个系统通过MQ中间件进行交流通信,A发请求至Q1队列,并根据关联ID对Q2进行监听,B系统从Q1中读取消息并处理,将响应消息放入Q2队列,A再从Q2中读取响应,此时,如果超时,Q2中的信息将不再读取,就会堆积在队列中。
MQ中有没有这样的机制,针对一个队列的属性设置,如果该队列中的某一条消息超过一定存在时间,则把该条消息删除或移走?

求各路大神指导,拜谢.

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
往Websphere MQ 本地队列中 放入消息和获取消息
在访问一个队列首先需要获取队列管理器对象,   需要提供如下属性信息, 如: 队列管理器名称,端口号,服务通道,主机名称,通过这些属性就能获取队列管理器, 然后通过队列管理器 访问队列, 放入消息 即可。 最后,关闭队列。   下面是一个把消息 放入 WebSphere MQ 本地队列中 程序代码:   建立一个QueueManagerEntity实体: 如下: priv...
was 中的JMS 与websphere MQ 中队列的绑定?????
我在was中配置了一个队列,JNDI为jms/queue1,、rn另外我在MQ中建立了一个队列管理器QM1,在这个队列管理器中我有建立了rn一个队列Q1。rn我该怎么配置才能把jms/queue1 和 Q1绑定起来
websphere MQ 消息回退与死信队列的问题.
首先,我想弄清几个问题.rn1.消息bean的OnMessage()方法中抛出异常引起的消息回退,回退的消息是否被自动放入死信队列(假设死信队列已在消息管理器中配置正确)?rn2.若第一个问题的答案是能.应该如何配置死信队列?rn3.如果第一个问题的答案是不能.请问如何设置能将1中回退的消息自动清除或是自动转移到其它队列?rn我这里的情况是有一个消息Bean(容器管理事务) 从MQ的Queue里获取任务.而这些任务不一定合法.应此有可能在onMessage里抛出异常.这导致消息被回退多交并被重试多次.而重试后依然抛出异常并继续回退,最终使消息bean的监听关闭.rn我开始想到用死信队列处理这些回退的消息.但在配置死信队列后,这些回退的消息并没有被自动放入死信队列.rn各们同仁有遇到这种类似的情况没有.请问都是怎么解决的?希望能提供一些参考.rnrn
MQ在websphere中的设置
有个web程序,作为MQ的客户端,打成war包在tomcat跑时能够正常的与MQ的服务端通信返回数据,rn可是同样的war包放到websphere61时却出错,想问的是为什么出错了,难道MQ需要在websphere中作特殊的设置?rn[11-3-10 17:33:08:546 CST] 00000014 SystemOut O [ERROR] com.ibm.mq.MQException: MQJE001: 完成代码为“2”,原因为“2044”。rn at com.ibm.mq.MQQueueManager.(MQQueueManager.java:1457)rn at com.ibm.mq.MQManagedConnectionJ11.getConnection(MQManagedConnectionJ11.java:414)rn at com.ibm.mq.MQSimpleConnectionManager.allocateConnection(MQSimpleConnectionManager.java:189)rn at com.ibm.mq.MQQueueManagerFactory.obtainBaseMQQueueManager(MQQueueManagerFactory.java:869)rn at com.ibm.mq.MQQueueManagerFactory.procure(MQQueueManagerFactory.java:761)rn at com.ibm.mq.MQQueueManagerFactory.constructQueueManager(MQQueueManagerFactory.java:712)rn at com.ibm.mq.MQQueueManagerFactory.createQueueManager(MQQueueManagerFactory.java:171)rn at com.ibm.mq.MQQueueManager.(MQQueueManager.java:684)
急!!!!怎么用websphere新建MQ队列!!!!
小弟是websphere新手,rn在本机装了websphere,试图新建MQ队列,我是按以下过程来的:rn1.新建websphere MQ serversrn2.新建Connection factoriesrn3.新建Queue connection factoriesrn4.新建Queuernrn其中从第一步开始,每一步都报错:原因为“2059”(“MQRC_Q_MGR_NOT_AVAILABLE”)。rnrn其中新建websphere MQ servers时报的错为:WebSphere MQ server MQserver connection test failed for WebSphere MQ queue manager MQserver. CWSJP0050E: An attempt to connect to WebSphere MQ queue manager or queue sharing group MQserver failed. The WebSphere MQ reason code is MQRC_Q_MGR_NOT_AVAILABLE (2059)..rnrnrn请问高手小弟建队列的步骤和方法有没有错,遇到这种问题怎么解决,可能是什么原因引起的。rnrn感激不尽
IBM WebSphere MQ消息持久化
描述MQ消息持久化,在队列管理器发生异常时,传送到队列中的信息怎样通过日志将信息恢复到队列中。
请问在 websphere mq 中怎么指定 hostName
如果使用默认的hostname程序就可以运行成功,但如果指定了hostname程序就会出错rnrn会出现rnMQJE001:发生 MQException:完成码 2,原因 2195rnMQJE020:队列管理器不支持 CCSIDrnMQJE001:完成码 2,原因 2195rnA WebSphere MQ error occurred : Completion code 2 Reason code 2195rnrn请问是什么原因?rnrnString hostName = "justin";rnString channel = "S_justin";rnString qManager = "QM_justin";rnString qName = "clq_default_justin";rnrnrnrnMQEnvironment.hostname = hostName;rnMQEnvironment.channel = channel;rnMQEnvironment.properties.put(MQC.TRANSPORT_PROPERTY,MQC.TRANSPORT_MQSERIES);rnrnrn
websphere 中是否集成 websphere MQ?
websphere 中是否集成 websphere MQ?
WebSphere MQ中将消息发送至远程队列的配置
在学习本教程之前,你需要先在linxu环境下安装MQ并配置完成,可以百度一下教程很多,很简单。(入职第一天老大给了一个任务四天时间学习IBM MQSeries并写一份学习报告,现在基本上初步对MQ消息队列有了初步的了解,写一些笔记总结总结,也方便大家学习...)。注:部分内容转 本教程介绍了如何设置一台计算机上的队列管理器 QM_ORANGE 与另一台计算机上的队列管理器 QM_APPLE 之间
mq put 消息到远程队列
[mqm@yyjk sbin]$ cat put_mq_message.pl use MQSeries qw(:functions); use MQSeries::QueueManager; use MQSeries::Queue; use MQSeries::Message; use MQSeries::Command; use Data::Dumper; use M...
WebSphere MQ中的基本概念和对象
WebSphere MQ中的基本概念和对象
C# 实现消息的收发IBM WebSphere MQ 队列
一个C#实现IBM WebSphere MQ 消息收发的实例,自己平时写的,如遇困难,请留言
IBM WEBSPHERE MQ实现本地队列消息传收
IBM WEBSPHERE MQ实现本地队列消息传送接收。websphere资源管理器中队列,通道等的创建过程,以及java代码实现数据的传输
MQ,websphere mq
MQ学习资料,websphere mq,有3本关于mq的电子书
IBM websphere MQ远程队列的简单配置
原理: 1.远程队列分发送方和接收方 2.接收方配置: 接收方配置要先拿到对方的发送通道配置,接收方的队列名称必须和远程发送方的队列名称一致,告诉远程发送方,你的地址,队列管理器名称等信息,在通道中建立一个接受方通道即可, 远程发送方就可以连接了。 3.发送方配置: 发送方配置要先拿到对方的接收方通道配置,首先建立一个传输队列,(传输队列就是一个本地队列,只不过属性不一样),在传输队列,
迁移 WebSphere MQ 队列管理器的一些办法
#在A服务器上使用的指令 su - mqm #进行mqm用户 cd /tmp dmpmqcfg -m 8AIR -a > 8AIR.dump #dmpmqcfg 导出8AIR队列管理器对象定义 dmpmqcfg -m 8AIR -o setmqaut > 8AIR.aut #dmpmqcfg 导出队列管理器对象权限定义 #在B服务器上使用的指令 scp  root@192.168.1.
关于WebSphere MQ队列启动的问题
我现在用IBM WebSphere MQ和IBM WebSphere Message Broker的时间不长, 现在只是摸索阶段。 现在有一个问题 老是解决不掉:rn问题如下,rn 我在MQ里建了一个本地队列 。现在要把这个队列启起来, 但是老报:WebSphere MQ 队列管理器“***(我的队列名称)”正在启动。rn AMQ7017:日志不可用。rn 退出值 = 71rn注:我的服务里 IBM MQSeries已经启动了rn 这个到底是什么问题?
WebSphere MQ 建立队列管理器错误
我安装MQ后进行默认配置,出现如下错误,很是郁闷。rn本人使用的是Windows2003操作系统。rnrnrn
Websphere MQ入门教程-使用IBM Websphere MQ
博文链接:https://sivyer.iteye.com/blog/117267
WebSphere MQ
WebSphere MQ for java
websphere mq
websphere mq websphere mq websphere mq
C#操作IBM Websphere MQ收发消息
C#操作IBM Websphere MQ收发消息,详细配置操作http://www.cnblogs.com/xlxr45/p/7904991.html
IBM WebSphere MQ发送消息和接收消息
package com.imp; import java.io.FileOutputStream; import java.util.ArrayList; import java.util.List; import com.ibm.mq.MQC; import com.ibm.mq.MQEnvironment; import com.ibm.mq.MQGetMessageOptions; imp
websphere MQ的日志文件怎么查看?
C:\Program Files\IBM\WebSphere MQ\log\队列管理器名\active下的文件打开来全是乱码~~~~是怎么回事啊?我建队列管理器的时候日志是用默认的设置的。
WebSphere MQ 6.0 队列管理器怎么支持 CCSID?
如题.
WebSphere MQ发送接收消息_二
WebSphere MQ发送接收消息_二 MQQueueConnectionFactory
WebSphere MQ安装配置,java发送接收消息
一.准备工作 二.创建MQ队列管理器,本地队列,通道 三.验证MQ是否配置成功 四.java发送接收消息
任务:消息 不可或缺的十种 WebSphere MQ Support
任务:消息 不可或缺的十种 WebSphere MQ Support
分布式事务中常规MQ队列消息的处理流程和特点
           消息中间件在分布式系统中的主要作用:异步通讯、解耦、并发缓存 在分布式部署环境下,需要通过网络进行通讯,就引入了数据传输的不确定性也就是CAP理论中的P(分区容错性的问题)                           流程图:                                              消息发送的一致性如何保障 1.如果业务操作成...
IBM Websphere MQ _02 MQ消息队列、通道、消息的创建及传输
准备条件: 1)  IBM MQ消息中间件软件安装完毕,详见文件夹下TXT文档 2)  Mqm用户及用户组创建完毕 下面开始建立MQ通道及队列 1、  查看目前已创建的队列:dspmq 2、  由于做本地实验,建立并启动两个队列管理器 分别用于ZHAOCONG发送和ZC接收message消息 创建:crtmqm  ZHAOCONG、crtmqm  ZC 启动:strm
Angular1中的超时处理
使用$http在请求访问中处理超时的代码: 关键代码:// 定义一个定时器 var timer = $timeout(function () { console.log('登录超时!'); // 模拟提示信息 });// post的数据 var postData = {"name":"ng", "password":"111111"};// 请求 $http.post('your-login-
websphere 会话超时消息中存在部分无关的文本??
websphere软件:rnrn出现用户会话超时,会返回下列消息:rn•会话已无效。您先前的会话已无效,这是因为它已超时、管理员已将您注销,或者另一个用户已使用相同的用户标识进行登录。请单击“确定”以继续。rnrnrn尝试着登陆了十几次,还是这种情况。rnrn最后,登陆页面无法显示了。rnrn这是哪里的问题?
多线程怎么取线程队列中消息?
-
常规MQ队列消息的处理流程和特点
常规MQ队列消息的处理流程和特点,详细说明 系列资源分享
IBM MQ将消息发送至远程队列
IBM MQ将消息发送至远程队列,文档详细,有截图,有命令
Java 接收IBM mq队列消息
void getConnectInfo() throws MQException { if(qMgr==null){ getInfo(); MQEnvironment.hostname = hostname;//主机IP MQEnvironment.channel = channel;//连接通道名字
在PowerBuilder中如何对组件的未处理消息进行拦截处理?
如何实现鼠标移入与移出一个组件的鼠标形状切换?
Laravel中的队列处理
Laravel中的队列处理队列介绍为什么要有消息队?这里先对其进行一个简单的介绍,方便还不了解的同学理解.在面向对象里,有一个很简单的概念–消息传递,而消息队列就可以在它上面扩展一下,把它说的更通俗些:从执行的角度去看,消息队列把原 来可直接调用的一个函数(一段程序或一个对象)放到另一个进程中了,所以它们之间的消息传递就从直接传递参数变成了以队列为载体来传递所需参数的一种方式.更加详细的介绍可以参
WebSphere MQ FTE 中的资源监控功能
简介: WebSphere MQ File Transfer Edition(以下简称 WebSphere MQ FTE)在多个 IT 系统之间提供无需编程的可靠的、可审计的和可管理的文件传输,并且对文件大小没有限制。本文将向您描述几个场景,以展示如何使用 WebSphere MQ FTE 资源监控功能。 资源监控概述: 资源监控功能是 IBM® WebSphere® MQ ...
Java 获取MQ 本地队列的消息
最近工作中需要用的从MQ队列中取消息的业务..找了一下MQ API写了一个实例..   建立一个QueueManagerEntity实体: 如下: private String queueManagerName; //队列管理器名称; private int port; //端口号 private String svrconn; //连接通道 private Strin...
相关热词 c#检测非法字符 c#双屏截图 c#中怎么关闭线程 c# 显示服务器上的图片 api嵌入窗口 c# c# 控制网页 c# encrypt c#微信网页版登录 c# login 居中 c# 考试软件