Bom dia Pessoal,
Tenho um projeto usando jms, estou usando jboss 4.2, porem na hora de registrar um listener para um topico que ja havia criado, eu tenho um CassCastException... e tenho mais que certeza que o topico esta disponivel, joguei o xml dele no deploy do servidor e ele fez o bind, irei mostrar a minha classe...
package fr.globalit.loja.jms;
import javax.jms.JMSException;
import javax.jms.Session;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicConnectionFactory;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;
import javax.naming.InitialContext;
import javax.naming.NamingException;
public class RegistraTratadorNoTopico {
public static void main(String[] args) throws NamingException, JMSException{
InitialContext ic = new InitialContext();
TopicConnectionFactory topicConnectionFactory = (TopicConnectionFactory) ic
.lookup("ConnectionFactory");
TopicConnection topicConnection = topicConnectionFactory
.createTopicConnection();
TopicSession topicSession = topicConnection.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
Topic topic = (Topic) ic.lookup("topico-teste");
TopicSubscriber topicSubscriber = topicSession.createSubscriber(topic);
topicSubscriber.setMessageListener(new TratadorDeMensagem());
topicConnection.start();
}
}
o jboss me diz que o topico-teste esta disponivel, tanto no jmx view, quanto quando ele inicializa, porem quando executo esta classe, que nao faz nada alem de registrar um listener para mensagens, eu recebo este erro aqui…
Exception in thread "main" java.lang.ClassCastException: org.jboss.mq.SpyQueue cannot be cast to javax.jms.Topic
at fr.globalit.loja.jms.RegistraTratadorNoTopico.main(RegistraTratadorNoTopico.java:27)
O que poderia ser?
Abraços
André