summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/InMemoryContent.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-01-09 19:44:50 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-01-09 19:44:50 +0000
commit879413783bf64537e3a1c7d036e2fb34700cc4e5 (patch)
treedd10e99b938ed82523bf878d05edcc6e06f90231 /cpp/lib/broker/InMemoryContent.cpp
parentcb148a3cf74760e2af234896825cc117f13c506e (diff)
downloadqpid-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.cpp8
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));
}
}
}