activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Adrian Co <...@exist.com>
Subject Re: TransactionRolledbackLocalException in method
Date Fri, 19 Jan 2007 18:27:29 GMT
Please add the complete stack trace.

miniman wrote:
> All when i send a message from my MDB i get this error come up.
>
> = true, text = null}
> 16:50:24,949 INFO  [PublishMsgToTopic] Autobahn Monitor.onMessage
> 16:50:27,965 INFO  [PublishMsgToTopic] Autobahn Monitor.ejbRemove
> 16:50:27,981 ERROR [LogInterceptor] TransactionRolledbackLocalException in
> method: public abstract v
> oid javax.jms.MessageListener.onMessage(javax.jms.Message), causedBy:
> java.lang.ClassCastException: java.lang.String
>
> my main code is
>
> 	public void onMessage(Message message)  {
> 		if (logger.isInfoEnabled()) {
> 			logger.info("Autobahn Monitor.onMessage");
> 		}
> 		
>
> 			handleMessage(message);
>
> 		
> 	}
> 	private void handleMessage(Message message) {
> 		try {
> 			if (message instanceof ObjectMessage) {
> 				//TextMessage textMessage = (TextMessage) message;
> 				ObjectMessage objMsg = (ObjectMessage)message;
> 				eventMsg = (MonitorMSG)objMsg.getObject();
> 				if (logger.isInfoEnabled()) {
> 					logger.info("Message received: " + eventMsg.getHostname());
> 				}
> 				send(objMsg);
> 			} else {
> 				if (logger.isInfoEnabled()) {
> 					logger.info("Unknown message type received: " + message.toString());
> 				}
> 				//send("Unknown message type: " + message.toString());
> 			}
> 		} catch (JMSException e) {
> 			// TODO Auto-generated catch block
> 			e.printStackTrace();
> 		}
> 	}
> 	
> 	private void send(ObjectMessage obj) {
> 		sendToEJB(obj);
> 	}
> 	
> 	private void sendToEJB(ObjectMessage obj)  {
> 		PublishToTopic publishtoTopic = new PublishToTopic();
> 		publishtoTopic.sendMessage(obj);
> 	} 
>
>
> Then in the PublishtoTopic class
>
>
> 	public void sendMessage(ObjectMessage obj){
> 		try {
> 			ObjectMessage objMsg = (ObjectMessage)obj;
> 			//eventMSG = (MonitorMSG)objMsg.getObject();
> 			ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory(url);
> 			connection = factory.createConnection();    	
> 			session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
> 			topic = session.createTopic("TOOL.TOPICTEST");
> 			//control = session.createTopic("topictest.control");
> 			
> 			publisher = session.createProducer(topic);
> 			publisher.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
> 			
> 			//session.createConsumer(control).setMessageListener(this);
> 			connection.start();
>
> 			//request shutdown
> 			publisher.send(objMsg);
>
> 			connection.stop();
> 			connection.close();
> 		} catch (JMSException e) {
> 			// TODO Auto-generated catch block
> 			e.printStackTrace();
> 		}    
> 	}
>
> Am i missing something......
>
>
>
>
>   


Mime
View raw message