ConnectWebSocket 2.0.0

Bundle
org.apache.nifi | nifi-websocket-processors-nar
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. If a new flowfile is passed to the processor, the previous sessions will be closed and any data being sent will be aborted.
Tags
WebSocket, consume, listen, subscribe
Input Requirement
ALLOWED
Supports Sensitive Dynamic Properties
false
Properties
Relationships
Name Description
success FlowFile holding connection configuration attributes (like URL or HTTP headers) in case of successful connection
text message The WebSocket text message output
binary message The WebSocket binary message output
failure FlowFile holding connection configuration attributes (like URL or HTTP headers) in case of connection failure
connected The WebSocket session is established
Writes Attributes
Name Description
websocket.controller.service.id WebSocket Controller Service id.
websocket.session.id Established WebSocket session id.
websocket.endpoint.id WebSocket endpoint id.
websocket.local.address WebSocket client address.
websocket.remote.address WebSocket server address.
websocket.message.type TEXT or BINARY.