userver: userver/urabbitmq/consumer_settings.hpp Source File
Loading...
Searching...
No Matches
consumer_settings.hpp
Go to the documentation of this file.
1#pragma once
2
3/// @file userver/urabbitmq/consumer_settings.hpp
4/// @brief Consumer settings.
5
6#include <cstddef>
7
8#include <userver/urabbitmq/typedefs.hpp>
9
10USERVER_NAMESPACE_BEGIN
11
12namespace urabbitmq {
13
14/// @brief Consumer settings struct
15struct ConsumerSettings final {
16 /// A queue to consume from
17 Queue queue;
18
19 /// Limit for unacked messages, degree of parallelism if you will.
20 /// Tasks are dispatched asynchronously, so be a bit careful with this value:
21 /// up to this value of tasks might be executed concurrently,
22 /// which could be overwhelming
23 ///
24 /// Settings this value to 1 basically makes a consumer synchronous, which
25 /// could be of use for some workloads
26 std::uint16_t prefetch_count;
27};
28
29} // namespace urabbitmq
30
31USERVER_NAMESPACE_END