Author: gsim
Date: Mon Aug 6 08:02:36 2007
New Revision: 563163
URL: http://svn.apache.org/viewvc?view=rev&rev=563163
Log:
Send flush after get request. Fixes perftest.
Modified:
incubator/qpid/trunk/qpid/cpp/src/qpid/client/ClientChannel.cpp
incubator/qpid/trunk/qpid/cpp/src/qpid/client/Response.h
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/ClientChannel.cpp
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/ClientChannel.cpp?view=diff&rev=563163&r1=563162&r2=563163
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/ClientChannel.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/ClientChannel.cpp Mon Aug 6
08:02:36 2007
@@ -220,7 +220,9 @@
bool Channel::get(Message& msg, const Queue& queue, AckMode ackMode) {
AMQMethodBody::shared_ptr request(new BasicGetBody(version, 0,
queue.getName(), ackMode));
+
Response response = session->send(request, true);
+ session->flush();
if (response.isA<BasicGetEmptyBody>()) {
return false;
} else {
Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/client/Response.h
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/client/Response.h?view=diff&rev=563163&r1=563162&r2=563163
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/client/Response.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/client/Response.h Mon Aug 6
08:02:36 2007
@@ -43,7 +43,8 @@
}
template <class T> bool isA()
{
- return future->getResponse()->isA<T>();
+ framing::AMQMethodBody::shared_ptr response(future->getResponse());
+ return response && response->isA<T>();
}
void sync()
