Mercurial > lbo > hg > clusterrpc-java
changeset 2:9a19a94a5e74
Add exploratory test
author | Lewin Bormann <lbo@spheniscida.de> |
---|---|
date | Fri, 23 Sep 2016 16:50:09 +0200 |
parents | 4f815715fcbd |
children | c81cdb1b037d |
files | src/test/java/net/borgac/clusterrpc/JeroMQGeneral.java |
diffstat | 1 files changed, 54 insertions(+), 0 deletions(-) [+] |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/test/java/net/borgac/clusterrpc/JeroMQGeneral.java Fri Sep 23 16:50:09 2016 +0200 @@ -0,0 +1,54 @@ +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); + } +}