Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: local policy includes SPF record at
 spf.trusted-forwarder.org)
Date: Thu, 26 Sep 2013 13:08:22 -0700 (PDT)
From: zbc <zhebincong@163.com>
To: users@activemq.apache.org
Message-ID: <1380226102517-4671868.post@n4.nabble.com>
Subject: standard jms code can not receive message from queue
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

please look at following code:

	    InitialContext ctx = null;
	    QueueConnection con = null;
	    QueueSession queueSession = null;
	    QueueReceiver receiver = null;
	    try {
	      Hashtable env = new Hashtable();
	      env = new Hashtable();
	      env.put(Context.INITIAL_CONTEXT_FACTORY,
"org.apache.activemq.jndi.ActiveMQInitialContextFactory");
	      env.put(Context.PROVIDER_URL, "tcp://localhost:61616");
	      ctx = new InitialContext(env);
	      QueueConnectionFactory fac =
(QueueConnectionFactory)ctx.lookup("ConnectionFactory");
	      con = fac.createQueueConnection();
	      queueSession = con.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
	      con.start();
	      receiver =
queueSession.createReceiver((Queue)ctx.lookup("dynamicQueues/FromReqRespClient"));
	      Message result = receiver.receiveNoWait(); 
	      System.out.println(result);
	    } catch (Exception e) {
	    	e.printStackTrace();
	    } finally {
                close();
	    }


this is standard jms code, but it can NOT receive message from queue, if you
add a line "Thread.sleep(500)" before "Message result =
receiver.receiveNoWait(); ", it WORKS. this code work well to openJMS, is it
a bug? you can try yourself, thanks.


--
View this message in context: http://activemq.2283324.n4.nabble.com/standard-jms-code-can-not-receive-message-from-queue-tp4671868.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.