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;
}