Mailing-List: contact camel-dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: camel-dev@activemq.apache.org
Message-ID: <597346983.1218301492588.JavaMail.jira@brutus>
Date: Sat, 9 Aug 2008 10:04:52 -0700 (PDT)
From: "Claus Ibsen (JIRA)" <jira@apache.org>
To: camel-dev@activemq.apache.org
Subject: [jira] Commented: (CAMEL-798) NullPointerException is generated
 when Flatpack component is used with Tracer
In-Reply-To: <1807862312.1218197332597.JavaMail.jira@brutus>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable


    [ https://issues.apache.org/activemq/browse/CAMEL-798?page=3Dcom.atlass=
ian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D4=
4887#action_44887 ]=20

Claus Ibsen commented on CAMEL-798:
-----------------------------------

Charles about the bug?

You need to convert the content to something that can be serailized/handled=
 by the JMS provider.
But as said before we should give the flatpack component an overhaul.

But can you test with this (there is a type converter from DataSet to Map)

from(flatpack:fixed:com/bravura/babel/transformation/cutas/in/CUTAS.xml)
.convertBodyTo(Map.class)
.to(activemq:queue:cutas.clientA.accepted.in);

I will close this as not a bug. And then we must make sure the flatpack stu=
ff can be sent to JMS out-of-the-box with eg a good type converter or a cam=
el type that is seiralizable.

> NullPointerException is generated when Flatpack component is used with Tr=
acer
> -------------------------------------------------------------------------=
----
>
>                 Key: CAMEL-798
>                 URL: https://issues.apache.org/activemq/browse/CAMEL-798
>             Project: Apache Camel
>          Issue Type: Bug
>          Components: camel-flatpack
>    Affects Versions: 1.4.0
>            Reporter: Charles Moulliard
>             Fix For: 1.5.0
>
>
> Hi,=20
> The following error is returned when Tracer is activated for the Flatpack=
 component :
> 4317672 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-1 -> interceptor2 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[flatpack:fixed:com/bravura/babel/tra=
nsformation/cutas/in/CUTAS.xml]]), sendTo(Endpoint[seda:errors]), Redeliver=
yPolicy[maximumRedeliveries=3D1]])] InOnly Properties:{org.apache.camel.fil=
e.lock.name=3Dc:\temp\cutas\input\clientA\ST000355.txt.cameLock, org.apache=
.camel.file.lock=3Dsun.nio.ch.FileLockImpl[0:9223372036854775807 exclusive =
valid], org.apache.camel.fileChannel=3Dsun.nio.ch.FileChannelImpl@4610fa} H=
eaders:{org.apache.camel.file.name=3DST000355.txt} BodyType:java.io.File
> 4317672 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-1 -> to4 To[flatpack:fixed:com/bravura/babel/tr=
ansformation/cutas/in/CUTAS.xml] InOnly Properties:{CamelCauseException=3Dn=
ull, org.apache.camel.file.lock.name=3Dc:\temp\cutas\input\clientA\ST000355=
.txt.cameLock, org.apache.camel.file.lock=3Dsun.nio.ch.FileLockImpl[0:92233=
72036854775807 exclusive valid], org.apache.camel.fileChannel=3Dsun.nio.ch.=
FileChannelImpl@4610fa} Headers:{org.apache.camel.file.name=3DST000355.txt}=
 BodyType:java.io.File
