[java] Fixing accidentally broken ZMQ socket type
LOG.info(String.format("XPUB binding to %s, XSUB binding to %s", xpubAddr, xsubAddr));
- xpub = context.createSocket(SocketType.PUB);
+ xpub = context.createSocket(SocketType.XPUB);
xpub.setImmediate(true);
xpub.bind(xpubAddr.bindTo);
