summaryrefslogtreecommitdiffstats
path: root/src/rgw/rgw_pubsub_push.cc
diff options
context:
space:
mode:
authorYuval Lifshitz <yuvalif@yahoo.com>2019-03-31 21:52:27 +0200
committerYuval Lifshitz <yuvalif@yahoo.com>2019-03-31 21:52:27 +0200
commit376a3df0d12b544a0378a1467fcf4b2c32fd8afa (patch)
tree4386ef31a9e33d699d36a957bf2752819d1ceb58 /src/rgw/rgw_pubsub_push.cc
parentrgw/pubsub: add s3-compatible API documentation (diff)
downloadceph-376a3df0d12b544a0378a1467fcf4b2c32fd8afa.tar.xz
ceph-376a3df0d12b544a0378a1467fcf4b2c32fd8afa.zip
rgw/pubsub: avoid static creation of amqp manager
Signed-off-by: Yuval Lifshitz <yuvalif@yahoo.com>
Diffstat (limited to 'src/rgw/rgw_pubsub_push.cc')
-rw-r--r--src/rgw/rgw_pubsub_push.cc2
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rgw/rgw_pubsub_push.cc b/src/rgw/rgw_pubsub_push.cc
index 1244ee8ccb9..81c9aefa1a6 100644
--- a/src/rgw/rgw_pubsub_push.cc
+++ b/src/rgw/rgw_pubsub_push.cc
@@ -258,7 +258,7 @@ public:
CephContext* cct) :
endpoint(_endpoint),
topic(_topic),
- conn(amqp::connect(endpoint, get_exchange(args), cct)) {
+ conn(amqp::connect(endpoint, get_exchange(args))) {
bool exists;
// get ack level
str_ack_level = args.get("amqp-ack-level", &exists);