> 4318031 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-2 -> interceptor3 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[activemq:queue:cutas.clientA.accepte=
d.in]]), sendTo(Endpoint[seda:errors]), RedeliveryPolicy[maximumRedeliverie=
s=3D1]])] InOnly Properties:{} Headers:{camelFlatpackCounter=3D0} BodyType:=
net.sf.flatpack.DefaultDataSet
> 4318031 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-2 -> to5 To[activemq:queue:cutas.clientA.accept=
ed.in] InOnly Properties:{CamelCauseException=3Dnull} Headers:{camelFlatpac=
kCounter=3D0} BodyType:net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-3 -> interceptor3 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[activemq:queue:cutas.clientA.accepte=
d.in]]), sendTo(Endpoint[seda:errors]), RedeliveryPolicy[maximumRedeliverie=
s=3D1]])] InOnly Properties:{} Headers:{camelFlatpackCounter=3D1} BodyType:=
net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-3 -> to5 To[activemq:queue:cutas.clientA.accept=
ed.in] InOnly Properties:{CamelCauseException=3Dnull} Headers:{camelFlatpac=
kCounter=3D1} BodyType:net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-4 -> interceptor3 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[activemq:queue:cutas.clientA.accepte=
d.in]]), sendTo(Endpoint[seda:errors]), RedeliveryPolicy[maximumRedeliverie=
s=3D1]])] InOnly Properties:{} Headers:{camelFlatpackCounter=3D2} BodyType:=
net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-4 -> to5 To[activemq:queue:cutas.clientA.accept=
ed.in] InOnly Properties:{CamelCauseException=3Dnull} Headers:{camelFlatpac=
kCounter=3D2} BodyType:net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-5 -> interceptor3 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[activemq:queue:cutas.clientA.accepte=
d.in]]), sendTo(Endpoint[seda:errors]), RedeliveryPolicy[maximumRedeliverie=
s=3D1]])] InOnly Properties:{} Headers:{camelFlatpackCounter=3D3} BodyType:=
net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-5 -> to5 To[activemq:queue:cutas.clientA.accept=
ed.in] InOnly Properties:{CamelCauseException=3Dnull} Headers:{camelFlatpac=
kCounter=3D3} BodyType:net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-6 -> interceptor3 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[activemq:queue:cutas.clientA.accepte=
d.in]]), sendTo(Endpoint[seda:errors]), RedeliveryPolicy[maximumRedeliverie=
s=3D1]])] InOnly Properties:{} Headers:{camelFlatpackCounter=3D4} BodyType:=
net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-6 -> to5 To[activemq:queue:cutas.clientA.accept=
ed.in] InOnly Properties:{CamelCauseException=3Dnull} Headers:{camelFlatpac=
kCounter=3D4} BodyType:net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-7 -> interceptor3 Interceptor[Delegate(DeadLett=
erChannel[Delegate(TraceInterceptor[To[activemq:queue:cutas.clientA.accepte=
d.in]]), sendTo(Endpoint[seda:errors]), RedeliveryPolicy[maximumRedeliverie=
s=3D1]])] InOnly Properties:{} Headers:{camelFlatpackCounter=3D5} BodyType:=
net.sf.flatpack.DefaultDataSet
> 4318172 [Thread: 2 org.apache.camel.component.file.FileComponent@14f5a31]=
 INFO  org.apache.camel.processor.interceptor.TraceInterceptor  - ID-dell-c=
