diff options
Diffstat (limited to 'qpid/java/bdbstore')
3 files changed, 8 insertions, 8 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/AbstractBDBMessageStore.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/AbstractBDBMessageStore.java index df12af5a90..35efa55569 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/AbstractBDBMessageStore.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/AbstractBDBMessageStore.java @@ -45,7 +45,7 @@ import org.apache.commons.configuration.Configuration; import org.apache.commons.configuration.ConfigurationException; 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.model.VirtualHost; import org.apache.qpid.server.queue.AMQQueue; import org.apache.qpid.server.store.*; @@ -1697,7 +1697,7 @@ public abstract class AbstractBDBMessageStore implements MessageStore, DurableCo } } - public void enqueueMessage(TransactionLogResource queue, EnqueableMessage message) throws AMQStoreException + public void enqueueMessage(TransactionLogResource queue, EnqueueableMessage message) throws AMQStoreException { if(message.getStoredMessage() instanceof StoredBDBMessage) { @@ -1709,7 +1709,7 @@ public abstract class AbstractBDBMessageStore implements MessageStore, DurableCo AbstractBDBMessageStore.this.enqueueMessage(_txn, queue, message.getMessageNumber()); } - public void dequeueMessage(TransactionLogResource queue, EnqueableMessage message) throws AMQStoreException + public void dequeueMessage(TransactionLogResource queue, EnqueueableMessage message) throws AMQStoreException { AbstractBDBMessageStore.this.dequeueMessage(_txn, queue, message.getMessageNumber()); } diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/PreparedTransactionBinding.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/PreparedTransactionBinding.java index 09f2c50e2d..e543cfb719 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/PreparedTransactionBinding.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/tuple/PreparedTransactionBinding.java @@ -26,7 +26,7 @@ import java.util.UUID; import com.sleepycat.bind.tuple.TupleBinding; import com.sleepycat.bind.tuple.TupleInput; import com.sleepycat.bind.tuple.TupleOutput; -import org.apache.qpid.server.message.EnqueableMessage; +import org.apache.qpid.server.message.EnqueueableMessage; import org.apache.qpid.server.store.StoredMessage; import org.apache.qpid.server.store.Transaction; import org.apache.qpid.server.store.TransactionLogResource; @@ -81,7 +81,7 @@ public class PreparedTransactionBinding extends TupleBinding<PreparedTransaction } } - private static class RecordImpl implements Transaction.Record, TransactionLogResource, EnqueableMessage + private static class RecordImpl implements Transaction.Record, TransactionLogResource, EnqueueableMessage { private long _messageNumber; @@ -98,7 +98,7 @@ public class PreparedTransactionBinding extends TupleBinding<PreparedTransaction return this; } - public EnqueableMessage getMessage() + public EnqueueableMessage getMessage() { return this; } diff --git a/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java b/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java index aa144e7a35..0f4cdf1078 100644 --- a/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java +++ b/qpid/java/bdbstore/systests/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStoreTest.java @@ -33,7 +33,7 @@ import org.apache.qpid.framing.MethodRegistry; import org.apache.qpid.framing.ProtocolVersion; import org.apache.qpid.framing.abstraction.MessagePublishInfo; import org.apache.qpid.server.message.AMQMessageHeader; -import org.apache.qpid.server.message.EnqueableMessage; +import org.apache.qpid.server.message.EnqueueableMessage; import org.apache.qpid.server.protocol.v0_10.MessageMetaDataType_0_10; import org.apache.qpid.server.protocol.v0_8.MessageMetaData; import org.apache.qpid.server.protocol.v0_10.MessageMetaData_0_10; @@ -540,7 +540,7 @@ public class BDBMessageStoreTest extends MessageStoreTest } @SuppressWarnings("rawtypes") - private static class MockMessage implements ServerMessage, EnqueableMessage + private static class MockMessage implements ServerMessage, EnqueueableMessage { private long _messageId; |