[#AMQ-1632] PrefetchSubscription may not wake up if messages delivered in transaction - Apache ActiveMQ, Apache ServiceMix, Apache Camel

ActiveMQ

PrefetchSubscription may not wake up if messages delivered in transaction

Created: 23/Mar/08 11:30 PM Updated: 06/Jun/08 07:15 AM

Return to search

Component/s:

Broker

Affects Version/s:

4.1.1

Fix Version/s:

4.1.2

Time Tracking:

Not Specified

Issue Links:

Related

This issue is related to:

~~AMQ-1779~~ RA does not reconnect correctly to a failed broker

Description

« Hide

we noticed mdbs w/transaction on don't work if the prefetch size is less than the number of sessions for the mdb. There's an error in calculating the prefetchExtension in afterCommit and there's no notification that it might be time to send more messages. Apparently if the prefetch size is large enough one of the earlier acks triggers delivery of the next batch.

There are also a bunch of synchronization errors in some classes...

All

Comments

Work Log

Change History

Subversion Commits

FishEye

Crucible

Sort Order:

640336 by David Jencks (5 files)

24/Mar/08 12:22 AM (19 months, 23 days ago)

~~AMQ-1632~~ Fix mdb stopping problem and improve some thread-safety

branches/activemq-4.1/activemq-ra/src/main/java/org/apache/activemq/ra/ServerSessionPoolImpl.java 640336

(+2 -2) diffs

branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/ActiveMQSessionExecutor.java 640336

(+44 -39) diffs

branches/activemq-4.1/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java 640336

(+69 -56) diffs

branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java 640336

(+3 -2) diffs

branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/thread/PooledTaskRunner.java 640336

(+4 -1) diffs

640626 by David Jencks (2 files)

24/Mar/08 03:42 PM (19 months, 23 days ago)

~~AMQ-1632~~. Correct prefetch size instead of trying to push messages more often

branches/activemq-4.1/activemq-ra/src/main/java/org/apache/activemq/ra/ActiveMQEndpointWorker.java 640626

(+3 -2) diffs

branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/broker/region/PrefetchSubscription.java 640626

(+0 -1) diffs