diff --git a/src/mesy_nng_push_pull_main.cc b/src/mesy_nng_push_pull_main.cc index 925a1f8..24da0f1 100644 --- a/src/mesy_nng_push_pull_main.cc +++ b/src/mesy_nng_push_pull_main.cc @@ -144,6 +144,11 @@ int main(int argc, char *argv[]) { spdlog::set_level(spdlog::level::info); + size_t ProducerCount = 10; + + if (argc > 1) + ProducerCount = std::stoull(argv[1]); + nng_socket consumerSocket = NNG_SOCKET_INITIALIZER; if (int res = nng_pull0_open(&consumerSocket)) @@ -162,10 +167,13 @@ int main(int argc, char *argv[]) std::vector threads; - const size_t ProducerCount = 10; + spdlog::info("Starting {} producers.", ProducerCount); + for (size_t i=0; i