2024-11-21 21:38:20 +01:00
|
|
|
#include "test_producer_consumer.h"
|
2023-06-27 23:17:56 +02:00
|
|
|
|
|
|
|
int main(int argc, char *argv[])
|
|
|
|
{
|
|
|
|
spdlog::set_level(spdlog::level::info);
|
|
|
|
auto producerSocket = make_pair_socket();
|
|
|
|
|
|
|
|
if (int res = nng_listen(producerSocket, "tcp6://*:41234", nullptr, 0))
|
2024-12-07 17:36:59 +01:00
|
|
|
mnode_nng_fatal("nng_listen tcp", res);
|
2023-06-27 23:17:56 +02:00
|
|
|
|
2023-06-28 11:37:52 +02:00
|
|
|
producer(producerSocket);
|
2023-06-27 23:17:56 +02:00
|
|
|
|
|
|
|
if (int res = nng_close(producerSocket))
|
2024-12-07 17:36:59 +01:00
|
|
|
mnode_nng_fatal("nng_close", res);
|
2023-06-27 23:17:56 +02:00
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|