You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2009/03/25 19:00:50 UTC
svn commit: r758372 - in /qpid/branches/0.5-release/qpid/java/broker/src:
main/java/org/apache/qpid/server/queue/
test/java/org/apache/qpid/server/exchange/
test/java/org/apache/qpid/server/queue/
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:commits-subscribe@qpid.apache.org