From 2772d181145f25200db2931ca4ab1b753145d9ab Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Fri, 13 Jun 2014 14:26:15 +0000 Subject: QPID-5801: [Java Broker] BDB HA - ensure that replication exceptions when reading the message id sequence cause the environment to restart Addresses review comment from Alex Rudyy. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1602441 13f79535-47bb-0310-9956-ffa450edef68 --- .../store/berkeleydb/BDBConfigurationStore.java | 25 ++++++++++++++++++---- 1 file changed, 21 insertions(+), 4 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java index 1e1447325e..be1c7c140e 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBConfigurationStore.java @@ -644,10 +644,7 @@ public class BDBConfigurationStore implements MessageStoreProvider, DurableConfi public StoredMessage addMessage(T metaData) { - Sequence mmdSeq = _environmentFacade.openSequence(getMessageMetaDataSeqDb(), - MESSAGE_METADATA_SEQ_KEY, - MESSAGE_METADATA_SEQ_CONFIG); - long newMessageId = mmdSeq.get(null, 1); + long newMessageId = getNextMessageSequenceNumber(); if (metaData.isPersistent()) { @@ -659,6 +656,26 @@ public class BDBConfigurationStore implements MessageStoreProvider, DurableConfi } } + private long getNextMessageSequenceNumber() + { + long newMessageId; + try + { + // The implementations of sequences mean that there is only a transaction + // after every n sequence values, where n is the MESSAGE_METADATA_SEQ_CONFIG.getCacheSize() + + Sequence mmdSeq = _environmentFacade.openSequence(getMessageMetaDataSeqDb(), + MESSAGE_METADATA_SEQ_KEY, + MESSAGE_METADATA_SEQ_CONFIG); + newMessageId = mmdSeq.get(null, 1); + } + catch (DatabaseException de) + { + throw _environmentFacade.handleDatabaseException("Cannot get sequence value for new message", de); + } + return newMessageId; + } + @Override public boolean isPersistent() { -- cgit v1.2.1