summaryrefslogtreecommitdiff
path: root/qpid/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
commit13659cefe235ac0228749ba53e534910b9aae193 (patch)
tree048e91f6708aa307a239ad1df65f551161a971ba /qpid/cpp/lib/broker/InMemoryContent.cpp
parent639e998c5fe03fc0a73667887af6a1828d400c0e (diff)
downloadqpid-python-13659cefe235ac0228749ba53e534910b9aae193.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@494540 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/lib/broker/InMemoryContent.cpp')
-rw-r--r--qpid/cpp/lib/broker/InMemoryContent.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/qpid/cpp/lib/broker/InMemoryContent.cpp b/qpid/cpp/lib/broker/InMemoryContent.cpp
index 8826b42d2c..07af8633e5 100644
--- a/qpid/cpp/lib/broker/InMemoryContent.cpp
+++ b/qpid/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));
}
}
}