[
https://issues.apache.org/jira/browse/CAMEL-15615?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212479#comment-17212479
]
Andrea Cosentino commented on CAMEL-15615:
------------------------------------------
Docs updated with a note.
> 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)
