library/cpp/messagebus/queue_config.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

#include "queue_config.h" 
 
using namespace NBus; 
 
TBusQueueConfig::TBusQueueConfig() { 
    // workers and listeners configuratioin 
    NumWorkers = 1; 
} 
 
void TBusQueueConfig::ConfigureLastGetopt(
    NLastGetopt::TOpts& opts, const TString& prefix) {
    opts.AddLongOption(prefix + "worker-count")
        .RequiredArgument("COUNT")
        .DefaultValue(ToString(NumWorkers))
        .StoreResult(&NumWorkers);
} 
 
TString TBusQueueConfig::PrintToString() const {
    TStringStream ss; 
    ss << "NumWorkers=" << NumWorkers << "\n"; 
    return ss.Str(); 
}