ConnectWebSocket

Description:

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.

Tags:

subscribe, WebSocket, consume, listen

Properties:

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:
WebSocketClientService
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.

Relationships:

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

Reads Attributes:

None specified.

Writes Attributes:

NameDescription
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.

Restricted:

This component is not restricted.

Input requirement:

This component does not allow an incoming relationship.