javajndiactivemq-classic

Using ActiveMQ via JNDI

I'm trying to create simply connect with ActiveMQ using JNDI.

I have:

  1. Queue named example.A.
  2. According ActiveMQ documentation touching JNDI, if I want to use ConectionFactories and Queues (Topics) via JNDI, I have to place jndi.properties file on my classpath. As I have understood, ActiveMQ classpath is %activemq%/conf directory by default. I have not changed it. So I have this property for my queue: 
    queue.MyQueue = example.A
  3. I have created java client class for ActiveMQ which uses JNDI as below: 
    Properties jndiParameters = new Properties() ;
jndiParameters.put(Context.INITIAL_CONTEXT_FACTORY, "org.apache.activemq.jndi.ActiveMQInitialContextFactory");
jndiParameters.put(Context.PROVIDER_URL, "tcp://localhost:61616");
Context context = new InitialContext(jndiParameters);
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");
Queue queue = (Queue) context.lookup("MyQueue");

But it cannot find my queue. It throws exception:

javax.naming.NameNotFoundException: MyQueue

Where are my mistakes?

Solution

  • The problem is that you are explicitly creating the properties and passing them into the InitialContext constructor. This means the jndi.properties on the class path won't be read.

    Your code should be something like:

    Context context = new InitialContext();
ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");
Queue queue = (Queue) context.lookup("MyQueue");