Shapes

Start a flow

Live stream

Subscribes to a queue, topic or stream and runs the flow for each message as it arrives.

Nodes › TriggersOpen in Neblex
Good for
Continuous, real-time event processing
Role
Starts a flow
Find it in
Nodes › Triggers

When to use it

  • Events flow through Kafka, Azure Event Hubs, AWS Kinesis, AWS SQS, Redis Streams, WebSocket or Server-Sent Events.
  • You need Salesforce Change Data Capture in real time.
  • Each event should be handled as soon as it arrives.

Reach for something else when

Example

Each Kafka message carries a sensor reading. Readings outside their limits raise an alert in Microsoft Teams.

  1. Live stream
  2. Filter
  3. Microsoft Teams

How it works

Starts a run for each message on a persistent subscription. See Streaming triggers for every source and its settings.

More in the guide

Add it to a flow

  1. Open the flow from Build › Workflows.
  2. Open Nodes and find Live stream under Triggers. Drag it onto the canvas as the first step.
  3. Connect it to the next step and open its settings with ✎ Edit.
  4. Save and test with Run, then set the flow Active so it starts on its own.