Fix QueueEntry routeToAlternate bug

git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/java-broker-amqp-1-0-management@1566480 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 27 insertions, 25 deletions

diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java b/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
index 8b6968b2cf..173705c0f7 100644
--- a/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
+++ b/java/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
@@ -368,42 +368,44 @@ public abstract class QueueEntryImpl<E extends QueueEntryImpl<E,Q,L>, Q extends
         final AMQQueue currentQueue = getQueue();
         Exchange alternateExchange = currentQueue.getAlternateExchange();
         boolean autocommit =  txn == null;
+        int enqueues;
+
+        if(autocommit)
+        {
+            txn = new LocalTransaction(getQueue().getVirtualHost().getMessageStore());
+        }
+
         if (alternateExchange != null)
         {
-            if(autocommit)
+            enqueues = alternateExchange.send(getMessage(),
+                                              getInstanceProperties(),
+                                              txn,
+                                              action);
+        }
+        else
+        {
+            enqueues = 0;
+        }
+
+        txn.dequeue(currentQueue, getMessage(), new ServerTransaction.Action()
+        {
+            public void postCommit()
             {
-                txn = new LocalTransaction(getQueue().getVirtualHost().getMessageStore());
+                delete();
             }
 
-            int enqueues = alternateExchange.send(getMessage(),
-                                                  getInstanceProperties(),
-                                                  txn,
-                                                  action);
-
-            txn.dequeue(currentQueue, getMessage(), new ServerTransaction.Action()
+            public void onRollback()
             {
-                public void postCommit()
-                {
-                    delete();
-                }
-
-                public void onRollback()
-                {
-
-                }
-            });
 
-            if(autocommit)
-            {
-                txn.commit();
             }
-            return enqueues;
+        });
 
-        }
-        else
+        if(autocommit)
         {
-            return 0;
+            txn.commit();
         }
+
+        return enqueues;
     }
 
     public boolean isQueueDeleted()