package net.borgac.clusterrpc;

import org.junit.After;
import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.zeromq.ZMQ;

/**
 * A unit test to explore how JeroMQ works.
 *
 * @author lbo
 */
public class JeroMQGeneral {

    private static final String address = "inproc://jero-exploration";
    private final ZMQ.Context context;

    public JeroMQGeneral() {
        this.context = ZMQ.context(1);
    }

    @BeforeClass
    public static void setUpClass() {
    }

    @AfterClass
    public static void tearDownClass() {
    }

    @Before
    public void setUp() {
    }

    @After
    public void tearDown() {
    }

    @Test
    public void testReqRep() {
        ZMQ.Socket server = context.socket(ZMQ.REP);
        ZMQ.Socket client = context.socket(ZMQ.REQ);

        server.bind(address);
        client.connect(address);

        client.send("Hello World");
        String msg = server.recvStr();

        Assert.assertEquals("HelloWorld", msg);
    }
}