diff options
Diffstat (limited to 'cpp/src/qpid/broker/Bridge.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Bridge.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Bridge.cpp b/cpp/src/qpid/broker/Bridge.cpp index d1706b5907..4604ac643f 100644 --- a/cpp/src/qpid/broker/Bridge.cpp +++ b/cpp/src/qpid/broker/Bridge.cpp @@ -86,7 +86,7 @@ Bridge::~Bridge() mgmtObject->resourceDestroy(); } -void Bridge::create(Connection& c) +void Bridge::create(Connection& c, AsyncStore* const store) { detached = false; // Reset detached in case we are recovering. connState = &c; @@ -153,7 +153,7 @@ void Bridge::create(Connection& c) Exchange::shared_ptr exchange = link->getBroker()->getExchanges().get(args.i_src); if (exchange.get() == 0) throw Exception("Exchange not found for dynamic route"); - exchange->registerDynamicBridge(this); + exchange->registerDynamicBridge(this, store); QPID_LOG(debug, "Activated bridge " << name << " for dynamic route for exchange " << args.i_src); } else { QPID_LOG(debug, "Activated bridge " << name << " for static route from exchange " << args.i_src << " to " << args.i_dest); |