[jira] [Commented] (SM-2151) java.lang.ClassCastException: org.apache.activemq.command.ActiveMQTempQueue cannot be cast to org.apache.activemq.command.Message

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