Modules
ADT Database GTK2 GUI IP PiJAX Public Sql Stdio Subversion System Tools Xosd lua v4l2 wx
Recent Changes
Public.Parser.XML2 1.50
Public.ZeroMQ 1.1
Public.Template.Mustache 1.0
Public.Protocols.XMPP 1.4
Sql.Provider.jdbc 1.0
Popular Downloads
Public.Parser.JSON2 1.0
Public.Parser.JSON 0.2
GTK2 2.23
Public.Web.FCGI 1.8
Public.Parser.XML2 1.48
|
Module Information
Public.ZeroMQ
Viewing contents of Public_ZeroMQ-1.1/testrm.pike
int main(int argc, array argv) {
object ctx = Public.ZeroMQ.Context();
object sock = Public.ZeroMQ.Socket(ctx, Public.ZeroMQ.SUB);
object sock1 = Public.ZeroMQ.Socket(ctx, Public.ZeroMQ.SUB);
sock->connect("tcp://127.0.0.1:5555");
sock1->connect("tcp://127.0.0.1:5555");
sock->set_option(Public.ZeroMQ.SUBSCRIBE, "Foo ");
sock1->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(mixed t) {i++; write("Q: %O\n", t->dta);});
poll->add_socket(sock1, lambda(mixed t) {i++; write("Q1: %O\n", t->dta);});
poll->remove_socket(sock);
werror("pollin!\n");
do{
rv = poll->poll(1.0);
werror("rv: %O\n", rv);
} while(1);
return 0;
}
|
|
|