0

我正在尝试在 weblogic 10r3 服务器上调试 web 应用程序 hostde。com.ibm.mq.jms.MQQueue该应用程序正在通过 Java 消息驱动 Bean接收来自外部 IBM JMS 队列（类名：）的输入。

我编写了一个小型测试应用程序来连接到该队列并发送测试消息。问题是现在测试消息会产生异常，并且它会以某种方式被放回队列并一次又一次地循环。这会产生许多异常，导致日志不可读。

首先，我尝试通过在我的测试应用程序上构建消费者来删除毒消息，但代码无限期地阻塞在consumer.receive().

然后我尝试设置JMSexpiration为某个数字而不是默认的 0，但最终消息仍然使用 0 作为过期。

欢迎所有想法，非常感谢

代码概述了 JMS 生产者：

        static String rawTradeUpload = "some long chunk of data"

        Hashtable ht = new Hashtable();

        ht.put(Context.INITIAL_CONTEXT_FACTORY,
                weblogic.jndi.WLInitialContextFactory.class.getName());

        //ht.put(Context.PROVIDER_URL, "t3://gprimeap1d.eur.nsroot.net:12016");
        ht.put(Context.PROVIDER_URL, "t3://gprimeap1d.eur.nsroot.net:12001");

        ht.put(Context.SECURITY_PRINCIPAL, "weblogic");

        ht.put(Context.SECURITY_CREDENTIALS, "welcome5");

        Connection con = null;
        Session s = null;

        try {
            if(ctx == null)

                    ctx = new InitialContext(ht);


            ConnectionFactory myConnFactory = null;

            Queue myQueue = null;

                myConnFactory = (ConnectionFactory) ctx
                        .lookup("SwiftConnectionFactory");

                con = myConnFactory.createConnection();

                s = con.createSession(false, Session.AUTO_ACKNOWLEDGE);



                myQueue = (Queue) ctx
                        .lookup("IncomingSwiftFxQueue");


                MessageProducer producer = s.createProducer(myQueue);
                Message msg = s.createTextMessage(rawTradeUpload);

                producer.send(msg); 
                    s.close();

            con.close();

        } catch (NamingException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (JMSException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
4

2 回答 2

0

您是否尝试过设置重新传递限制并定义错误队列目标，以便在 x 次尝试后，容器负责将消息移动到错误队列？这使您可以保持主队列没有有害消息，并使用专用的错误队列来浏览/调试问题。

于 2012-07-05T15:28:12.270 回答
0

在 IBM WebSphere MQ 队列管理器上配置回退队列和重新传递设置非常简单。设置 BOThreshold 和 BO 队列名称以及本地队列。毕竟，也许您可​​以说服他们进行此设置-您都可以从该解决方案中受益，以尽可能好地工作，对吗？

否则，为什么不尝试捕获所有异常，如果它们发生 - 将失败的消息重新排队到 WebLogic 上的错误队列中。似乎是一个不错的选择。

如果您需要接收，请改为使用超时调用它。

Message msg = consumer.receive(1000L);  // wait for a message for 1 sec, then continue.
于 2012-07-08T21:23:35.790 回答