9 Replies Latest reply on May 29, 2009 10:06 AM by Mark Strecker

    ClassCastException looking up ConnectionFactory

    Mark Strecker Newbie

      Hello,

      I'm trying to get the P2P example working so that my webapp(running in JBoss 4.2.3) can write and consume messages. I used the example from the JBoss docs (http://www.jboss.org/file-access/default/members/jbossas/freezone/docs/Server_Configuration_Guide/4/html-single/index.html#JMS_Examples-A_Point_To_Point_Example) and when I start the webapp and execute my JNDI lookup, I get this error :

      java.lang.ClassCastException: org.jboss.mq.SpyConnectionFactory cannot be cast to javax.jms.QueueConnectionFactory


      So, I change it to a SpyConnectionFactory and get a similar error about SpyQueue. I change that and then get this :

      java.lang.LinkageError: loader constraint violation: loader (instance of org/jboss/web/tomcat/service/WebAppClassLoader) previously initiated loading for a different type with name "javax/jms/QueueConnection"
       java.lang.ClassLoader.defineClass1(Native Method)
       java.lang.ClassLoader.defineClass(Unknown Source)
       java.security.SecureClassLoader.defineClass(Unknown Source)
       org.apache.catalina.loader.WebappClassLoader.findClassInternal(WebappClassLoader.java:1814)
       org.apache.catalina.loader.WebappClassLoader.findClass(WebappClassLoader.java:872)
       org.jboss.web.tomcat.service.WebAppClassLoader.findClass(WebAppClassLoader.java:75)
       org.apache.catalina.loader.WebappClassLoader.loadClass(WebappClassLoader.java:1325)
       org.apache.catalina.loader.WebappClassLoader.loadClass(WebappClassLoader.java:1204)
       java.lang.ClassLoader.loadClassInternal(Unknown Source)
      


      Here's the original version of my code.

      package test.jms;
      
      import javax.jms.JMSException;
      import javax.jms.Queue;
      import javax.jms.QueueConnection;
      import javax.jms.QueueConnectionFactory;
      import javax.jms.QueueReceiver;
      import javax.jms.QueueSender;
      import javax.jms.QueueSession;
      import javax.jms.TextMessage;
      import javax.naming.InitialContext;
      import javax.naming.NamingException;
      
      public class QueueSetup
      {
       public void sendRecvAsync(String text) throws JMSException, NamingException
       {
       InitialContext iniCtx = new InitialContext();
       Object tmp = iniCtx.lookup("ConnectionFactory");
       QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
       QueueConnection conn = qcf.createQueueConnection();
       Queue que = (Queue) iniCtx.lookup("queue/A");
       QueueSession session = conn.createQueueSession(false,
       QueueSession.AUTO_ACKNOWLEDGE);
       conn.start();
      
       // Set the async listener
       QueueReceiver recv = session.createReceiver(que);
       recv.setMessageListener(new MyMessageListener());
      
       // Send a text msg
       QueueSender send = session.createSender(que);
       TextMessage tm = session.createTextMessage("This is a test");
       send.send(tm);
       send.close();
       }
      }
      


      Any ideas about what's wrong?(I did try java:JmsXA with similar results) Is there some setup that I missed?
      TIA