From d955bd525247461fcd8129480d615e2375dee2c2 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Wed, 24 Jan 2007 19:51:13 +0000 Subject: fixed NPE in AMQMessage, _taken was not being initialized from some constructors, now it is initialized on declaration git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@499549 13f79535-47bb-0310-9956-ffa450edef68 --- java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'java') diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java index e01635b061..b074d0ffa8 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java @@ -88,7 +88,7 @@ public class AMQMessage */ private boolean _deliveredToConsumer; private ConcurrentHashMap _decodedMessages; - private AtomicBoolean _taken; + private AtomicBoolean _taken = new AtomicBoolean(false); public AMQMessage(MessageStore messageStore, MessageTransferBody transferBody) @@ -104,7 +104,6 @@ public class AMQMessage _contents = new LinkedList(); _decodedMessages = new ConcurrentHashMap(); _storeWhenComplete = storeWhenComplete; - _taken = new AtomicBoolean(false); } public AMQMessage(MessageStore store, long messageId, MessageTransferBody transferBody, -- cgit v1.2.1