RTBKit: soa/service/testing/zmq_endpoint

00001 
00009 #define BOOST_TEST_MAIN
00010 #define BOOST_TEST_DYN_LINK
00011 
00012 #include <boost/test/unit_test.hpp>
00013 
00014 #include "jml/arch/timers.h"
00015 #include "jml/utils/testing/watchdog.h"
00016 
00017 #include "soa/service/zmq_endpoint.h"
00018 
00019 using namespace std;
00020 using namespace ML;
00021 using namespace Datacratic;
00022 
00023 
00028 BOOST_AUTO_TEST_CASE( test_no_connect )
00029 {
00030     Watchdog watchdow(10.0);
00031 
00032     auto proxies = std::make_shared<ServiceProxies>();
00033 
00034     ZmqNamedClientBusProxy socket;
00035     socket.init(proxies->config);
00036     socket.connectToServiceClass("foo", "bar");
00037 
00038     socket.start();
00039     ML::sleep(1.0);
00040     socket.shutdown();
00041 }