Experimental ZeroMQ Socket API with Context automagically managed for you

PushPullTest.java

package org.zeromq.zmq;

import static org.junit.Assert.assertTrue;

import java.util.Arrays;

import org.junit.Test;
import static org.zeromq.zmq.ZMQ.*;

public class PushPullTest {
  @Test
  public void testSimplePushPull() {
    try (final Socket pull = new Socket(ZMQ_PULL); 
         final Socket push = new Socket(ZMQ_PUSH)) {
      pull.bind("tcp://*:7210");
      push.connect("tcp://127.0.0.1:7210");
      
      byte[] expected = "hello".getBytes();
      push.send(expected);
      byte[] actual = pull.receive();

      assertTrue(Arrays.equals(expected, actual));
    }
  }
}