mirror of
https://github.com/zeromq/cppzmq.git
synced 2024-12-12 18:40:28 +01:00
d4374cbebe
Setting a routing id is necessary when sending a message through a ZMQ_SERVER socket. See [1] for more details. [1] http://api.zeromq.org/4-2:zmq-socket#toc5
130 lines
3.0 KiB
C++
130 lines
3.0 KiB
C++
#include <gtest/gtest.h>
|
|
#include <zmq.hpp>
|
|
|
|
#if defined(ZMQ_CPP11)
|
|
static_assert(!std::is_copy_constructible<zmq::message_t>::value,
|
|
"message_t should not be copy-constructible");
|
|
static_assert(!std::is_copy_assignable<zmq::message_t>::value,
|
|
"message_t should not be copy-assignable");
|
|
#endif
|
|
|
|
TEST(message, constructor_default)
|
|
{
|
|
const zmq::message_t message;
|
|
ASSERT_EQ(0u, message.size());
|
|
}
|
|
|
|
const char *const data = "Hi";
|
|
|
|
TEST(message, constructor_iterators)
|
|
{
|
|
const std::string hi(data);
|
|
const zmq::message_t hi_msg(hi.begin(), hi.end());
|
|
ASSERT_EQ(2u, hi_msg.size());
|
|
ASSERT_EQ(0, memcmp(data, hi_msg.data(), 2));
|
|
}
|
|
|
|
TEST(message, constructor_pointer_size)
|
|
{
|
|
const std::string hi(data);
|
|
const zmq::message_t hi_msg(hi.data(), hi.size());
|
|
ASSERT_EQ(2u, hi_msg.size());
|
|
ASSERT_EQ(0, memcmp(data, hi_msg.data(), 2));
|
|
}
|
|
|
|
TEST(message, constructor_char_array)
|
|
{
|
|
const zmq::message_t hi_msg(data, strlen(data));
|
|
ASSERT_EQ(2u, hi_msg.size());
|
|
ASSERT_EQ(0, memcmp(data, hi_msg.data(), 2));
|
|
}
|
|
|
|
#if defined(ZMQ_BUILD_DRAFT_API) && defined(ZMQ_CPP11)
|
|
TEST(message, constructor_container)
|
|
{
|
|
const std::string hi(data);
|
|
zmq::message_t hi_msg(hi);
|
|
ASSERT_EQ(2u, hi_msg.size());
|
|
ASSERT_EQ(0, memcmp(data, hi_msg.data(), 2));
|
|
}
|
|
#endif
|
|
|
|
#ifdef ZMQ_HAS_RVALUE_REFS
|
|
TEST(message, constructor_move)
|
|
{
|
|
zmq::message_t hi_msg(zmq::message_t(data, strlen(data)));
|
|
}
|
|
|
|
TEST(message, assign_move_empty_before)
|
|
{
|
|
zmq::message_t hi_msg;
|
|
hi_msg = zmq::message_t(data, strlen(data));
|
|
ASSERT_EQ(2u, hi_msg.size());
|
|
ASSERT_EQ(0, memcmp(data, hi_msg.data(), 2));
|
|
}
|
|
|
|
TEST(message, assign_move_empty_after)
|
|
{
|
|
zmq::message_t hi_msg(data, strlen(data));
|
|
hi_msg = zmq::message_t();
|
|
ASSERT_EQ(0u, hi_msg.size());
|
|
}
|
|
|
|
TEST(message, assign_move_empty_before_and_after)
|
|
{
|
|
zmq::message_t hi_msg;
|
|
hi_msg = zmq::message_t();
|
|
ASSERT_EQ(0u, hi_msg.size());
|
|
}
|
|
#endif
|
|
|
|
TEST(message, equality_self)
|
|
{
|
|
const zmq::message_t hi_msg(data, strlen(data));
|
|
ASSERT_EQ(hi_msg, hi_msg);
|
|
}
|
|
|
|
TEST(message, equality_equal)
|
|
{
|
|
const zmq::message_t hi_msg_a(data, strlen(data));
|
|
const zmq::message_t hi_msg_b(data, strlen(data));
|
|
ASSERT_EQ(hi_msg_a, hi_msg_b);
|
|
}
|
|
|
|
TEST(message, equality_equal_empty)
|
|
{
|
|
const zmq::message_t msg_a;
|
|
const zmq::message_t msg_b;
|
|
ASSERT_EQ(msg_a, msg_b);
|
|
}
|
|
|
|
TEST(message, equality_non_equal)
|
|
{
|
|
const zmq::message_t msg_a("Hi", 2);
|
|
const zmq::message_t msg_b("Hello", 5);
|
|
ASSERT_NE(msg_a, msg_b);
|
|
}
|
|
|
|
TEST(message, equality_non_equal_rhs_empty)
|
|
{
|
|
const zmq::message_t msg_a("Hi", 2);
|
|
const zmq::message_t msg_b;
|
|
ASSERT_NE(msg_a, msg_b);
|
|
}
|
|
|
|
TEST(message, equality_non_equal_lhs_empty)
|
|
{
|
|
const zmq::message_t msg_a;
|
|
const zmq::message_t msg_b("Hi", 2);
|
|
ASSERT_NE(msg_a, msg_b);
|
|
}
|
|
|
|
#if defined(ZMQ_BUILD_DRAFT_API) && ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 2, 0)
|
|
TEST(message, routing_id_persists)
|
|
{
|
|
zmq::message_t msg;
|
|
msg.set_routing_id(123);
|
|
ASSERT_EQ(123u, msg.routing_id());
|
|
}
|
|
#endif
|