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.
