Author: gsim
Date: Thu Nov 27 05:03:32 2008
New Revision: 721174

URL: http://svn.apache.org/viewvc?rev=721174&view=rev
Log:
Further check in decode of policy.


Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp?rev=721174&r1=721173&r2=721174&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Queue.cpp Thu Nov 27 05:03:32 
2008
@@ -760,7 +760,7 @@
     std::pair<Queue::shared_ptr, bool> result = queues.declare(name, true);
     buffer.get(result.first->settings);
     result.first->configure(result.first->settings);
-    if (result.first->policy.get()) {
+    if (result.first->policy.get() && buffer.available() >= 
result.first->policy->encodedSize()) {
         buffer.get ( *(result.first->policy) );
     }
     return result.first;


Reply via email to