[
https://issues.apache.org/jira/browse/ARTEMIS-317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justin Bertram reassigned ARTEMIS-317:
--------------------------------------
Assignee: Justin Bertram
> 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
> Assignee: Justin Bertram
>
> 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)
