package net.borgac.clusterrpc.client;

import org.zeromq.ZMQ;

/**
 * Provides access to the single ZeroMQ context that is shared. by all sockets.
 *
 * @author lbo
 */
final class GlobalContextProvider {

    private static final ZMQ.Context context = ZMQ.context(1);

    static ZMQ.Socket socket(int type) {
        return context.socket(type);
    }

    static ZMQ.Socket clientSocket() {
        // We need to do everything ourselves, as JeroMQ doesn't yet support
        // all features used by clusterrpc servers.
        ZMQ.Socket sock = socket(ZMQ.DEALER);

        // Missing against original implementation:
        // Immediate = false
        // Relaxed = 1
        // ReqCorrelate = 1
        sock.setIPv4Only(false);
        sock.setLinger(0);
        sock.setSendTimeOut(10_000);
        sock.setReceiveTimeOut(10_000);
        sock.setReconnectIVL(100);

        return sock;
    }
}