Author: rhs
Date: Wed Jan 24 11:51:13 2007
New Revision: 499549
URL: http://svn.apache.org/viewvc?view=rev&rev=499549
Log:
fixed NPE in AMQMessage, _taken was not being initialized from some
constructors, now it is initialized on declaration
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
Modified:
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java?view=diff&rev=499549&r1=499548&r2=499549
==============================================================================
---
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
(original)
+++
incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java
Wed Jan 24 11:51:13 2007
@@ -88,7 +88,7 @@
*/
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 @@
_contents = new LinkedList();
_decodedMessages = new ConcurrentHashMap<String, MessageDecorator>();
_storeWhenComplete = storeWhenComplete;
- _taken = new AtomicBoolean(false);
}
public AMQMessage(MessageStore store, long messageId, MessageTransferBody
transferBody,
