diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2007-01-24 19:51:13 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2007-01-24 19:51:13 +0000 |
| commit | d955bd525247461fcd8129480d615e2375dee2c2 (patch) | |
| tree | 0bfa9c33b86cd9d8a37821e2a0bcb9afb1540847 /java | |
| parent | 2d84ebceb5c55a7dca0f8523704a8ef1b7190a42 (diff) | |
| download | qpid-python-d955bd525247461fcd8129480d615e2375dee2c2.tar.gz | |
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
Diffstat (limited to 'java')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java | 3 |
1 files changed, 1 insertions, 2 deletions
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<String, MessageDecorator> _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<String, MessageDecorator>(); _storeWhenComplete = storeWhenComplete; - _taken = new AtomicBoolean(false); } public AMQMessage(MessageStore store, long messageId, MessageTransferBody transferBody, |