diff options
author | Alan Conway <aconway@apache.org> | 2007-01-05 00:52:33 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-01-05 00:52:33 +0000 |
commit | e614b63e6703b98407129deb3e4e533de868ef30 (patch) | |
tree | 2447ad354b9d180f843a51ee6cdd0a54819bcd32 /cpp/lib/broker/SessionHandlerImpl.cpp | |
parent | 04f454c9c580a7ad77698e7e4a7e8ce25e59b14f (diff) | |
download | qpid-python-e614b63e6703b98407129deb3e4e533de868ef30.tar.gz |
0-9 branch now compiles but is not yet functional.
Areas needing attention are marked FIXME.
It includes both 0-8 Basic etc. classes 0-9 Message claasses,
0-8 classes cannot be removed till 0-9 Message is ready to replace them.
Summary of fixes:
- added 0-9 methods to SessionHandlerImpl.h, no implementation yet.
- added missing framing::Content methods
- unimplemented methods do { assert(0); // FIXME
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@492840 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/lib/broker/SessionHandlerImpl.cpp')
-rw-r--r-- | cpp/lib/broker/SessionHandlerImpl.cpp | 65 |
1 files changed, 61 insertions, 4 deletions
diff --git a/cpp/lib/broker/SessionHandlerImpl.cpp b/cpp/lib/broker/SessionHandlerImpl.cpp index 9131060b81..d0971c4fae 100644 --- a/cpp/lib/broker/SessionHandlerImpl.cpp +++ b/cpp/lib/broker/SessionHandlerImpl.cpp @@ -217,9 +217,13 @@ void SessionHandlerImpl::ConnectionHandlerImpl::closeOk(u_int16_t /*channel*/){ void SessionHandlerImpl::ChannelHandlerImpl::open(u_int16_t channel, const string& /*outOfBand*/){ - parent->channels[channel] = new Channel(parent->client->getProtocolVersion() , parent->context, channel, parent->framemax, - parent->queues->getStore(), parent->settings.stagingThreshold); - parent->client->getChannel().openOk(channel); + parent->channels[channel] = new Channel( + parent->client->getProtocolVersion() , parent->context, channel, + parent->framemax, parent->queues->getStore(), + parent->settings.stagingThreshold); + + // FIXME aconway 2007-01-04: provide valid channel Id as per ampq 0-9 + parent->client->getChannel().openOk(channel, std::string()/* ID */); } void SessionHandlerImpl::ChannelHandlerImpl::flow(u_int16_t /*channel*/, bool /*active*/){} @@ -262,7 +266,21 @@ void SessionHandlerImpl::ExchangeHandlerImpl::declare(u_int16_t channel, u_int16 if(!nowait){ parent->client->getExchange().declareOk(channel); } -} +} + + +void SessionHandlerImpl::ExchangeHandlerImpl::unbind( + u_int16_t /*channel*/, + u_int16_t /*ticket*/, + const string& /*queue*/, + const string& /*exchange*/, + const string& /*routingKey*/, + const qpid::framing::FieldTable& /*arguments*/ ) +{ + assert(0); // FIXME aconway 2007-01-04: 0-9 feature +} + + void SessionHandlerImpl::ExchangeHandlerImpl::delete_(u_int16_t channel, u_int16_t /*ticket*/, const string& exchange, bool /*ifUnused*/, bool nowait){ @@ -453,3 +471,42 @@ void SessionHandlerImpl::TxHandlerImpl::rollback(u_int16_t channel){ parent->getChannel(channel)->recover(false); } +void +SessionHandlerImpl::QueueHandlerImpl::unbind( + u_int16_t /*channel*/, + u_int16_t /*ticket*/, + const string& /*queue*/, + const string& /*exchange*/, + const string& /*routingKey*/, + const qpid::framing::FieldTable& /*arguments*/ ) +{ + assert(0); // FIXME aconway 2007-01-04: 0-9 feature +} + +void +SessionHandlerImpl::ChannelHandlerImpl::ok( u_int16_t /*channel*/ ) +{ + assert(0); // FIXME aconway 2007-01-04: 0-9 feature +} + +void +SessionHandlerImpl::ChannelHandlerImpl::ping( u_int16_t /*channel*/ ) +{ + assert(0); // FIXME aconway 2007-01-04: 0-9 feature +} + +void +SessionHandlerImpl::ChannelHandlerImpl::pong( u_int16_t /*channel*/ ) +{ + assert(0); // FIXME aconway 2007-01-04: 0-9 feature +} + +void +SessionHandlerImpl::ChannelHandlerImpl::resume( + u_int16_t /*channel*/, + const string& /*channelId*/ ) +{ + assert(0); // FIXME aconway 2007-01-04: 0-9 feature +} + + |