#include "_cgo_export.h" #include #include char *listenaddr = "tcp://*:5555"; void requestResponse() { int len; char buffer [65536]; GoString goStr; goStr.p = buffer; // Socket to talk to clients void *context = zmq_ctx_new (); void *responder = zmq_socket (context, ZMQ_REP); int rc = zmq_bind (responder, listenaddr); while (1) { len = zmq_recv (responder, buffer, 65536, 0); goStr.p = buffer; goStr.n = len; GoString resp = getValue(goStr); zmq_send (responder, resp.p, resp.n, 0); } }