Skip to main content

JettyWebSocketClient

Description

Implementation of WebSocketClientService. This service uses Jetty WebSocket client module to provide WebSocket session management throughout the application.

Tags

Jetty, WebSocket, client

Properties

In the list below required Properties are shown with an asterisk (*). Other properties are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
Input Buffer Size *input-buffer-size4 kbThe size of the input (read from network layer) buffer size.
Max Text Message Size *max-text-message-size64 kbThe maximum size of a text message during parsing/generating.
Max Binary Message Size *max-binary-message-size64 kbThe maximum size of a binary message during parsing/generating.
WebSocket URI *websocket-uriThe WebSocket URI this client connects to.

Supports Expression Language, using FlowFile attributes and Environment variables.
SSL Context Servicessl-context-serviceController Service:
RestrictedSSLContextService

Implementations:
StandardRestrictedSSLContextService
The SSL Context Service to use in order to secure the server. If specified, the server will accept only WSS requests; otherwise, the server will accept only WS requests
Connection Timeout *connection-timeout3 secThe timeout to connect the WebSocket URI.

Supports Expression Language, using Environment variables.
Connection Attempt Count *connection-attempt-timeout3The number of times to try and establish a connection.

Supports Expression Language, using Environment variables.
Session Maintenance Interval *session-maintenance-interval10 secThe interval between session maintenance activities. A WebSocket session established with a WebSocket server can be terminated due to different reasons including restarting the WebSocket server or timing out inactive sessions. This session maintenance activity is periodically executed in order to reconnect those lost sessions, so that a WebSocket client can reuse the same session id transparently after it reconnects successfully. The maintenance activity is executed until corresponding processors or this controller service is stopped.

Supports Expression Language, using Environment variables.
User Nameuser-nameThe user name for Basic Authentication.

Supports Expression Language, using Environment variables.
User Passworduser-passwordThe user password for Basic Authentication.

Supports Expression Language, using Environment variables.
Authentication Header Charset *authentication-charsetUS-ASCIIThe charset for Basic Authentication header base64 string.

Supports Expression Language, using Environment variables.
Custom Authorizationcustom-authorizationConfigures a custom HTTP Authorization Header as described in RFC 7235 Section 4.2. Setting a custom Authorization Header excludes configuring the User Name and User Password properties for Basic Authentication.

Supports Expression Language, using Environment variables.
HTTP Proxy Hostproxy-hostThe host name of the HTTP Proxy.

Supports Expression Language, using Environment variables.
HTTP Proxy Portproxy-portThe port number of the HTTP Proxy.

Supports Expression Language, using Environment variables.

State Management

This component does not store state.

Restricted

This component is not restricted.

System Resource Considerations

This component does not specify system resource considerations.

See Also