Comments (0)

Files changed (3)

File xmpp-server/src/main/java/rocks/xmpp/extensions/httpbind/server/BoshConnection.java Modified

View file
  • Ignore whitespace
  • Hide word diff
         // and send any future response to the latest request.
         final Optional<BodyRequest> pendingRequest = requests.stream().filter(r -> r.body.getRid().equals(body.getRid())).findAny();
         pendingRequest.ifPresent(bodyRequest -> bodyRequest.resume(Body.builder().type(Body.Type.ERROR).build()));
-
+                                      
         // Upon reception of a session pause request,
         // if the requested period is not greater than the maximum permitted time,
         // then the connection manager SHOULD respond immediately to all pending requests
     }
 
     @Override
-    public final void restart() {
-    }
-
-    @Override
     public final void write(final StreamElement streamElement) {
         deliverables.add(streamElement);
     }

File xmpp-server/src/main/java/rocks/xmpp/server/Connection.java Modified

View file
  • Ignore whitespace
  • Hide word diff
 
     public abstract void open(SessionOpen sessionOpen);
 
-    public abstract void restart();
+    public void restart() {
+    }
 
     public abstract void write(StreamElement streamElement);
 

File xmpp-server/src/main/java/rocks/xmpp/websocket/server/WebSocketConnection.java Modified

View file
  • Ignore whitespace
  • Hide word diff
     }
 
     @Override
-    public final void restart() {
-    }
-
-    @Override
     public final void write(final StreamElement streamElement) {
         if (session.isOpen()) {
             session.getAsyncRemote().sendObject(streamElement);
     @Override
     public final void close() throws Exception {
         writeAndFlush(new Close());
-        try {
-            session.close();
-        } catch (IOException e) {
-            throw new UncheckedIOException(e);
-        }
+        session.close();
     }
 }