Esper JMS adapters onMessage exception

Hello,

       I created Spring JMS input/ouput adapters for esper with ActiveMQ as the JMS provider.  When I try to send a message using the ActiveMQ web console I get the following exception. Can anyone help me with this?

 

INFO: Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@7a1576: defining beans [jmsActiveMQFactory,defaultDestination,jmsActiveMQTemplate,listenerContainer,jmsMessageUnmarshaller,jmsInputAdapter]; root of factory hierarchy

Sep 29, 2009 10:32:08 AM com.espertech.esperio.jms.JMSDefaultAnyMessageUnmarshaller unmarshal

SEVERE: .unmarshal Failed to unmarshal message of JMS type:

Sep 29, 2009 10:32:08 AM com.espertech.esperio.jms.SpringJMSTemplateInputAdapter onMessage

SEVERE: .onMessage exception

com.espertech.esper.client.EPException: .unmarshal Failed to unmarshal message of JMS type:

      at com.espertech.esperio.jms.JMSDefaultAnyMessageUnmarshaller.unmarshal(JMSDefaultAnyMessageUnmarshaller.java:81)

      at com.espertech.esperio.jms.JMSDefaultAnyMessageUnmarshaller.unmarshal(JMSDefaultAnyMessageUnmarshaller.java:31)

      at com.espertech.esperio.jms.SpringJMSTemplateInputAdapter.onMessage(SpringJMSTemplateInputAdapter.java:65)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:531)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:466)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:435)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:407)

      at org.springframework.jms.listener.SimpleMessageListenerContainer.processMessage(SimpleMessageListenerContainer.java:290)

      at org.springframework.jms.listener.SimpleMessageListenerContainer$2.onMessage(SimpleMessageListenerContainer.java:266)

      at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1021)

      at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:122)

      at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:192)

      at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)

      at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)

      at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)

      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)

      at java.lang.Thread.run(Thread.java:619)

 

 

 

Thanks,

Sandeep

Hi,

I tried to send the messages using main, I got the exception shown below. The Object and Map JMS message types are set in the JMSDefaultAnyMessageUnmarshaller class, and since I’m specifying this ‘jmsMessageMarshaller’  in the Spring JMS input adapter configuration, will it not unmarshall the messages? Am I required to create JMS messages of type Object or Map and then send them to the queue?

 

The exception shows the JMS message types to be null.

 

Oct 2, 2009 10:29:08 AM esperfiles.JMSDefaultAnyMessageUnmarshaller unmarshal

SEVERE: .unmarshal Failed to unmarshal message of JMS type: null

Oct 2, 2009 10:29:08 AM esperfiles.SpringJMSTemplateInputAdapter onMessage

SEVERE: .onMessage exception

com.espertech.esper.client.EPException: .unmarshal Failed to unmarshal message of JMS type: null

      at esperfiles.JMSDefaultAnyMessageUnmarshaller.unmarshal(JMSDefaultAnyMessageUnmarshaller.java:77)

      at esperfiles.JMSDefaultAnyMessageUnmarshaller.unmarshal(JMSDefaultAnyMessageUnmarshaller.java:1)

      at esperfiles.SpringJMSTemplateInputAdapter.onMessage(SpringJMSTemplateInputAdapter.java:57)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:531)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:466)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:435)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:407)

      at org.springframework.jms.listener.SimpleMessageListenerContainer.processMessage(SimpleMessageListenerContainer.java:290)

      at org.springframework.jms.listener.SimpleMessageListenerContainer$2.onMessage(SimpleMessageListenerContainer.java:266)

      at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1021)

      at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:122)

      at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:192)

      at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)

      at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)

      at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)

      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)

      at java.lang.Thread.run(Thread.java:619)

 

 

 

Thanks,

Sandeep

From: Alexandre Vasseur [mailto:avasseur@...]
Sent: Tuesday, September 29, 2009 4:15 PM
To: user@...
Subject: Re: [esper-user] Esper JMS adapters onMessage exception

 

this unmarshaller can deal with ObjectMessage or MapMessage JMS messages. The exception shows that the JMS message type is not even set - otherwise it should be printed out. I 'd suspect that the ActiveMQ web console is not doing any good there.
Can you try sending a message from a main class for example?
Alex

On Tue, Sep 29, 2009 at 5:40 PM, Sandeep Poreddy <sandeep.poreddy@...> wrote:

Hello,

       I created Spring JMS input/ouput adapters for esper with ActiveMQ as the JMS provider.  When I try to send a message using the ActiveMQ web console I get the following exception. Can anyone help me with this?

 

INFO: Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@7a1576: defining beans [jmsActiveMQFactory,defaultDestination,jmsActiveMQTemplate,listenerContainer,jmsMessageUnmarshaller,jmsInputAdapter]; root of factory hierarchy

Sep 29, 2009 10:32:08 AM com.espertech.esperio.jms.JMSDefaultAnyMessageUnmarshaller unmarshal

SEVERE: .unmarshal Failed to unmarshal message of JMS type:

Sep 29, 2009 10:32:08 AM com.espertech.esperio.jms.SpringJMSTemplateInputAdapter onMessage

SEVERE: .onMessage exception

com.espertech.esper.client.EPException: .unmarshal Failed to unmarshal message of JMS type:

      at com.espertech.esperio.jms.JMSDefaultAnyMessageUnmarshaller.unmarshal(JMSDefaultAnyMessageUnmarshaller.java:81)

      at com.espertech.esperio.jms.JMSDefaultAnyMessageUnmarshaller.unmarshal(JMSDefaultAnyMessageUnmarshaller.java:31)

      at com.espertech.esperio.jms.SpringJMSTemplateInputAdapter.onMessage(SpringJMSTemplateInputAdapter.java:65)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:531)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:466)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:435)

      at org.springframework.jms.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:407)

      at org.springframework.jms.listener.SimpleMessageListenerContainer.processMessage(SimpleMessageListenerContainer.java:290)

      at org.springframework.jms.listener.SimpleMessageListenerContainer$2.onMessage(SimpleMessageListenerContainer.java:266)

      at org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1021)

      at org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:122)

      at org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:192)

      at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)

      at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)

      at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)

      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)

      at java.lang.Thread.run(Thread.java:619)

 

 

 

Thanks,

Sandeep