Author: robbie
Date: Tue Dec 8 04:06:59 2009
New Revision: 888251
URL: http://svn.apache.org/viewvc?rev=888251&view=rev
Log:
QPID-2250: Remove requirement for message persistence and queue durability from
the copy process
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
Modified:
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java?rev=888251&r1=888250&r2=888251&view=diff
==============================================================================
---
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
(original)
+++
qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
Tue Dec 8 04:06:59 2009
@@ -1037,30 +1037,26 @@
{
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()
+ {
- }
- });
+ }
+ });
- }
}
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
