consumer_settings.hpp

Go to the documentation of this file.

#pragma once
 
/// @file userver/urabbitmq/consumer_settings.hpp
/// @brief Consumer settings.
 
#include <cstddef>
 
#include <userver/urabbitmq/typedefs.hpp>
 
USERVER_NAMESPACE_BEGIN
 
namespace urabbitmq {
 
/// @brief Consumer settings struct
struct ConsumerSettings final {
    /// A queue to consume from
    Queue queue;
 
    /// Limit for unacked messages, degree of parallelism if you will.
    /// Tasks are dispatched asynchronously, so be a bit careful with this value:
    /// up to this value of tasks might be executed concurrently,
    /// which could be overwhelming
    ///
    /// Settings this value to 1 basically makes a consumer synchronous, which
    /// could be of use for some workloads
    std::uint16_t prefetch_count;
};
 
}  // namespace urabbitmq
 
USERVER_NAMESPACE_END