Verbindingen en streams

Deze acties komen in families van twee of drie: verbinden, verzenden, sluiten. De verbinding blijft tussen de vakjes open, waardoor u er andere aanroepen tussendoor kunt weven.

Het gemeenschappelijke patroon

Een verbindingsactie heeft twee uitvoeren:

Uitvoer	Uitzending
connected	Eén signaal, eenmalig, wanneer de verbinding totstandkomt
message	Eén uitzending per ontvangen bericht

De actie draagt een verbindingsnaam (connectionName). De verzend- en sluitacties wijzen die verbinding daarna aan via haar vakje-identificator (connectionNodeId).

Elk bericht verwerken

Een vakje dat op message is aangesloten, wordt standaard maar één keer geactiveerd. Wil u dat het alle berichten verwerkt, zet dan “Bij elk ontvangen event opnieuw spelen” aan in het contextmenu. Zie Poorten en verbindingen.

Het klassieke patroon:

MQTT connect ──connected──► HTTP-verzoek (de functionele actie uitlokken)
      └────────message────► Assert (het verwachte bericht is aangekomen)
                            daarna ──► MQTT-verbinding sluiten

WebSocket

Actie	Invoer	Uitvoer
WebSocket-verbinding	—	connected, message (elk ontvangen frame)
WebSocket send	payload	—
WebSocket-verbinding sluiten	—	—
WebSocket-server sluiten	—	—

Zie WebSocket.

Socket.IO

Actie	Invoer	Uitvoer
Socket.IO-verbinding	—	connected, één poort event:<naam> per opgegeven event, en others
Socket.IO send	channel, payload	—
Socket.IO-verbinding sluiten	—	—
Socket.IO-server sluiten	—	—

Dit is de enige verbindingsactie waarvan u de uitvoeren kunt instellen: geef de lijst met events op die u interesseren en elk event krijgt een eigen poort. Elk event dat u niet hebt opgegeven, komt op others binnen.

Zie Socket.IO.

MQTT

Actie	Invoer	Uitvoer
MQTT connect	—	connected, message
MQTT publish	payload	—
MQTT-verbinding sluiten	—	—

De verbinding abonneert zich op het topic van het verzoek; het verzenden publiceert met de ingestelde QoS en retentie-optie. Zie MQTT.

SSE

Actie	Invoer	Uitvoer
SSE-verbinding	—	connected, message
SSE-verbinding sluiten	—	—

Alleen ontvangend: er is geen verzendactie. Zie SSE.

STOMP

Actie	Invoer	Uitvoer
STOMP-verbinding	—	connected, message
STOMP verzenden	payload	—
STOMP-verbinding sluiten	—	—

De verbinding verstuurt de CONNECT en daarna één SUBSCRIBE per ingesteld abonnement; het verzenden levert een SEND-frame op; het sluiten een DISCONNECT. Zie STOMP.

AMQP

Actie	Invoer	Uitvoer
AMQP-verbinding	—	connected, message
AMQP-publicatie	payload	—
AMQP-verbinding sluiten	—	—

De verbinding consumeert de wachtrij van het verzoek (modus subscribe); de publicatie gebruikt de exchange en de routingsleutel daarvan. Zie AMQP.

Redis

Actie	Invoer	Uitvoer
Redis subscribe	—	connected, message
Redis-verbinding sluiten	—	—

Voor één losse opdracht gebruikt u Redis command, een verzoek-responsactie — zie Verzoeken en samenstelling.

Kafka

Actie	Invoer	Uitvoer
Kafka consume	—	connected, message
Kafka-verbinding sluiten	—	—

Het consumeren abonneert zich via de consumergroep van het verzoek. Om te produceren gebruikt u Kafka produce, een enkelvoudige actie. Zie Kafka.

gRPC met streaming

Actie	Invoer	Uitvoer
gRPC connect	—	connected, message
gRPC send	payload	—
gRPC-verbinding sluiten	—	—

Voor de modi server-stream, client-stream en bidirectional-stream: het verzenden heeft alleen zin voor de laatste twee, en het sluiten voert de half-close aan de clientzijde uit. Een unary-aanroep doet u met HTTP-verzoek. Zie gRPC.

GraphQL-abonnementen

Actie	Invoer	Uitvoer
GraphQL-abonnement	—	connected, message
GraphQL-abonnement opzeggen	—	—

Zie GraphQL.