Acts as a WebSocket client endpoint to interact with a remote WebSocket server. FlowFiles are transferred to downstream relationships according to received message types as WebSocket client configured with this processor receives messages from remote WebSocket server.


subscribe, WebSocket, consume, listen


In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.

NameDefault ValueAllowable ValuesDescription
WebSocket Client ControllerServiceController Service API:
Implementation: JettyWebSocketClient
A WebSocket CLIENT Controller Service which can connect to a WebSocket server.
WebSocket Client IdThe client ID to identify WebSocket session. It should be unique within the WebSocket Client Controller Service. Otherwise, it throws WebSocketConfigurationException when it gets started.


text messageThe WebSocket text message output
binary messageThe WebSocket binary message output
connectedThe WebSocket session is established

Reads Attributes:

None specified.

Writes Attributes:

websocket.controller.service.idWebSocket Controller Service id.
websocket.session.idEstablished WebSocket session id.
websocket.endpoint.idWebSocket endpoint id.
websocket.local.addressWebSocket client address.
websocket.remote.addressWebSocket server address.
websocket.message.typeTEXT or BINARY.

State management:

This component does not store state.


This component is not restricted.

Input requirement:

This component does not allow an incoming relationship.

System Resource Considerations:

None specified.