You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Andrea Cosentino (Jira)" <ji...@apache.org> on 2020/10/09 10:29:00 UTC
[jira] [Commented] (CAMEL-15615) Camel-Infinispan: Cannot consume
events
[ https://issues.apache.org/jira/browse/CAMEL-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17210810#comment-17210810 ]
Andrea Cosentino commented on CAMEL-15615:
------------------------------------------
This turns out to be related to the encoding of the cache. It's important to define the encoding on the cache configuration, otherwise we'll need this Warning. We need to add some documentation about this. So I'll leave this open.
> Camel-Infinispan: Cannot consume events
> ----------------------------------------
>
> Key: CAMEL-15615
> URL: https://issues.apache.org/jira/browse/CAMEL-15615
> Project: Camel
> Issue Type: Bug
> Components: camel-infinispan
> Reporter: Andrea Cosentino
> Assignee: Andrea Cosentino
> Priority: Major
> Fix For: 3.6.0
>
>
> If you try to run a simple route like this one:
> {code:java}
> from("infinispan://mycache?hosts=localhost&sync=false&eventTypes=CACHE_ENTRY_CREATED") from("infinispan://mycache?hosts=localhost&sync=false&eventTypes=CACHE_ENTRY_CREATED") .log("Header ${header.CamelInfinispanEventType}");
> {code}
> This will fail with the following WARN
> {code:java}
> 2020-10-01 20:39:06,042 [-async-pool-1-2] WARN HeaderDecoder - ISPN004039: Unable to complete reading event from server 127.0.0.1/127.0.0.1:112222020-10-01 20:39:06,042 [-async-pool-1-2] WARN HeaderDecoder - ISPN004039: Unable to complete reading event from server 127.0.0.1/127.0.0.1:11222org.infinispan.client.hotrod.exceptions.HotRodClientException: ISPN004034: Unable to unmarshall bytes 636F6170 at org.infinispan.client.hotrod.marshall.MarshallerUtil.bytes2obj(MarshallerUtil.java:72) ~[infinispan-client-hotrod-11.0.3.Final.jar:11.0.3.Final] at org.infinispan.client.hotrod.DataFormat.keyToObj(DataFormat.java:103) ~[infinispan-client-hotrod-11.0.3.Final.jar:11.0.3.Final] at org.infinispan.client.hotrod.impl.protocol.Codec21.readCacheEvent(Codec21.java:78) ~[infinispan-client-hotrod-11.0.3.Final.jar:11.0.3.Final] at org.infinispan.client.hotrod.impl.transport.netty.HeaderDecoder.decode(HeaderDecoder.java:156) [infinispan-client-hotrod-11.0.3.Final.jar:11.0.3.Final] at org.infinispan.client.hotrod.impl.transport.netty.HintedReplayingDecoder.callDecode(HintedReplayingDecoder.java:94) [infinispan-client-hotrod-11.0.3.Final.jar:11.0.3.Final] at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:276) [netty-codec-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) [netty-handler-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) [netty-transport-4.1.51.Final.jar:4.1.51.Final] at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792) [netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final] at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:475) [netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final] at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) [netty-transport-native-epoll-4.1.51.Final-linux-x86_64.jar:4.1.51.Final] at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) [netty-common-4.1.51.Final.jar:4.1.51.Final] at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) [netty-common-4.1.51.Final.jar:4.1.51.Final] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_252] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_252] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_252]Caused by: java.lang.IllegalStateException: Unexpected tag : 99 (Field number : 12, Wire type : 3) at org.infinispan.protostream.WrappedMessage.readMessage(WrappedMessage.java:364) ~[protostream-4.3.3.Final.jar:?] at org.infinispan.protostream.ProtobufUtil.fromWrappedByteArray(ProtobufUtil.java:161) ~[protostream-4.3.3.Final.jar:?] at org.infinispan.commons.marshall.ProtoStreamMarshaller.objectFromByteBuffer(ProtoStreamMarshaller.java:45) ~[infinispan-commons-11.0.3.Final.jar:11.0.3.Final] at org.infinispan.commons.marshall.AbstractMarshaller.objectFromByteBuffer(AbstractMarshaller.java:82) ~[infinispan-commons-11.0.3.Final.jar:11.0.3.Final] at org.infinispan.client.hotrod.marshall.MarshallerUtil.bytes2obj(MarshallerUtil.java:56) ~[infinispan-client-hotrod-11.0.3.Final.jar:11.0.3.Final] ... 24 more
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)