diff options
author | Carl C. Trieloff <cctrieloff@apache.org> | 2007-01-09 19:44:50 +0000 |
---|---|---|
committer | Carl C. Trieloff <cctrieloff@apache.org> | 2007-01-09 19:44:50 +0000 |
commit | 879413783bf64537e3a1c7d036e2fb34700cc4e5 (patch) | |
tree | dd10e99b938ed82523bf878d05edcc6e06f90231 /cpp/lib/broker/InMemoryContent.cpp | |
parent | cb148a3cf74760e2af234896825cc117f13c506e (diff) | |
download | qpid-python-879413783bf64537e3a1c7d036e2fb34700cc4e5.tar.gz |
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
Diffstat (limited to 'cpp/lib/broker/InMemoryContent.cpp')
-rw-r--r-- | cpp/lib/broker/InMemoryContent.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
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<AMQBody, AMQContentBody>(*i); - out->send(new AMQFrame(channel, contentBody)); + out->send(new AMQFrame(version, channel, contentBody)); } } } |