harles/1671-1218196761734/1-7 -> to5 To[activemq:queue:cutas.clientA.accept=
ed.in] InOnly Properties:{CamelCauseException=3Dnull} Headers:{camelFlatpac=
kCounter=3D5} BodyType:net.sf.flatpack.DefaultDataSet
> 4318219 [DefaultMessageListenerContainer-9] WARN  org.apache.camel.compon=
ent.jms.EndpointMessageListener  - Endpoint[activemq:queue:cutas.clientA.ac=
cepted.in] consumer caught an exception while processing JMS message: Activ=
eMQMessage {commandId =3D 5, responseRequired =3D true, messageId =3D ID:de=
ll-charles-1675-1218196762046-2:3:1:1:1, originalDestination =3D null, orig=
inalTransactionId =3D null, producerId =3D ID:dell-charles-1675-12181967620=
46-2:3:1:1, destination =3D queue://cutas.clientA.accepted.in, transactionI=
d =3D null, expiration =3D 0, timestamp =3D 1218196771187, arrival =3D 0, b=
rokerInTime =3D 1218196771187, brokerOutTime =3D 1218196771218, correlation=
Id =3D null, replyTo =3D null, persistent =3D true, type =3D null, priority=
 =3D 4, groupID =3D null, groupSequence =3D 0, targetConsumerId =3D null, c=
ompressed =3D false, userID =3D null, content =3D null, marshalledPropertie=
s =3D null, dataStructure =3D null, redeliveryCounter =3D 0, size =3D 1024,=
 properties =3D {camelFlatpackCounter=3D0}, readOnlyProperties =3D true, re=
adOnlyBody =3D true, droppable =3D false}
> 43org.apache.camel.RuntimeCamelException: java.lang.NullPointerException
> =09at org.apache.camel.component.jms.EndpointMessageListener.onMessage(En=
dpointMessageListener.java:71)
> =09at org.springframework.jms.listener.AbstractMessageListenerContainer.d=
oInvokeListener(AbstractMessageListenerContainer.java:531)
> =09at org.springframework.jms.listener.AbstractMessageListenerContainer.i=
nvokeListener(AbstractMessageListenerContainer.java:466)
> =09at org.springframework.jms.listener.AbstractMessageListenerContainer.d=
oExecuteListener(AbstractMessageListenerContainer.java:435)
> =09at org.springframework.jms.listener.AbstractPollingMessageListenerCont=
ainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:322)
> =09at org.springframework.jms.listener.AbstractPollingMessageListenerCont=
ainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:260)
> =09at org.springframework.jms.listener.DefaultMessageListenerContainer$As=
yncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.ja=
va:944)
> =09at org.springframework.jms.listener.DefaultMessageListenerContainer$As=
yncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:875)
> =09at java.lang.Thread.run(Unknown Source)
> Caused by: java.lang.NullPointerException
> =09at org.apache.camel.processor.interceptor.TraceFormatter.getBodyTypeAs=
String(TraceFormatter.java:124)
> =09at org.apache.camel.processor.interceptor.TraceFormatter.format(TraceF=
ormatter.java:39)
> =09at org.apache.camel.processor.interceptor.TraceInterceptor.format(Trac=
eInterceptor.java:68)
> =09at org.apache.camel.processor.Logger.logMessage(Logger.java:218)
> =09at org.apache.camel.processor.Logger.process(Logger.java:125)
> =09at org.apache.camel.processor.interceptor.TraceInterceptor.logExceptio=
n(TraceInterceptor.java:128)
> =09at org.apache.camel.processor.interceptor.TraceInterceptor.process(Tra=
ceInterceptor.java:59)
> =09at org.apache.camel.impl.converter.AsyncProcessorTypeConverter$Process=
orToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:43)
> =09at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkPr=
ocessor.java:39)
> =09at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHe=
lper.java:41)
> =09at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateA=
syncProcessor.java:66)
> =09at org.apache.camel.component.jms.EndpointMessageListener.onMessage(En=
dpointMessageListener.java:68)
> =09... 8 more
> =09
> Code snippet :
> =09public void configure() {
> =09=09=09
> =09=09errorHandler(deadLetterChannel("seda:errors").maximumRedeliveries(1=
)
> =09=09=09=09.useExponentialBackOff());
> =09=09
>         // Display trace
> =09=09Tracer tracer =3D new Tracer();
> =09=09tracer.getFormatter().setShowBody(false);
> =09=09tracer.getFormatter().setShowHeaders(true);
> =09=09tracer.getFormatter().setShowNode(true);
> =09=09getContext().addInterceptStrategy(tracer);
> =09=09
> =09
> =09=09from(file:///c:/temp/cutas/input/clientA/?delete=3Dfalse&amp;lock=
=3Dtrue&amp;consumer.delay=3D500&amp;consumer.initialDelay=3D10)
> =09=09.to(flatpack:fixed:com/bravura/babel/transformation/cutas/in/CUTAS.=
xml);
> =09=09
> =09=09from(flatpack:fixed:com/bravura/babel/transformation/cutas/in/CUTAS=
.xml)
> =09=09.to(activemq:queue:cutas.clientA.accepted.in);

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