diff --git a/pom.xml b/pom.xml
index c3b127a..5f15d66 100644
--- a/pom.xml
+++ b/pom.xml
@@ -3,7 +3,7 @@
 
     <groupId>com.cdptech</groupId>
     <artifactId>cdpclient</artifactId>
-    <version>1.0.2</version>
+    <version>1.0.3</version>
     <packaging>jar</packaging>
 
     <name>${project.groupId}:${project.artifactId}</name>
@@ -105,7 +105,7 @@
         <dependency>
             <groupId>org.java-websocket</groupId>
             <artifactId>Java-WebSocket</artifactId>
-            <version>1.3.0</version>
+            <version>1.5.0</version>
         </dependency>
         <dependency>
             <groupId>junit</groupId>
diff --git a/src/main/java/com/cdptech/cdpclient/RequestDispatch.java b/src/main/java/com/cdptech/cdpclient/RequestDispatch.java
index 83fab15..969c5ce 100644
--- a/src/main/java/com/cdptech/cdpclient/RequestDispatch.java
+++ b/src/main/java/com/cdptech/cdpclient/RequestDispatch.java
@@ -310,7 +310,7 @@ private boolean addExistingAppNode(Node receivedAppNode) {
   private void interceptNode(Node node) {
     for (Request req : new ArrayList<Request>(pendingRequests))
       req.offer(node);
-    pendingRequests.removeIf(req -> req.getStatus() == Status.RESOLVED);
+    pendingRequests.removeIf(req -> req.getStatus() != Status.PENDING);
   }
   
   /** Find a node from this connection's cache. */
diff --git a/src/main/java/com/cdptech/cdpclient/Transport.java b/src/main/java/com/cdptech/cdpclient/Transport.java
index 2b7de53..f33b72a 100644
--- a/src/main/java/com/cdptech/cdpclient/Transport.java
+++ b/src/main/java/com/cdptech/cdpclient/Transport.java
@@ -26,7 +26,7 @@ enum State {
   
   /** Create a transport with an URI and received data queue. */
   Transport(URI serverURI, BlockingQueue<byte[]> queue) {
-    super(serverURI, new org.java_websocket.drafts.Draft_17());
+    super(serverURI);
     this.queue = queue;
     this.state = State.IDLE;
   }