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;