summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/BrokerAdapter.h
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/BrokerAdapter.h')
-rw-r--r--cpp/src/qpid/broker/BrokerAdapter.h6
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/BrokerAdapter.h b/cpp/src/qpid/broker/BrokerAdapter.h
index c66bdb3a31..795744aa9a 100644
--- a/cpp/src/qpid/broker/BrokerAdapter.h
+++ b/cpp/src/qpid/broker/BrokerAdapter.h
@@ -56,7 +56,7 @@ class MessageHandlerImpl;
class BrokerAdapter : public CoreRefs, public framing::AMQP_ServerOperations
{
public:
- BrokerAdapter(Channel& ch, Connection& c, Broker& b);
+ BrokerAdapter(Channel& ch, Connection& c, Broker& b, framing::ChannelAdapter& a);
framing::ProtocolVersion getVersion() const;
ChannelHandler* getChannelHandler() { return &channelHandler; }
@@ -172,8 +172,10 @@ class BrokerAdapter : public CoreRefs, public framing::AMQP_ServerOperations
public BasicHandler,
public HandlerImpl<framing::AMQP_ClientProxy::Basic>
{
+ NameGenerator tagGenerator;
+
public:
- BasicHandlerImpl(BrokerAdapter& parent) : HandlerImplType(parent) {}
+ BasicHandlerImpl(BrokerAdapter& parent) : HandlerImplType(parent), tagGenerator("sgen") {}
void qos(const framing::MethodContext& context, uint32_t prefetchSize,
uint16_t prefetchCount, bool global);