From 08c70bfc30c592aa8ce9fab9b52c2435b4d2ed4e Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Thu, 23 Jan 2014 21:23:57 +0000 Subject: 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 --- .../main/java/org/apache/qpid/server/store/QuotaMessageStore.java | 6 +++--- .../main/java/org/apache/qpid/server/store/SlowMessageStore.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) (limited to 'qpid/java/systests/src') 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"); -- cgit v1.2.1