diff options
Diffstat (limited to 'java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java | 34 |
1 files changed, 15 insertions, 19 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java index b4cebda09a..6915850376 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java @@ -1037,30 +1037,26 @@ public class SimpleAMQQueue implements AMQQueue, Subscription.StateListener { final ServerMessage message = entry.getMessage(); - if (message.isPersistent() && toQueue.isDurable()) + txn.enqueue(toQueue, message, new ServerTransaction.Action() { - - txn.enqueue(toQueue, message, new ServerTransaction.Action() + public void postCommit() + { + try { - public void postCommit() - { - try - { - toQueue.enqueue(message); - } - catch (AMQException e) - { - throw new RuntimeException(e); - } - } + toQueue.enqueue(message); + } + catch (AMQException e) + { + throw new RuntimeException(e); + } + } - public void onRollback() - { + public void onRollback() + { - } - }); + } + }); - } } } |