Class AbstractWebSocketTransport<S>

    • Field Detail

      • MESSAGES_PER_FRAME_OPTION

        public static final java.lang.String MESSAGES_PER_FRAME_OPTION
        See Also:
        Constant Field Values
      • BUFFER_SIZE_OPTION

        public static final java.lang.String BUFFER_SIZE_OPTION
        See Also:
        Constant Field Values
      • IDLE_TIMEOUT_OPTION

        public static final java.lang.String IDLE_TIMEOUT_OPTION
        See Also:
        Constant Field Values
      • COMETD_URL_MAPPING_OPTION

        public static final java.lang.String COMETD_URL_MAPPING_OPTION
        See Also:
        Constant Field Values
      • REQUIRE_HANDSHAKE_PER_CONNECTION_OPTION

        public static final java.lang.String REQUIRE_HANDSHAKE_PER_CONNECTION_OPTION
        See Also:
        Constant Field Values
      • ENABLE_EXTENSION_PREFIX_OPTION

        public static final java.lang.String ENABLE_EXTENSION_PREFIX_OPTION
        See Also:
        Constant Field Values
    • Constructor Detail

      • AbstractWebSocketTransport

        protected AbstractWebSocketTransport​(BayeuxServerImpl bayeux)
    • Method Detail

      • newScheduledExecutor

        protected java.util.concurrent.ScheduledExecutorService newScheduledExecutor()
      • getScheduler

        public java.util.concurrent.ScheduledExecutorService getScheduler()
      • getProtocol

        public java.lang.String getProtocol()
      • getMessagesPerFrame

        public int getMessagesPerFrame()
      • checkProtocol

        protected boolean checkProtocol​(java.util.List<java.lang.String> serverProtocols,
                                        java.util.List<java.lang.String> clientProtocols)
      • getContext

        public BayeuxContext getContext()
        Returns:
        The current transport context or null if no current context
      • normalizeURLMapping

        protected java.util.List<java.lang.String> normalizeURLMapping​(java.lang.String urlMapping)
      • handleJSONParseException

        protected void handleJSONParseException​(S wsSession,
                                                ServerSession session,
                                                java.lang.String json,
                                                java.lang.Throwable exception)
      • handleException

        protected void handleException​(S wsSession,
                                       ServerSession session,
                                       java.lang.Throwable exception)
      • send

        protected abstract void send​(S wsSession,
                                     ServerSession session,
                                     java.lang.String data,
                                     org.eclipse.jetty.util.Callback callback)
      • onClose

        protected void onClose​(int code,
                               java.lang.String reason)