[
https://issues.apache.org/jira/browse/ARTEMIS-317?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15081551#comment-15081551
]
Raj commented on ARTEMIS-317:
-----------------------------
Hi Justin,
Happy new Year.
Yes. We did load testing with small and large message and Artemis was fine.
We notice that sometimes Topic and Queue was getting block when subscriber
does not process data as fast as publisher. We have HornetQ publisher and
HornetQ and STOMP subscriber. Issue was coming from STOMP subscribers which is
web based client.
Let us know better optimum configuration to mitigate Blocking issues.
Also when we tried to use "STOMP_WS" protocol configuration in broker.xml file
we got error. It said unknown protocol. In documentation and does mention to
use STOMP_WS for websocket clients.
We are waiting for final release of 1.1.1 so we can retest Artemis. We did
testing from snapshot of Master branch 12/9/2015
Thanks for your help.
> 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)
