Module Information
Public.ZeroMQ
Viewing contents of Public_ZeroMQ-1.0/testsrv.pike
int main(int argc, array argv) {
object ctx = Public.ZeroMQ.Context();
object sock = Public.ZeroMQ.Socket(ctx, Public.ZeroMQ.SUB);
sock->connect("tcp://127.0.0.1:5555");
sock->set_option(Public.ZeroMQ.SUBSCRIBE, "Foo");
// werror("sub: %O\n", sock->get_option_string(Public.ZeroMQ.SUBSCRIBE));
mixed rv;
object poll = Public.ZeroMQ.Poll();
int i = 0;
int start = time();
poll->add_socket(sock, lambda(object socket, mixed ... t) {i++; write("Q: %O, %O\n", socket, t);});
do{
rv = poll->poll(1.0);
werror("rv: %O\n", rv);
//if((time() - start) == 10) {werror("i: %d\n", i); return 0; }
} while(1);
return 0;
}
|
|