Author: ritchiem
Date: Wed Mar 25 18:00:35 2009
New Revision: 758372
URL: http://svn.apache.org/viewvc?rev=758372&view=rev
Log:
QPID-1735 : Removed duplicated methods with differing functionality that was
causing FtD to fail. Annoyingly the tests work as they used the method with the
extra functionality.
Modified:
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntry.java
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
Modified:
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntry.java
URL:
http://svn.apache.org/viewvc/qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntry.java?rev=758372&r1=758371&r2=758372&view=diff
==============================================================================
---
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntry.java
(original)
+++
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntry.java
Wed Mar 25 18:00:35 2009
@@ -170,14 +170,15 @@
boolean isDeleted();
boolean acquiredBySubscription();
-
- void setDeliveredToSubscription();
-
+
/**
* Called when this message is delivered to a consumer. (used to implement
the 'immediate' flag functionality).
* And for selector efficiency.
+ *
+ * This is now also used to unload the message if this entry is on a
flowed queue. As a result this method should
+ * only be called after the message has been sent.
*/
- public void setDeliveredToConsumer();
+ void setDeliveredToSubscription();
void release();
Modified:
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
URL:
http://svn.apache.org/viewvc/qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java?rev=758372&r1=758371&r2=758372&view=diff
==============================================================================
---
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
(original)
+++
qpid/branches/0.5-release/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
Wed Mar 25 18:00:35 2009
@@ -158,7 +158,7 @@
return (_flags & DELIVERED_TO_CONSUMER) != 0;
}
- public void setDeliveredToConsumer()
+ public void setDeliveredToSubscription()
{
_flags |= DELIVERED_TO_CONSUMER;
@@ -223,11 +223,6 @@
return (_state instanceof SubscriptionAcquiredState);
}
- public void setDeliveredToSubscription()
- {
- _flags |= DELIVERED_TO_CONSUMER;
- }
-
public void release()
{
_stateUpdater.set(this, AVAILABLE_STATE);
Modified:
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
URL:
http://svn.apache.org/viewvc/qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java?rev=758372&r1=758371&r2=758372&view=diff
==============================================================================
---
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
(original)
+++
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/AbstractHeadersExchangeTestBase.java
Wed Mar 25 18:00:35 2009
@@ -280,11 +280,6 @@
//To change body of implemented methods use File |
Settings | File Templates.
}
- public void setDeliveredToConsumer()
- {
- //To change body of implemented methods use File |
Settings | File Templates.
- }
-
public void release()
{
//To change body of implemented methods use File |
Settings | File Templates.
Modified:
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
URL:
http://svn.apache.org/viewvc/qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java?rev=758372&r1=758371&r2=758372&view=diff
==============================================================================
---
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
(original)
+++
qpid/branches/0.5-release/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTest.java
Wed Mar 25 18:00:35 2009
@@ -77,7 +77,7 @@
assertFalse("Undelivered Message should not say it is delivered.",
queueEntry.getDeliveredToConsumer());
- queueEntry.setDeliveredToConsumer();
+ queueEntry.setDeliveredToSubscription();
assertTrue("Delivered Message should say it is delivered.",
queueEntry.getDeliveredToConsumer());
@@ -112,7 +112,7 @@
assertFalse("Undelivered Message should not say it is delivered.",
queueEntry.getDeliveredToConsumer());
- queueEntry.setDeliveredToConsumer();
+ queueEntry.setDeliveredToSubscription();
assertTrue("Delivered Message should say it is delivered.",
queueEntry.getDeliveredToConsumer());
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
