summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
index 3f1d1b9530..4003279d57 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java
@@ -97,12 +97,12 @@ public class MemoryMessageStore extends NullMessageStore
public void activate() throws Exception
{
_stateManager.attainState(State.ACTIVATING);
-
+
_stateManager.attainState(State.ACTIVE);
}
@Override
- public StoredMessage addMessage(StorableMessageMetaData metaData)
+ public <T extends StorableMessageMetaData> StoredMessage<T> addMessage(T metaData)
{
final long id = _messageId.getAndIncrement();
StoredMemoryMessage message = new StoredMemoryMessage(id, metaData);