diff --git a/modules/ipc/tests/pub_sub_tests.cpp b/modules/ipc/tests/pub_sub_tests.cpp index 3d02cecd..bdfde190 100644 --- a/modules/ipc/tests/pub_sub_tests.cpp +++ b/modules/ipc/tests/pub_sub_tests.cpp @@ -18,23 +18,23 @@ #include "hephaestus/types_proto/dummy_type.h" // NOLINT(misc-include-cleaner) #include "hephaestus/utils/exception.h" -namespace heph::ipc::tests { +namespace heph::ipc::zenoh::tests { namespace { void checkMessageExchange(bool subscriber_dedicated_callback_thread) { auto mt = random::createRNG(); - ipc::zenoh::Config config{}; - auto session = ipc::zenoh::createSession(std::move(config)); + Config config{}; + auto session = createSession(std::move(config)); const auto topic = ipc::TopicConfig(fmt::format("test_topic/{}", random::random(mt, 10, false, true))); - ipc::zenoh::Publisher publisher(session, topic); + Publisher publisher(session, topic); types::DummyType received_message; std::atomic_flag stop_flag = ATOMIC_FLAG_INIT; - auto subscriber = ipc::zenoh::createSubscriber( + auto subscriber = createSubscriber( session, topic, - [&received_message, &stop_flag]([[maybe_unused]] const ipc::zenoh::MessageMetadata& metadata, + [&received_message, &stop_flag]([[maybe_unused]] const MessageMetadata& metadata, const std::shared_ptr& message) { received_message = *message; stop_flag.test_and_set(); @@ -59,17 +59,17 @@ TEST(PublisherSubscriber, MessageExchange) { TEST(PublisherSubscriber, MismatchType) { auto mt = random::createRNG(); - ipc::zenoh::Config config{}; - auto session = ipc::zenoh::createSession(std::move(config)); + Config config{}; + auto session = createSession(std::move(config)); const auto topic = ipc::TopicConfig(fmt::format("test_topic/{}", random::random(mt, 10, false, true))); - ipc::zenoh::Publisher publisher(session, topic); + Publisher publisher(session, topic); std::atomic_flag stop_flag = ATOMIC_FLAG_INIT; - auto subscriber = ipc::zenoh::createSubscriber( + auto subscriber = createSubscriber( session, topic, - [&stop_flag]([[maybe_unused]] const ipc::zenoh::MessageMetadata& metadata, + [&stop_flag]([[maybe_unused]] const MessageMetadata& metadata, const std::shared_ptr& message) { (void)metadata; (void)message; @@ -87,4 +87,4 @@ TEST(PublisherSubscriber, MismatchType) { } } // namespace -} // namespace heph::ipc::tests +} // namespace heph::ipc::zenoh::tests