You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@servicemix.apache.org by "Kruttik Aggarwal (Created) (JIRA)" <ji...@apache.org> on 2012/03/27 21:15:27 UTC
[jira] [Created] (SM-2151) java.lang.ClassCastException:
org.apache.activemq.command.ActiveMQTempQueue cannot be cast to
org.apache.activemq.command.Message
java.lang.ClassCastException: org.apache.activemq.command.ActiveMQTempQueue cannot be cast to org.apache.activemq.command.Message
---------------------------------------------------------------------------------------------------------------------------------
Key: SM-2151
URL: https://issues.apache.org/jira/browse/SM-2151
Project: ServiceMix
Issue Type: Bug
Components: servicemix-jms
Affects Versions: 3.3.1
Environment: Linux 2.6.18-274.el5 #1 SMP Fri Jul 8 17:36:59 EDT 2011 x86_64 x86_64 x86_64 GNU/Linux
Reporter: Kruttik Aggarwal
Priority: Blocker
I am using 'amq:jdbcPersistenceAdapter' in the activemq.xml. I get the following error when sending messages to the queue-
ava.lang.ClassCastException: org.apache.activemq.command.ActiveMQTempQueue cannot be cast to org.apache.activemq.command.Message
at org.apache.activemq.store.jdbc.JDBCMessageStore$2.recoverMessage(JDBCMessageStore.java:234)
at org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRecoverNextMessages(DefaultJDBCAdapter.java:722)
at org.apache.activemq.store.jdbc.JDBCMessageStore.recoverNextMessages(JDBCMessageStore.java:230)
at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:83)
at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:75)
at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:227)
at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:100)
at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157)
at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1179)
at org.apache.activemq.broker.region.Queue.addSubscription(Queue.java:237)
at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:275)
at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:372)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:83)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:93)
at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:541)
at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:345)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
at java.lang.Thread.run(Thread.java:662)
--activemq.xml
<amq:persistenceAdapter>
<amq:jdbcPersistenceAdapter dataSource="#hub-ds"/>
</amq:persistenceAdapter>
<bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" id="hub-ds">
<property name="driverClassName" value="org.postgresql.Driver"/>
<property name="url" value="jdbc:postgresql://localhost:5507/test"/>
<property name="username" value="test"/>
<property name="password" value="test"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (SM-2151) java.lang.ClassCastException:
org.apache.activemq.command.ActiveMQTempQueue cannot be cast to
org.apache.activemq.command.Message
Posted by "Kruttik Aggarwal (Commented) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SM-2151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13239848#comment-13239848 ]
Kruttik Aggarwal commented on SM-2151:
--------------------------------------
This how the activemq_msgs table looks like-
id;container;msgid_prod;msgid_seq;expiration;msg
1936;"queue://caxchangeOutboundQueue";"ID:ncias-d760-v.nci.nih.gov-56188-1332836573609-2:1:1:1";2;0;"<binary data>"
1940;"queue://caxchangeOutboundQueue";"ID:ncias-d760-v.nci.nih.gov-56188-1332836573609-2:1:1:1";3;0;"<binary data>"
3300;"queue://caxchangeOutboundQueue";"ID:ncias-d760-v.nci.nih.gov-43888-1332839662905-2:1:1:1";1;0;"<binary data>"
4694;"queue://caxchangeOutboundQueue";"ID:ncias-d760-v.nci.nih.gov-48141-1332873055502-2:1:1:1";1;0;"<binary data>"
> java.lang.ClassCastException: org.apache.activemq.command.ActiveMQTempQueue cannot be cast to org.apache.activemq.command.Message
> ---------------------------------------------------------------------------------------------------------------------------------
>
> Key: SM-2151
> URL: https://issues.apache.org/jira/browse/SM-2151
> Project: ServiceMix
> Issue Type: Bug
> Components: servicemix-jms
> Affects Versions: 3.3.1
> Environment: Linux 2.6.18-274.el5 #1 SMP Fri Jul 8 17:36:59 EDT 2011 x86_64 x86_64 x86_64 GNU/Linux
> Reporter: Kruttik Aggarwal
> Priority: Blocker
> Labels: activemq, broker
>
> I am using 'amq:jdbcPersistenceAdapter' in the activemq.xml. I get the following error when sending messages to the queue-
> ava.lang.ClassCastException: org.apache.activemq.command.ActiveMQTempQueue cannot be cast to org.apache.activemq.command.Message
> at org.apache.activemq.store.jdbc.JDBCMessageStore$2.recoverMessage(JDBCMessageStore.java:234)
> at org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter.doRecoverNextMessages(DefaultJDBCAdapter.java:722)
> at org.apache.activemq.store.jdbc.JDBCMessageStore.recoverNextMessages(JDBCMessageStore.java:230)
> at org.apache.activemq.store.ProxyMessageStore.recoverNextMessages(ProxyMessageStore.java:83)
> at org.apache.activemq.broker.region.cursors.QueueStorePrefetch.doFillBatch(QueueStorePrefetch.java:75)
> at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:227)
> at org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:100)
> at org.apache.activemq.broker.region.cursors.StoreQueueCursor.reset(StoreQueueCursor.java:157)
> at org.apache.activemq.broker.region.Queue.doPageIn(Queue.java:1179)
> at org.apache.activemq.broker.region.Queue.addSubscription(Queue.java:237)
> at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:275)
> at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:372)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
> at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:83)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
> at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:93)
> at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:541)
> at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:345)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
> at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
> at java.lang.Thread.run(Thread.java:662)
> --activemq.xml
> <amq:persistenceAdapter>
> <amq:jdbcPersistenceAdapter dataSource="#hub-ds"/>
> </amq:persistenceAdapter>
> <bean class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close" id="hub-ds">
> <property name="driverClassName" value="org.postgresql.Driver"/>
> <property name="url" value="jdbc:postgresql://localhost:5507/test"/>
> <property name="username" value="test"/>
> <property name="password" value="test"/>
> <property name="poolPreparedStatements" value="true"/>
> </bean>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira