JMS队列客户端onMessage（）没有收到来自发件人的消息

我是JMS的新手，并且使用Jdeveloper和Weblogic 12c，我的代码运行良好，但消费者onMessage()方法没有收到来自Producer的任何消息。虽然我没有使用onMessage()时可以收到消息。在工作之前，我必须配置任何文件吗？JMS队列客户端onMessage（）没有收到来自发件人的消息

这里是消息消费者代码

package com.soap_jms; 



import javax.jms.ExceptionListener; 
import java.util.*; 
import javax.jms.Connection; 
import javax.jms.ConnectionFactory; 
import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.MessageConsumer; 
import javax.jms.MessageListener; 
import javax.jms.Queue; 
import javax.jms.Session; 
import javax.jms.TextMessage; 

import javax.naming.InitialContext; 
import javax.naming.NamingException; 
import javax.naming.Context; 

import utils.system; 


public class QueueConsume implements MessageListener, ExceptionListener{ 

     private final static String JMS_FACTORY="jms/ThesisConnectionFactory"; 
     private final static String QUEUE="jms/ThesisJMSQueue"; 
     private static Connection mConnection; 
     private static ConnectionFactory mConnectionFactory; 
     private static Queue mQueue; 
     private static MessageConsumer mConsumer; 
     private static Session mSession; 


     public static void main (String [] args) throws JMSException, NamingException { 
     mConnection=null; 
     MessageListener listener = null; 
     System.out.println("Entering into JMS Queue Consumer........"); 
     Context ctx = QueueConsume.getInitialContext(); 
     mConnectionFactory=(javax.jms.ConnectionFactory)ctx.lookup(JMS_FACTORY); 
     mQueue=(javax.jms.Queue)ctx.lookup(QUEUE); 
     mConnection=mConnectionFactory.createConnection(); 
     mSession=mConnection.createSession(false,Session.AUTO_ACKNOWLEDGE); 
     mConsumer=mSession.createConsumer(mQueue); 
     QueueConsume mConsume = new QueueConsume(); 
     mConsumer.setMessageListener(mConsume); 
     mConnection.setExceptionListener(mConsume); 
     mConnection.start(); 

     System.out.println("JMS is set to accept sent message....."); 
     System.out.println("Exiting from JMS Queue Consumer ........"); 
     close(); 
     } // closes main method 


    @SuppressWarnings("oracle.jdeveloper.java.insufficient-catch-block") 
    public void onMessage(Message message) { 
     try { 
      System.out.println("Message is " + ((TextMessage) message).getText()); 
     } catch (JMSException e) { 
     } 
    } 
     @SuppressWarnings("oracle.jdeveloper.java.unchecked-conversion-or-cast") 
    public static Context getInitialContext() throws JMSException, NamingException { 
      Hashtable htb = new Hashtable(); 
      htb.put(Context.INITIAL_CONTEXT_FACTORY,"weblogic.jndi.WLInitialContextFactory"); 
      htb.put(Context.PROVIDER_URL,"t3://localhost:7101"); 
      Context ctx= new InitialContext(htb); 
     return ctx; 
     }  


    public static void close() throws JMSException { 
     mSession.close(); 
     mConnection.close(); 
     mConsumer.close(); 
    } 



    public void onException(JMSException exception) 
     { 
      System.err.println("an error occurred: " + exception); 
     } 

}

来源

2016-05-03 TheGood

您是否已将onMessage消息侦听器附加到使用者？ – Shashi

是的Shashi。我附上了它。看到上面的代码。谢谢。 – TheGood

我怀疑问题是因为被称为onMessage方法之前，主线程结束。在调用Connection.start()方法后，您正在致电close。通常情况下，setMessageListener是一个异步操作，所以该调用立即返回，但实际的onMessage线程并行发生。建议你放一些睡眠或其他方式让主线程等待，而onMessage线程接收消息。

来源

2016-05-06 13:29:35 Shashi

谢谢莎西。它以这种方式工作。 – TheGood

你介意接受我的回答吗？我贪婪:) – Shashi

JMS队列客户端onMessage（）没有收到来自发件人的消息

回答

相关问题