[JBoss-user] Registry of Queue in JBoss/JMS

[Valentin Encinas]

Hello again! 

 

Now I have the following error in JMS:

 

Queue name is MyQueue

JNDI lookup failed: javax.naming.NameNotFoundException: MyQueue not bound

The code of the program is simple and is the following one:

 

import java.util.Properties;
import javax.jms.*;
import javax.naming.*;

 

public class SimpleQueueSender {

    public static void main(String[] args) {
        String                  queueName = null;
        Context                 jndiContext = null;
        QueueConnectionFactory  queueConnectionFactory = null;
        QueueConnection         queueConnection = null;
        QueueSession            queueSession = null;
        Queue                   queue = null;
        QueueSender             queueSender = null;
        TextMessage             message = null;
        final int               NUM_MSGS;
        final String    MSG_TEXT = new String("Here is a message");

 

        System.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
        System.setProperty("java.naming.provider.url", "localhost:1099");

 

        queueName = new String("A");
        System.out.println("Queue name is " + queueName);
        NUM_MSGS = 1;

 

        try {
           jndiContext = new InitialContext();
        } catch (NamingException e) {
            System.out.println("Could not create JNDI " +
                "context: " + e.toString());
            System.exit(1);
        }

 

        try {
            queueConnectionFactory = (QueueConnectionFactory)
                jndiContext.lookup("QueueConnectionFactory");
         queue = (Queue) jndiContext.lookup(queueName); // Here it is where it gives the error because it it does not find

        } catch (NamingException e) {
            System.out.println("JNDI lookup failed: " +
                e.toString());
            System.exit(1);
        }

 

        try {
            queueConnection =
                queueConnectionFactory.createQueueConnection();
            queueSession =
                queueConnection.createQueueSession(false,
                    Session.AUTO_ACKNOWLEDGE);
            queueSender = queueSession.createSender(queue);
            message = queueSession.createTextMessage();
            for (int i = 0; i < NUM_MSGS; i++) {
                message.setText(MSG_TEXT + " " + (i + 1));
                System.out.println("Sending message: " +
                    message.getText());
                queueSender.send(message);
            }

 

            queueSender.send(queueSession.createMessage());
        } catch (JMSException e) {
            System.out.println("Exception occurred: " +
                e.toString());
        } finally {
            if (queueConnection != null) {
                try {
                    queueConnection.close();
                } catch (JMSException e) {}
            }
        }
    }
}

I believe that the problem is in which not this registered MyQueue. Where it must make this in JBoss and like?

Thank you very much!