import org.zeromq.ZMQ;
public class JeroMQSender {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.PUSH);
socket.bind("tcp://*:5555");
String message = "Hello, JeroMQ!";
socket.send(message.getBytes(), 0);
socket.close();
context.term();
}
}
import org.zeromq.ZMQ;
public class JeroMQReceiver {
public static void main(String[] args) {
ZMQ.Context context = ZMQ.context(1);
ZMQ.Socket socket = context.socket(ZMQ.PULL);
socket.connect("tcp://localhost:5555");
byte[] message = socket.recv(0);
System.out.println(new String(message));
socket.close();
context.term();
}
}
