package org.opendaylight.controller.sal.connector.remoterpc;

import org.zeromq.ZMQ;

import java.util.UUID;

/**
 *
 */
public class SocketPair implements AutoCloseable{
  private ZMQ.Socket sender;
  private ZMQ.Socket receiver;

  private static final String INPROC_PREFIX = "inproc://";

  public SocketPair(){
    String address = new StringBuilder(INPROC_PREFIX)
                         .append(UUID.randomUUID())
                         .toString();

    receiver = Context.getInstance().getZmqContext().socket(ZMQ.PAIR);
    receiver.bind(address);

    sender = Context.getInstance().getZmqContext().socket(ZMQ.PAIR);
    sender.connect(address);
  }

  public ZMQ.Socket getSender(){
    return this.sender;
  }

  public ZMQ.Socket getReceiver(){
    return this.receiver;
  }

  @Override
  public void close() throws Exception {
    sender.close();
    receiver.close();
  }
}