Module Information
Public.ZeroMQ
Viewing contents of Public_ZeroMQ-1.0/testcl.pike
int main(int argc, array argv) {
object ctx = Public.ZeroMQ.Context();
object sock = Public.ZeroMQ.Socket(ctx, Public.ZeroMQ.PUB);
object sock2 = Public.ZeroMQ.Socket(ctx, Public.ZeroMQ.PUB);
sock->bind("tcp://127.0.0.1:5555");
sock2->bind("tcp://127.0.0.1:5555");
int rv;
int i;
while(rv >= 0) {
rv = sock->send( ({Public.ZeroMQ.Message("Foo"), Public.ZeroMQ.Message("Bar"), Public.ZeroMQ.Message("Gazonk") }) );
rv = sock->send( ({Public.ZeroMQ.Message("Foo"), Public.ZeroMQ.Message("Bar"), Public.ZeroMQ.Message("Gazonk") }) );
rv = sock->send( ({Public.ZeroMQ.Message("Foo"), Public.ZeroMQ.Message("Bar"), Public.ZeroMQ.Message("Gazonk") }) );
werror("rv: %O\n", rv);
// rv = sock->send(Public.ZeroMQ.Message("" + i++), 0);
werror("rv: %O\n", rv);
//werror("return code: " + rv + "\n");
//return 0;
}
return 0;
}
|
|