75
75
sockets_.insert(std::make_pair(cfg.socket(i).socket_id(), ZeroMQSocket(new_socket)));
78
zmq::pollitem_t item = { *new_socket, 0, ZMQ_POLLIN, 0 };
78
zmq::pollitem_t item = { (void*)*new_socket, 0, ZMQ_POLLIN, 0 };
80
80
// publish sockets can't receive
81
81
if(cfg.socket(i).socket_type() != protobuf::ZeroMQServiceConfig::Socket::PUBLISH)