Issue Details (XML | Word | Printable)

Key: AMQ-1189
Type: Bug Bug
Status: Resolved Resolved
Resolution: Fixed
Priority: Blocker Blocker
Assignee: Hiram Chirino
Reporter: Aman Nanner
Votes: 0
Watchers: 1
Operations

If you were logged in you would be able to see more operations.
ActiveMQ

java.lang.ClassCastException: org.apache.activemq.ActiveMQConnectionConsumer, when trying to publish to a topic

Created: 06/Mar/07 11:56 AM   Updated: 07/Mar/07 08:15 AM
Return to search
Component/s: None
Affects Version/s: 4.1.0
Fix Version/s: 4.1.1, 5.0.0

Time Tracking:
Not Specified

Environment: Windows XP SP2

Regression: Regression


 Description  « Hide
When publishing to a topic, a ClassCastException occurs:

Caused by: java.lang.ClassCastException: org.apache.activemq.ActiveMQConnectionConsumer
at org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:810)
at org.apache.activemq.broker.TransportConnection.dispatchSync(TransportConnection.java:769)
at org.apache.activemq.broker.region.TopicSubscription.dispatch(TopicSubscription.java:360)
at org.apache.activemq.broker.region.TopicSubscription.add(TopicSubscription.java:83)
at org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:51)
at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:417)
at org.apache.activemq.broker.region.Topic.send(Topic.java:264)
at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:292)
at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:385)
at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:193)
at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:98)
at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:497)
at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:293)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:95)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
at org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java:96)
at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:83)
at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:69)
at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:74)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1175)
... 7 more

The problem seems to stem in the processDispatch() method of the org.apache.activemq.broker.TransportConnection class. Specifically, it happens during the line:

Runnable sub=(Runnable) md.getConsumer();

It doesn't appear that ActiveMQConnectionConsumer implements the Runnable interface, so this is why the ClassCastException occurs.

 All   Comments   Work Log   Change History   Subversion Commits   FishEye   Crucible      Sort Order: Ascending order - Click to sort in descending order
515524 by  James Strachan (1 file)
07/Mar/07 02:44 AM (32 months, 10 days ago)
Repository Revision Date User Message
AMQ #515524 Wed Mar 07 02:44:14 PST 2007 jstrachan minor patch to avoid ClassCastException for AMQ-1189
Files Changed
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java

Hiram Chirino made changes - 07/Mar/07 07:40 AM
Field Original Value New Value
Assignee Hiram Chirino [ chirino ]
[ Permlink | « Hide ]
James Strachan added a comment - 07/Mar/07 08:04 AM
Issue fixed, many thanks.

Incidentally there was some background discussion on this here: http://www.nabble.com/question-on-AMQ-1189-and-TransportConnection---ActiveMQConnectionConsumer-tf3361343s2354.html


James Strachan made changes - 07/Mar/07 08:04 AM
Status Open [ 1 ] Resolved [ 5 ]
Resolution Fixed [ 1 ]
James Strachan made changes - 07/Mar/07 08:07 AM
Fix Version/s 4.2.0 [ 11712 ]
515622 by  James Strachan (1 file)
07/Mar/07 08:08 AM (32 months, 9 days ago)
[ Permlink | « Hide ]
James Strachan added a comment - 07/Mar/07 08:08 AM
4.2 rev: 515524
4.1 rev: 515622

515625 by  Hiram Chirino (4 files)
07/Mar/07 08:11 AM (32 months, 9 days ago)
Repository Revision Date User Message
AMQ #515625 Wed Mar 07 08:11:50 PST 2007 chirino Fix for https://issues.apache.org/activemq/browse/AMQ-1189, use 2 fields instead of 1 for the 2 usages of the consumer field to avoid CCE when using vm messaging.
Files Changed
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/command/MessageDispatch.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicSubscription.java
MODIFY /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java

515631 by  Hiram Chirino (4 files)
07/Mar/07 08:15 AM (32 months, 9 days ago)
[ Permlink | « Hide ]
Hiram Chirino added a comment - 07/Mar/07 08:15 AM
Fixed in rev 515625 in trunk and in rev 515631 in 4.1 branch.

Create crucible review for all 4 changesets in

Powered by a free Atlassian JIRA open source license for Apache Software Foundation - ActiveMQ. Try JIRA - bug tracking software for your team.
Atlassian JIRA the Professional Issue Tracker. (Enterprise Edition, Version: 3.13.2-#335) - Bug/feature request - Atlassian news - Contact Administrators