diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-01-23 21:23:57 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-01-23 21:23:57 +0000 |
| commit | 08c70bfc30c592aa8ce9fab9b52c2435b4d2ed4e (patch) | |
| tree | 6491c885a4c27cccdead618186e36bec24091c6e /qpid/java/systests/src | |
| parent | a83a34c912bad8fc90d8ac1ebb8bc048357e4cc8 (diff) | |
| download | qpid-python-08c70bfc30c592aa8ce9fab9b52c2435b4d2ed4e.tar.gz | |
NO-JIRA : fix spelling error/typo in name of Enque(ue)ableMessage
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1560811 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/systests/src')
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/store/QuotaMessageStore.java | 6 | ||||
| -rw-r--r-- | qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java | 6 |
2 files changed, 6 insertions, 6 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/QuotaMessageStore.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/QuotaMessageStore.java index e19aeb38e7..0e23983087 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/QuotaMessageStore.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/QuotaMessageStore.java @@ -24,7 +24,7 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; import org.apache.qpid.AMQStoreException; -import org.apache.qpid.server.message.EnqueableMessage; +import org.apache.qpid.server.message.EnqueueableMessage; import org.apache.qpid.server.message.MessageContentSource; import org.apache.qpid.server.model.VirtualHost; @@ -111,13 +111,13 @@ public class } @Override - public void enqueueMessage(TransactionLogResource queue, EnqueableMessage message) throws AMQStoreException + public void enqueueMessage(TransactionLogResource queue, EnqueueableMessage message) throws AMQStoreException { _storeSizeIncrease.addAndGet(((MessageContentSource)message).getSize()); } @Override - public void dequeueMessage(TransactionLogResource queue, EnqueableMessage message) throws AMQStoreException + public void dequeueMessage(TransactionLogResource queue, EnqueueableMessage message) throws AMQStoreException { _storeSizeIncrease.addAndGet(-((MessageContentSource)message).getSize()); } diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java index e08061deea..cc0205085b 100644 --- a/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java +++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/store/SlowMessageStore.java @@ -26,7 +26,7 @@ import java.util.UUID; import org.apache.log4j.Logger; import org.apache.qpid.AMQStoreException; -import org.apache.qpid.server.message.EnqueableMessage; +import org.apache.qpid.server.message.EnqueueableMessage; import org.apache.qpid.server.message.ServerMessage; import org.apache.qpid.server.model.VirtualHost; @@ -257,7 +257,7 @@ public class SlowMessageStore implements MessageStore, DurableConfigurationStore _underlying = underlying; } - public void enqueueMessage(TransactionLogResource queue, EnqueableMessage message) + public void enqueueMessage(TransactionLogResource queue, EnqueueableMessage message) throws AMQStoreException { doPreDelay("enqueueMessage"); @@ -265,7 +265,7 @@ public class SlowMessageStore implements MessageStore, DurableConfigurationStore doPostDelay("enqueueMessage"); } - public void dequeueMessage(TransactionLogResource queue, EnqueableMessage message) + public void dequeueMessage(TransactionLogResource queue, EnqueueableMessage message) throws AMQStoreException { doPreDelay("dequeueMessage"); |