JNDI Lookup problem, WebSphere + Queue Connetion Factory

[Cristiano Fontes]

Hello i am trying to make a RollBack in a Message from an MQ server.

I managed to make the MQ sending msg to work with WebSphere and ListenerPort Setup...

but i can't get the JNDI lookup(line103) of the connection factory to find anything... so i can't get the msg back.

i created a AUD_IN destination and an AUD_QCF in Connections Factory, so I don't know what else to do to make this Lookup work.

any help would be great !

Thanks to all

P.S: Every thing is running at LocalHost, the MQ and WebSphere, but it's only the test enviroment so It should work in the remote server too.

ERROR MESSAGE
 
[10/27/08 14:09:33:688 BRST] 00000043 MessageBean   I   MESSAGE BEAN: Message received: A
[10/27/08 14:09:36:547 BRST] 00000043 SystemOut     O Getting connection factory....
[10/27/08 14:09:36:547 BRST] 00000043 SystemOut     O Naming Exception namingName comp/env/jndi not found in context "java:".
 

// @annotations-disabled tagSet="websphere" tagSet="ejb"
package ejbs;
 
import java.util.logging.Logger;
 
import javax.ejb.MessageDrivenContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueReceiver;
import javax.jms.QueueRequestor;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TemporaryQueue;
import javax.jms.TextMessage;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
 
 
/**
 * Bean implementation class for Message-Driven Bean: AudMqTest
 *
 * @ejb.bean
 *name="AudMqTest"
 *transaction-type="Container"
 *  destination-type="javax.jms.Queue"
 */
public class AudMqTestBean implements javax.ejb.MessageDrivenBean, javax.jms.MessageListener {

/**
 * 
 */
private static final long serialVersionUID = 1L;

private MessageDrivenContext myMessageDrivenCtx = null;
    static final Logger logger = Logger.getLogger("MessageBean");
 
    private java.util.Properties parms = new java.util.Properties();
 
    
    private QueueConnection  queueConnection;
    private Queue queue;
    private QueueSession session;
    private QueueConnectionFactory factory;
    private QueueSender queueSender;
    private InitialContext ctx;
 
 
    
/**
 * getMessageDrivenContext
 */
public MessageDrivenContext getMessageDrivenContext() {
return myMessageDrivenCtx;
}
/**
 * setMessageDrivenContext
 */
public void setMessageDrivenContext(MessageDrivenContext ctx) {
myMessageDrivenCtx = ctx;
}
/**
 * ejbCreate
 */
public void ejbCreate() {
}
/**
 * ejbRemove
 */
public void ejbRemove() {
}

/**
 * onMessage
 */
public void onMessage(Message inMessage) {

        TextMessage msg = null;
 
        try {
            if (inMessage instanceof TextMessage) {
            
            String message = ((TextMessage) inMessage).getText();
            
            if(message.equals("A")){
            msg = (TextMessage) inMessage;
            logger.info("MESSAGE BEAN: Message received: " + msg.getText());
            }
            else if(message.equals("B"))
            {
              try{
                parms.setProperty(Context.INITIAL_CONTEXT_FACTORY,"com.ibm.websphere.naming.WsnInitialContextFactory");
                
            ctx = new InitialContext(parms);
                        
                        System.out.println("Getting connection factory....");
                        
                        
            factory = (QueueConnectionFactory) ctx.lookup("java:comp/env/jndi/AUD_QCF");
            System.out.println( "AUD_QCF = "+ctx );
            
                        
                    queue = (Queue) ctx.lookup("java:comp/env/jms/AUD_IN"); 
            
                    
            queueConnection  = factory.createQueueConnection();
            session = queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); 
            
            logger.info("AUD_QCF Got !");
            
            queueSender = session.createSender(queue);
            TextMessage messageRoll = session.createTextMessage(message); 
            queueSender.send(messageRoll);
            
                }catch(NamingException namingException){
            System.out.println("Naming Exception naming"+namingException.getMessage());
                }catch(JMSException jmsException){
            System.out.println ("JMSException"+jmsException.getMessage());
                }catch(Exception exception){
            exception.printStackTrace();                  
                }finally{
                try{
                if (session != null) {
                session.close();
                session = null;
                }
                if (queueConnection != null) {
                queueConnection.close();
                queueConnection = null;
                }
                }catch(Exception e){
                e.printStackTrace();
                }
                }

            }
            } else {
                logger.warning("Message of wrong type: " +
                    inMessage.getClass().getName());
            }
            
            
        } catch (JMSException e) {
            logger.severe("MessageBean.onMessage: JMSException: " +
                e.toString());
            e.printStackTrace();
            myMessageDrivenCtx.setRollbackOnly();
        } catch (Throwable te) {
            logger.severe("MessageBean.onMessage: Exception: " + te.toString());
            te.printStackTrace();
        }


}

}

[ October 27, 2008: Message edited by: Cristiano Fontes ]