intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 22 insertions, 0 deletions

diff --git a/library/cpp/messagebus/queue_config.cpp b/library/cpp/messagebus/queue_config.cpp
new file mode 100644
index 0000000000..78fb52ee49
--- /dev/null
+++ b/library/cpp/messagebus/queue_config.cpp
@@ -0,0 +1,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();
+}