activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1482794 - /activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
Date Wed, 15 May 2013 12:44:13 GMT
Author: chirino
Date: Wed May 15 12:44:13 2013
New Revision: 1482794

URL: http://svn.apache.org/r1482794
Log:
Fixing regression in last commit.

Modified:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java?rev=1482794&r1=1482793&r2=1482794&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java
Wed May 15 12:44:13 2013
@@ -797,15 +797,24 @@ public class Queue extends BaseDestinati
             }
             // do the ordered work
             if (!orderedWork.isEmpty()) {
+
+                ArrayList<SendSync> syncs = new ArrayList<SendSync>(orderedWork.size());;
                 sendLock.lockInterruptibly();
+
                 try {
                     for (Transaction tx : orderedWork) {
-                        sendSyncs.get(tx).processSend();
+                        SendSync sync = sendSyncs.get(tx);
+                        sync.processSend();
+                        syncs.add(sync);
                         sendSyncs.remove(tx);
                     }
                 } finally {
                     sendLock.unlock();
                 }
+
+                for (SendSync sync : syncs) {
+                    sync.processSent();
+                }
             }
         }
 



Mime
View raw message