Class AbstractWebSocketTransport.AbstractWebSocketScheduler

    • Field Detail

      • _logger

        protected final org.slf4j.Logger _logger
    • Constructor Detail

      • AbstractWebSocketScheduler

        protected AbstractWebSocketScheduler​(BayeuxContext context)
    • Method Detail

      • send

        protected void send​(S wsSession,
                            java.util.List<? extends ServerMessage> messages,
                            int batchSize,
                            org.eclipse.jetty.util.Callback callback)
      • onClose

        public void onClose​(int code,
                            java.lang.String reason)
      • onError

        public void onError​(java.lang.Throwable failure)
      • cancelMetaConnectTask

        protected boolean cancelMetaConnectTask​(ServerSessionImpl session)
      • onMessage

        public void onMessage​(S wsSession,
                              java.lang.String data)
      • close

        protected abstract void close​(int code,
                                      java.lang.String reason)
      • schedule

        protected abstract void schedule​(boolean timeout,
                                         ServerMessage.Mutable expiredConnectReply)
      • schedule

        protected void schedule​(S wsSession,
                                boolean timeout,
                                ServerMessage.Mutable expiredConnectReply)