Hi;

Does anyone have an idea why I am getting this error? I get the
NullPointerException when I try to start the queue connection inside of
the startJMS method for the Delegator class.  The exception and 
the startJMS method are also attached.  

Thanks for your help,
Cathy Dull

C:\Orion\orion\applications\Cathy-protos\lib\java>java
com.hitachi.hitel.genesis.em.asynchronous.Del
egator
Inside Delegator.startJMS
Just got new Initial Context
Did JNDI Look-up on the queue factory location
Cast it to a  queue connection factory
The queue name is: com.evermind.server.jms.EvermindQueue@2a5330
Created the queue connection
Started the connection
Created the session
Created the receiver
Exception in thread "main" java.lang.NullPointerException
        at java.io.DataOutputStream.writeUTF(DataOutputStream.java:329)
        at java.io.DataOutputStream.writeUTF(DataOutputStream.java:306)
        at com.evermind.server.jms.bx.<init>(JAX)
        at com.evermind.server.jms.EvermindQueueConnection.start(JAX)
        at
com.hitachi.hitel.genesis.em.asynchronous.Delegator.startJMS(Delegator.java:80)
        at
com.hitachi.hitel.genesis.em.asynchronous.Delegator.<init>(Delegator.java:31)
        at
com.hitachi.hitel.genesis.em.asynchronous.Delegator.main(Delegator.java:56)


private void startJMS() throws NamingException, JMSException {
        System.out.println("Inside Delegator.startJMS");
        ctx = new InitialContext();
        System.out.println("Just got new Initial Context");
        Object obj = ctx.lookup(QUEUE_FACTORY_LOCATION);
        System.out.println("Did JNDI Look-up on the queue factory
location");
        QueueConnectionFactory factory = (QueueConnectionFactory)
        PortableRemoteObject.narrow(obj, QueueConnectionFactory.class);
        System.out.println("Cast it to a  queue connection factory");
        Object obj2 = ctx.lookup(QUEUE_LOCATION);
        queue = (Queue)PortableRemoteObject.narrow(obj2, Queue.class);
        System.out.println("The queue name is: " + queue.toString());
        conn = factory.createQueueConnection();
        System.out.println("Created the queue connection ");
        //conn.setExceptionListener(this);
        //System.out.println("setExceptionListener to this ");
        System.out.println("Started the connection");
        session = conn.createQueueSession(false,
QueueSession.AUTO_ACKNOWLEDGE);
        System.out.println("Created the session");
        receiver = session.createReceiver(queue);
        System.out.println("Created the receiver");
        conn.start();
        System.out.println("Started the connection");
    }

Reply via email to