diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2006-12-20 22:29:38 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2006-12-20 22:29:38 +0000 |
| commit | 47081948f3e2d930c2564e5a2fad5ad3012659ac (patch) | |
| tree | d71ec6e1b86b377c01260e4ebc9c8fd2bafd4d1d /qpid/cpp/lib/broker/SessionHandlerImpl.cpp | |
| parent | 7b53aee0497f9a0479856c1a1f0e186961f6b6c7 (diff) | |
| download | qpid-python-47081948f3e2d930c2564e5a2fad5ad3012659ac.tar.gz | |
Support for multi version, merge part 1. - can still refactor out dup use of
version object in client and server opperations.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@489212 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/lib/broker/SessionHandlerImpl.cpp')
| -rw-r--r-- | qpid/cpp/lib/broker/SessionHandlerImpl.cpp | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/qpid/cpp/lib/broker/SessionHandlerImpl.cpp b/qpid/cpp/lib/broker/SessionHandlerImpl.cpp index bd6ca9dee9..9131060b81 100644 --- a/qpid/cpp/lib/broker/SessionHandlerImpl.cpp +++ b/qpid/cpp/lib/broker/SessionHandlerImpl.cpp @@ -131,7 +131,10 @@ void SessionHandlerImpl::initiated(qpid::framing::ProtocolInitiation* header){ if (client == NULL) { client = new qpid::framing::AMQP_ClientProxy(context, header->getMajor(), header->getMinor()); - + + + std::cout << "---------------" << this << std::endl; + //send connection start FieldTable properties; string mechanisms("PLAIN"); @@ -212,7 +215,9 @@ 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->context, channel, parent->framemax, + + + parent->channels[channel] = new Channel(parent->client->getProtocolVersion() , parent->context, channel, parent->framemax, parent->queues->getStore(), parent->settings.stagingThreshold); parent->client->getChannel().openOk(channel); } |