diff options
| author | Yuval Lifshitz <yuvalif@yahoo.com> | 2019-01-16 18:57:14 +0100 |
|---|---|---|
| committer | Yuval Lifshitz <yuvalif@yahoo.com> | 2019-02-13 10:19:18 +0100 |
| commit | 0eab504c7aca0a27c01ad8e727f29ebcac812090 (patch) | |
| tree | fb9c9ec2adca2a067093c6cdfb0a60edafeb83c4 /src/rgw/rgw_pubsub_push.cc | |
| parent | rgw: pubsub fix ubuntu linking issue (diff) | |
| download | ceph-0eab504c7aca0a27c01ad8e727f29ebcac812090.tar.xz ceph-0eab504c7aca0a27c01ad8e727f29ebcac812090.zip | |
rgw: pubsub handle immediate errors. support connection deletions
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.cc | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/rgw/rgw_pubsub_push.cc b/src/rgw/rgw_pubsub_push.cc index faa6befeca0..8ec646168d9 100644 --- a/src/rgw/rgw_pubsub_push.cc +++ b/src/rgw/rgw_pubsub_push.cc @@ -116,7 +116,7 @@ class RGWPubSubAMQPEndpoint : public RGWPubSubEndpoint { }; const std::string endpoint; const std::string topic; - const amqp::connection_t& conn; + amqp::connection_t& conn; ack_level_t ack_level; std::string str_ack_level; @@ -135,13 +135,13 @@ class RGWPubSubAMQPEndpoint : public RGWPubSubEndpoint { private: RGWDataSyncEnv* const sync_env; const std::string topic; - const amqp::connection_t& conn; + amqp::connection_t& conn; const std::string message; public: NoAckPublishCR(RGWDataSyncEnv* _sync_env, const std::string& _topic, - const amqp::connection_t& _conn, + amqp::connection_t& _conn, const std::string& _message) : RGWCoroutine(_sync_env->cct), sync_env(_sync_env), topic(_topic), conn(_conn), message(_message) {} @@ -166,14 +166,14 @@ class RGWPubSubAMQPEndpoint : public RGWPubSubEndpoint { private: RGWDataSyncEnv* const sync_env; const std::string topic; - const amqp::connection_t& conn; + amqp::connection_t& conn; const std::string message; const ack_level_t ack_level; // TODO not used for now public: AckPublishCR(RGWDataSyncEnv* _sync_env, const std::string& _topic, - const amqp::connection_t& _conn, + amqp::connection_t& _conn, const std::string& _message, ack_level_t _ack_level) : RGWCoroutine(_sync_env->cct), sync_env(_sync_env), |