[java] Avoid using deprecated API

SeleniumHQ · Apr 7, 2019 · 0d07868 · 0d07868
1 parent 7e0e0cc
commit 0d07868
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/java/server/src/org/openqa/selenium/events/zeromq/BoundZmqEventBus.java b/java/server/src/org/openqa/selenium/events/zeromq/BoundZmqEventBus.java
@@ -21,6 +21,7 @@
 import org.openqa.selenium.events.EventBus;
 import org.openqa.selenium.events.Type;
 import org.openqa.selenium.net.NetworkUtils;
+import org.zeromq.SocketType;
 import org.zeromq.ZContext;
 import org.zeromq.ZMQ;
 
@@ -44,11 +45,11 @@ class BoundZmqEventBus implements EventBus {
 
     LOG.info(String.format("XPUB binding to %s, XSUB binding to %s", xpubAddr, xsubAddr));
 
-    xpub = context.createSocket(ZMQ.XPUB);
+    xpub = context.createSocket(SocketType.PUB);
     xpub.setImmediate(true);
     xpub.bind(xpubAddr.bindTo);
 
-    xsub = context.createSocket(ZMQ.XSUB);
+    xsub = context.createSocket(SocketType.XSUB);
     xsub.setImmediate(true);
     xsub.bind(xsubAddr.bindTo);
 

diff --git a/java/server/src/org/openqa/selenium/events/zeromq/UnboundEventBus.java b/java/server/src/org/openqa/selenium/events/zeromq/UnboundEventBus.java
@@ -25,6 +25,7 @@
 import org.openqa.selenium.events.EventBus;
 import org.openqa.selenium.events.Type;
 import org.openqa.selenium.json.Json;
+import org.zeromq.SocketType;
 import org.zeromq.ZContext;
 import org.zeromq.ZMQ;
 
@@ -62,11 +63,11 @@ class UnboundZmqEventBus implements EventBus {
 
     LOG.info(String.format("Connecting to %s and %s", publishConnection, subscribeConnection));
 
-    sub = context.createSocket(ZMQ.SUB);
+    sub = context.createSocket(SocketType.SUB);
     sub.connect(publishConnection);
     sub.subscribe(new byte[0]);
 
-    pub = context.createSocket(ZMQ.PUB);
+    pub = context.createSocket(SocketType.PUB);
     pub.connect(subscribeConnection);
 
     ZMQ.Poller poller = context.createPoller(1);