diff options
Diffstat (limited to 'cpp/src/qpid/broker/BrokerChannel.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/BrokerChannel.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/BrokerChannel.cpp b/cpp/src/qpid/broker/BrokerChannel.cpp index c1f0b44ed4..26e590f87e 100644 --- a/cpp/src/qpid/broker/BrokerChannel.cpp +++ b/cpp/src/qpid/broker/BrokerChannel.cpp @@ -55,7 +55,7 @@ Channel::Channel( uint32_t _framesize, MessageStore* const _store, uint64_t _stagingThreshold ) : - ChannelAdapter(id, &con.getOutput(), con.getVersion()), + ChannelAdapter(), connection(con), currentDeliveryTag(1), prefetchSize(0), @@ -70,6 +70,7 @@ Channel::Channel( flowActive(true), adapter(new BrokerAdapter(*this, con, con.broker)) { + init(id, con.getOutput(), con.getVersion()); outstanding.reset(); } |
