You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
("BROKER.total_retrieving_timeout", po::value<int>()->default_value(120000), "max total duration the worker is going to spend when retrieving messages, in milliseconds")
98
98
("BROKER.prefetch_timeout", po::value<int>()->default_value(100), "RabbitMQ timeout for prefetched messages (maintenance/RT) in millisecond")
99
99
("BROKER.prefetch_message_count", po::value<int>()->default_value(100), "max number of messages (maintenance/RT) prefetched from RabbitMQ")
100
-
("BROKER.broker_prefetch_total_retrieving_timeout", po::value<int>()->default_value(10000), "max total duration the worker is going to spend when retrieving prefetched messages, in milliseconds")
100
+
("BROKER.prefetch_total_retrieving_timeout", po::value<int>()->default_value(10000), "max total duration the worker is going to spend when retrieving prefetched messages, in milliseconds")
101
101
("BROKER.sleeptime", po::value<int>()->default_value(1), "sleeptime for maintenance worker in second")
102
102
("BROKER.reconnect_wait", po::value<int>()->default_value(1), "Wait duration between connection attempts to rabbitmq, in seconds")
103
103
("BROKER.queue", po::value<std::string>(), "rabbitmq's queue name to be bound")
0 commit comments