[jira] Assigned: (CAMEL-2033) java.io.NotSerializableException: org.apache.camel.component.jms.JmsQueueEndpoint (polling consumer with POJO)

["Claus Ibsen (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/activemq/browse/CAMEL-2033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Claus Ibsen reassigned CAMEL-2033:
----------------------------------

    Assignee: Claus Ibsen

> java.io.NotSerializableException: org.apache.camel.component.jms.JmsQueueEndpoint (polling consumer with POJO)
> --------------------------------------------------------------------------------------------------------------
>
>                 Key: CAMEL-2033
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-2033
>             Project: Apache Camel
>          Issue Type: Bug
>            Reporter: Charles Moulliard
>            Assignee: Claus Ibsen
>
> The following error is generated when a POJO defined as a polling consumer try to consume messages from an activemq queue
> CaughtExceptionType:java.io.NotSerializableException,
> CaughtExceptionMessage:org.apache.camel.component.jms.JmsQueueEndpoint,
> StackTrace:java.io.NotSerializableException:
> org.apache.camel.component.jms.JmsQueueEndpoint
>        at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1081)
>        at java.io.ObjectOutputStream.writeArray(ObjectOutputStream.java:1251)
>        at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1075)
>        at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:302)
>        at org.apache.camel.component.bean.BeanInvocation.writeExternal(BeanInvocation.java:104)
>        at java.io.ObjectOutputStream.writeExternalData(ObjectOutputStream.java:1310)
>        at java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1288)
>        at java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1079)
>        at java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:302)
>        at org.apache.activemq.command.ActiveMQObjectMessage.storeContent(ActiveMQObjectMessage.java:98)
> Here is the code of the POJO
> {code}
> public class ReportingConsumer {
> 	
> 	@EndpointInject(name = "queueReportingEndpoint")
> 	private ConsumerTemplate consumer;
> 	
>        @EndpointInject(name = "queueReportingEndpoint")
> 	private Endpoint endpoint;
> 	
> 	public List<Map<String, Object>> collectMessages() {
>     	List<Map<String, Object>> result = new ArrayList<Map<String, Object>>();
>     	List<Map<String, Object>> received = new ArrayList<Map<String, Object>>();
>     	
> 	received = consumer.receiveBody(endpoint, List.class);
> ...
> {code}
> Everything works fine when the POJO is designed like this :
> {code}
> @Consume(ref="queueToBeRead")
> public List<> method(List<>) {
> ...
> }
> {code}
> but in this case it is not a polling consumer

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.