diff options
Diffstat (limited to 'qpid/java/bdbstore/src/main')
2 files changed, 6 insertions, 6 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; } |