Class JsonNettyStreamingService

    • Field Detail

      • objectMapper

        protected final com.fasterxml.jackson.databind.ObjectMapper objectMapper
    • Constructor Detail

      • JsonNettyStreamingService

        public JsonNettyStreamingService​(String apiUrl)
      • JsonNettyStreamingService

        public JsonNettyStreamingService​(String apiUrl,
                                         int maxFramePayloadLength)
      • JsonNettyStreamingService

        public JsonNettyStreamingService​(String apiUrl,
                                         int maxFramePayloadLength,
                                         Duration connectionTimeout,
                                         Duration retryDuration,
                                         int idleTimeoutSeconds)
    • Method Detail

      • processArrayMessageSeparately

        public boolean processArrayMessageSeparately()
      • messageHandler

        public void messageHandler​(String message)
        Description copied from class: NettyStreamingService
        Handler that receives incoming messages.
        Specified by:
        messageHandler in class NettyStreamingService<com.fasterxml.jackson.databind.JsonNode>
        Parameters:
        message - Content of the message from the server.
      • sendObjectMessage

        protected void sendObjectMessage​(Object message)