diff options
author | Carl C. Trieloff <cctrieloff@apache.org> | 2007-01-09 20:29:06 +0000 |
---|---|---|
committer | Carl C. Trieloff <cctrieloff@apache.org> | 2007-01-09 20:29:06 +0000 |
commit | f420415a0fd5ab9f536d38aa6ec6bd4580b45e30 (patch) | |
tree | 2889ea8ccb36409d52c4c927050869e58eb94c3c /cpp/lib/broker/LazyLoadedContent.cpp | |
parent | 34ba05808a60710ec97abf82620074c6b40fe1d4 (diff) | |
download | qpid-python-f420415a0fd5ab9f536d38aa6ec6bd4580b45e30.tar.gz |
version back merge from trunk rev 494553.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@494559 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/broker/LazyLoadedContent.cpp')
-rw-r--r-- | cpp/lib/broker/LazyLoadedContent.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/lib/broker/LazyLoadedContent.cpp b/cpp/lib/broker/LazyLoadedContent.cpp index 51aa6c590b..ec1ca3e195 100644 --- a/cpp/lib/broker/LazyLoadedContent.cpp +++ b/cpp/lib/broker/LazyLoadedContent.cpp @@ -36,19 +36,19 @@ u_int32_t LazyLoadedContent::size() return 0;//all content is written as soon as it is added } -void LazyLoadedContent::send(OutputHandler* out, int channel, u_int32_t framesize) +void LazyLoadedContent::send(qpid::framing::ProtocolVersion& version, OutputHandler* out, int channel, u_int32_t framesize) { if (expectedSize > framesize) { for (u_int64_t offset = 0; offset < expectedSize; offset += framesize) { u_int64_t remaining = expectedSize - offset; string data; store->loadContent(msg, data, offset, remaining > framesize ? framesize : remaining); - out->send(new AMQFrame(channel, new AMQContentBody(data))); + out->send(new AMQFrame(version, channel, new AMQContentBody(data))); } } else { string data; store->loadContent(msg, data, 0, expectedSize); - out->send(new AMQFrame(channel, new AMQContentBody(data))); + out->send(new AMQFrame(version, channel, new AMQContentBody(data))); } } |