You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rh...@apache.org on 2007/01/24 20:51:14 UTC

svn commit: r499549 - /incubator/qpid/branches/qpid.0-9/java/broker/src/main/java/org/apache/qpid/server/queue/AMQMessage.java

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,