Zoom Logo

EdgeX: Applications WG meeting - Shared screen with speaker view
Jim White
31:24
here is what we did in rules engine: https://github.com/edgexfoundry/support-rulesengine/blob/master/src/main/java/org/edgexfoundry/messaging/ZeroMQEventSubscriber.java
Unknown Speaker
00:31:52 Jim White:private ZMQ.Socket getSubscriber() {if (subscriber == null) {try {subscriber = context.socket(SocketType.SUB);subscriber.connect(zeromqAddress + ":" + zeromqAddressPort);subscriber.subscribe("".getBytes());} catch (Exception e) {logger.error("Unable to get a ZMQ subscriber. Error: " + e);subscriber = null;}}return subscriber;}