Raj created ARTEMIS-317:
---------------------------
Summary: Large Message Failure in calling interceptor
java.lang.ClassCastException
Key: ARTEMIS-317
URL: https://issues.apache.org/jira/browse/ARTEMIS-317
Project: ActiveMQ Artemis
Issue Type: Bug
Components: Broker
Affects Versions: 1.1.0
Environment: Artemis 1.1.0, HornetQ 2.4.7 client and Java JDK 1.8.0_65
Reporter: Raj
We download Artemis 1.1.0 and using HornetQ 2.4.7 client publish to
"LargeMSGTest" topic using 5445 port. MSG size is 2032KB XML.
We get following error (ClassCastException) for each Large MSG publication in
the log file.
We are current user of HornetQ and looking for broker because HornetQ support
was close this year. We are happy to see Artemis which support hornetQ.
Please provide workaround or anyfix. Thank you in advance.
AMQ212038: Failure in calling interceptor:
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor@443b9ce4:
java.lang.ClassCastException:
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendLargeMessage
cannot be cast to
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket.
Here is log file content.........................
09:21:12,002 INFO [org.apache.activemq.artemis.integration.bootstrap]
AMQ101000: Starting ActiveMQ Artemis Server
09:21:12,034 INFO [org.apache.activemq.artemis.core.server] AMQ221000: live
Message Broker is starting with configuration Broker Configuration
(clustered=false,journalDirectory=./data/journal,bindingsDirectory=./data/bindings,largeMessagesDirectory=./data/large-messages,pagingDirectory=./data/paging)
09:21:12,112 INFO [org.apache.activemq.artemis.core.server] AMQ221013: Using
NIO Journal
09:21:12,268 INFO [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-server]. Adding protocol support for: CORE
09:21:12,299 INFO [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-amqp-protocol]. Adding protocol support for:
AMQP
09:21:12,346 INFO [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-hornetq-protocol]. Adding protocol support for:
HORNETQ
09:21:12,362 INFO [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for:
MQTT
09:21:12,409 INFO [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-openwire-protocol]. Adding protocol support
for: OPENWIRE
09:21:12,627 INFO [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-stomp-protocol]. Adding protocol support for:
STOMP
09:21:29,671 INFO [org.apache.activemq.artemis.core.server] AMQ221003: trying
to deploy queue jms.queue.DLQ
09:21:29,687 INFO [org.apache.activemq.artemis.core.server] AMQ221003: trying
to deploy queue jms.queue.ExpiryQueue
09:21:29,703 INFO [org.apache.activemq.artemis.core.server] AMQ221003: trying
to deploy queue jms.topic.LargeMSGTest
09:21:30,374 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started
Acceptor at 0.0.0.0:5445 for protocols [HORNETQ,STOMP]
09:21:30,515 INFO [org.apache.activemq.artemis.core.server] AMQ221020: Started
Acceptor at 0.0.0.0:61613 for protocols [STOMP]
09:21:30,546 INFO [org.apache.activemq.artemis.core.server] AMQ221007: Server
is now live
09:21:30,546 INFO [org.apache.activemq.artemis.core.server] AMQ221001: Apache
ActiveMQ Artemis Message Broker version 1.1.0
[nodeID=62fcb50e-99ef-11e5-b584-372f138c390d]
09:22:53,634 WARN [org.apache.activemq.artemis.core.client] AMQ212038: Failure
in calling interceptor:
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor@443b9ce4:
java.lang.ClassCastException:
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendLargeMessage
cannot be cast to
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket
at
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor.intercept(HQPropertiesConversionInterceptor.java:71)
[artemis-hornetq-protocol-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor.intercept(HQPropertiesConversionInterceptor.java:34)
[artemis-hornetq-protocol-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.invokeInterceptors(ChannelImpl.java:382)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:341)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:331)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:595)
[artemis-server-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
[artemis-core-client-1.1.0.jar:1.1.0]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:244)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:110)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_65]
09:22:53,665 WARN [org.apache.activemq.artemis.core.client] AMQ212038: Failure
in calling interceptor:
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor@443b9ce4:
java.lang.ClassCastException:
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendContinuationMessage
cannot be cast to
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket
at
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor.intercept(HQPropertiesConversionInterceptor.java:71)
[artemis-hornetq-protocol-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor.intercept(HQPropertiesConversionInterceptor.java:34)
[artemis-hornetq-protocol-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.invokeInterceptors(ChannelImpl.java:382)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:341)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:331)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:595)
[artemis-server-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
[artemis-core-client-1.1.0.jar:1.1.0]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:244)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:110)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_65]
09:22:53,681 WARN [org.apache.activemq.artemis.core.client] AMQ212038: Failure
in calling interceptor:
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor@443b9ce4:
java.lang.ClassCastException:
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionSendContinuationMessage
cannot be cast to
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket
at
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor.intercept(HQPropertiesConversionInterceptor.java:71)
[artemis-hornetq-protocol-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.hornetq.HQPropertiesConversionInterceptor.intercept(HQPropertiesConversionInterceptor.java:34)
[artemis-hornetq-protocol-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.ChannelImpl.invokeInterceptors(ChannelImpl.java:382)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.doBufferReceived(RemotingConnectionImpl.java:341)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:331)
[artemis-core-client-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:595)
[artemis-server-1.1.0.jar:1.1.0]
at
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
[artemis-core-client-1.1.0.jar:1.1.0]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:244)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:110)
[netty-all-4.0.30.Final.jar:4.0.30.Final]
at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_65]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
