8#include <userver/utils/periodic_task.hpp>
10#include <userver/urabbitmq/consumer_settings.hpp>
12USERVER_NAMESPACE_BEGIN
17class ConsumerBaseImpl;
41 ConsumerBase(std::shared_ptr<
Client> client,
42 const ConsumerSettings& settings);
43 virtual ~ConsumerBase();
71 virtual void Process(std::string message) = 0;
74 std::shared_ptr<
Client> client_;
75 const ConsumerSettings settings_;
77 std::unique_ptr<ConsumerBaseImpl> impl_;
78 utils::PeriodicTask monitor_{};