]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
rgw: pubsub: create notif via REST api sets dest bucket
authorYehuda Sadeh <yehuda@redhat.com>
Thu, 26 Jul 2018 00:50:37 +0000 (17:50 -0700)
committerYehuda Sadeh <yehuda@redhat.com>
Tue, 11 Dec 2018 08:10:43 +0000 (00:10 -0800)
This got lost somewhere in the refactoring work

Signed-off-by: Yehuda Sadeh <yehuda@redhat.com>
src/rgw/rgw_sync_module_pubsub_rest.cc

index 5b5392cbde56f4d946a6ab95af1f55b4c5b0a21b..15b7bf5411ddbe738e3a2de0e2ca8016ed02b5ac 100644 (file)
@@ -311,7 +311,11 @@ public:
       return -EINVAL;
     }
 
+    auto psmodule = static_cast<RGWPSSyncModuleInstance *>(store->get_sync_module().get());
+    auto conf = psmodule->get_effective_conf();
+
     dest.push_endpoint = s->info.args.get("push-endpoint");
+    dest.bucket_name = string(conf["data_bucket_prefix"]) + s->owner.get_id().to_str() + "-" + topic_name;
 
     return 0;
   }