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