activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Dejan Bosanac <de...@nighttale.net>
Subject Re: ActiveMQ queue - JNDI lookup
Date Mon, 31 Aug 2009 08:47:02 GMT
Hi,

can you use jconsole to see what queues do you have and does the queue
contains the message?

Cheers
--
Dejan Bosanac

Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net


On Sat, Aug 29, 2009 at 7:28 PM, moonbird <moonbird@ymail.com> wrote:

>
> Hi,
> could it be, that i can not lookup destinations which are in the global
> jndi
> namespace of jboss ?
> i used activemq embedded in jboss5 via JCA with a ressource adapter.
> ...stationInfoQueue = (Queue) ctx.lookup("stationInfoQueue"); doesnt get
> null - but it also doenst work (the consument on the other side doenst get
> anything from the queue)
>
> this is a jndi list from the jboss administration web console:
> +- stationInfoQueue (class: org.apache.activemq.command.ActiveMQQueue)
>
> some posting threads ago, i had a posting about looking up the
> ConnectionFactory which also doesnt work. So i used the
> queueConnectionFactory = new
> ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL); and i
> thought now i can lookup the destinations via jndi...
>
> Thx so far !
>
>  this is my java client code:
> // Look up connection factory and queue(destination)
>                try
>                {
>                        // this seems to be not work - because ActiveMQ is
> embedded in JBoss5 by
> JCA/RA
>                        //queueConnectionFactory = (QueueConnectionFactory)
> ctx.lookup("activemq/QueueConnectionFactory");
>                        queueConnectionFactory = new
> ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
>
>                        stationInfoQueue = (Queue)
> ctx.lookup("stationInfoQueue");
>
>                        if (queueConnectionFactory == null)
>                        {
>                                System.err.println("NULL for
> queueConnectionFactory");
>                                System.exit(1);
>                        }
>
>                        if (stationInfoQueue == null)
>                        {
>                                System.err.println("NULL for
> stationInfoQueue");
>                                System.exit(1);
>                        }
>                }
>                catch (NamingException e)
>                {
>                        System.err.println("JNDI API lookup failed:" + e);
>                        System.exit(1);
>                }
>
>        // Create connection. Create session from connection; false means
>        // session is not transacted. Create requestor and text message.
> Send
>        // messages, wait for answer and finally close session and
> connection.
>                try
>                {
>                        queueConnection =
> queueConnectionFactory.createQueueConnection();
>                        queueSession =
> queueConnection.createQueueSession(false,
> Session.AUTO_ACKNOWLEDGE);
>                        // obviously this is needed ??? why doesnt it work
> to lookup the activemq
> queue via jndi ?
>                        stationInfoQueue =
> queueSession.createQueue("stationInfoQueue");
>                        textMessage =
> queueSession.createTextMessage(myXMLRequestAsString);
>                        // javax.jms.QueueRequestor creates a TemporaryQueue
> for the responses
> and provides a request method that sends the request message
>                        // and waits for its reply.This is a basic
> request/reply abstraction that
> should be sufficient for most uses.
>                        // JMS providers and clients are free to create more
> sophisticated
> versions.
>                        queueRequestor = new QueueRequestor(queueSession,
> stationInfoQueue);
>                        //sends the message and waits until respond is
> received
>                        TextMessage answer = (TextMessage)
> queueRequestor.request(textMessage);
>                        System.out.println("CLIENT: Response message
> received: ");
>                        System.out.println(answer.getText());
>                }
>                catch (JMSException e)
>                {
>                        System.out.println("JMSExceptionn occurred:" + e);
>                }
>                finally
>                {
>                        if (queueConnection != null)
>                        {
>                                // close connections
>                                try
>                                {
>                                        queueSession.close();
>                                        queueConnection.close();
>                                }
>                                catch (JMSException e)
>                                {
>                                        e.printStackTrace();
>                                }
>                        }
>                }
> --
> View this message in context:
> http://www.nabble.com/ActiveMQ-queue---JNDI-lookup-tp25204754p25204754.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message