diff options
Diffstat (limited to 'qpid/java/broker/src')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java index bc9cda7f71..154d7e6535 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/derby/DerbyMessageStore.java @@ -2057,8 +2057,11 @@ public class DerbyMessageStore implements MessageStore _messageId = messageId; _isRecovered = isRecovered; + if(!_isRecovered) + { + _metaData = metaData; + } _metaDataRef = new SoftReference<StorableMessageMetaData>(metaData); - _metaData = metaData; } @Override |