Class ClientTransport

    • Field Detail

      • MAX_NETWORK_DELAY_OPTION

        public static final java.lang.String MAX_NETWORK_DELAY_OPTION
        See Also:
        Constant Field Values
      • JSON_CONTEXT_OPTION

        public static final java.lang.String JSON_CONTEXT_OPTION
        See Also:
        Constant Field Values
      • SCHEDULER_OPTION

        public static final java.lang.String SCHEDULER_OPTION
        See Also:
        Constant Field Values
      • MAX_MESSAGE_SIZE_OPTION

        public static final java.lang.String MAX_MESSAGE_SIZE_OPTION
        See Also:
        Constant Field Values
      • logger

        protected final org.slf4j.Logger logger
    • Constructor Detail

      • ClientTransport

        protected ClientTransport​(java.lang.String name,
                                  java.lang.String url,
                                  java.util.Map<java.lang.String,java.lang.Object> options)
    • Method Detail

      • getURL

        public java.lang.String getURL()
      • setURL

        public void setURL​(java.lang.String url)
      • init

        public void init()
      • abort

        public abstract void abort()
        Aborts this transport, usually by cancelling all pending Bayeux messages that require a response, such as /meta/connects, without waiting for a response.
        See Also:
        BayeuxClient.abort()
      • terminate

        public void terminate()
        Terminates this transport, usually by closing network connections opened directly by this transport.
        See Also:
        BayeuxClient.disconnect()
      • accept

        public abstract boolean accept​(java.lang.String version)
      • parseMessages

        protected java.util.List<Message.Mutable> parseMessages​(java.lang.String content)
                                                         throws java.text.ParseException
        Throws:
        java.text.ParseException
      • generateJSON

        protected java.lang.String generateJSON​(java.util.List<Message.Mutable> messages)
      • getMaxNetworkDelay

        public long getMaxNetworkDelay()
      • setMaxNetworkDelay

        protected void setMaxNetworkDelay​(long maxNetworkDelay)