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);
+    }
+}