@@ -16,36 +16,36 @@ BOOST_AUTO_TEST_CASE(ZmqContext)
1616
1717BOOST_AUTO_TEST_CASE (Socket)
1818{
19- zmq::context_t context;
20- zmq::socket_t socket (context, zmq::socket_type::pub);
21- socket.close ();
19+ zmq::context_t context;
20+ zmq::socket_t socket (context, zmq::socket_type::pub);
21+ socket.close ();
2222 context.close ();
2323}
2424
2525BOOST_AUTO_TEST_CASE (Subscribe)
2626{
27- zmq::context_t context;
28- zmq::socket_t socket (context, zmq::socket_type::sub);
29- socket.set (zmq::sockopt::subscribe, " test" );
30- socket.close ();
31- context.close ();
27+ zmq::context_t context;
28+ zmq::socket_t socket (context, zmq::socket_type::sub);
29+ socket.set (zmq::sockopt::subscribe, " test" );
30+ socket.close ();
31+ context.close ();
3232}
3333
3434BOOST_AUTO_TEST_CASE (Publish)
3535{
36- zmq::context_t context;
36+ zmq::context_t context;
3737 zmq::socket_t pub_socket (context, zmq::socket_type::pub);
3838 zmq::socket_t sub_socket (context, zmq::socket_type::sub);
3939
40- pub_socket.bind (" inproc://test" );
40+ pub_socket.bind (" inproc://test" );
4141 sub_socket.connect (" inproc://test" );
4242
43- sub_socket.set (zmq::sockopt::subscribe, " test" );
43+ sub_socket.set (zmq::sockopt::subscribe, " test" );
4444 std::string message = " test message" ;
4545 pub_socket.send (zmq::buffer (" test" ), zmq::send_flags::sndmore);
46- pub_socket.send (zmq::buffer (message), zmq::send_flags::none);
46+ pub_socket.send (zmq::buffer (message), zmq::send_flags::none);
4747
48- std::string received_topic;
48+ std::string received_topic;
4949 received_topic.resize (4 );
5050 std::string received_message;
5151 received_message.resize (message.size ());
@@ -61,7 +61,7 @@ BOOST_AUTO_TEST_CASE(Publish)
6161
6262 sub_socket.close ();
6363 pub_socket.close ();
64- context.close ();
64+ context.close ();
6565}
6666
6767BOOST_AUTO_TEST_SUITE_END ()
0 commit comments