[Resolvido] Problema com JBoss e JMS

This message was edited 1 time. Last update was at 21/09/2009 07:12:58

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....

O que poderia ser?

Abraços

André

Na verdade o problema estava no meu xml... que estava referenciando para um tipo mbean Queue, quando na verdade o que eu queria era topic... por isso do ClassCastException...

Notícias, artigos e o maior fórum brasileiro sobre Java