From 879413783bf64537e3a1c7d036e2fb34700cc4e5 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Tue, 9 Jan 2007 19:44:50 +0000 Subject: Most of remaining version changes for C++. Still need to deal with AMQFrame defualt constructor and do some clean up here and there.. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@494540 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/lib/broker/InMemoryContent.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'cpp/lib/broker/InMemoryContent.cpp') diff --git a/cpp/lib/broker/InMemoryContent.cpp b/cpp/lib/broker/InMemoryContent.cpp index 8826b42d2c..07af8633e5 100644 --- a/cpp/lib/broker/InMemoryContent.cpp +++ b/cpp/lib/broker/InMemoryContent.cpp @@ -38,24 +38,24 @@ u_int32_t InMemoryContent::size() return sum; } -void InMemoryContent::send(OutputHandler* out, int channel, u_int32_t framesize) +void InMemoryContent::send(qpid::framing::ProtocolVersion& version, OutputHandler* out, int channel, u_int32_t framesize) { for (content_iterator i = content.begin(); i != content.end(); i++) { if ((*i)->size() > framesize) { u_int32_t offset = 0; for (int chunk = (*i)->size() / framesize; chunk > 0; chunk--) { string data = (*i)->getData().substr(offset, framesize); - out->send(new AMQFrame(channel, new AMQContentBody(data))); + out->send(new AMQFrame(version, channel, new AMQContentBody(data))); offset += framesize; } u_int32_t remainder = (*i)->size() % framesize; if (remainder) { string data = (*i)->getData().substr(offset, remainder); - out->send(new AMQFrame(channel, new AMQContentBody(data))); + out->send(new AMQFrame(version, channel, new AMQContentBody(data))); } } else { AMQBody::shared_ptr contentBody = static_pointer_cast(*i); - out->send(new AMQFrame(channel, contentBody)); + out->send(new AMQFrame(version, channel, contentBody)); } } } -- cgit v1.2.1