activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Raj (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-317) Large Message Failure in calling interceptor java.lang.ClassCastException
Date Mon, 04 Jan 2016 18:38:40 GMT

    [ 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)

Mime
View raw message