Anslutningar och strömmar

Dessa åtgärder kommer i familjer om två eller tre: anslut, skicka, stäng. Anslutningen förblir öppen mellan boxarna, vilket gör att du kan väva in andra anrop i mitten.

Det gemensamma mönstret

En anslutningsåtgärd har två utgångar:

Utgång	Sändning
connected	En signal, en gång, när anslutningen upprättas
message	En sändning per mottaget meddelande

Den bär ett anslutningsnamn (connectionName). Sänd- och stängåtgärderna pekar sedan ut anslutningen med boxens identifierare (connectionNodeId).

Behandla varje meddelande

En box som är kopplad till message utlöses bara en gång som standard. För att den ska behandla alla meddelanden aktiverar du ”Spela om vid varje mottagen händelse” i dess snabbmeny. Se Portar och kopplingar.

Det klassiska mönstret:

MQTT connect ──connected──► HTTP-begäran (utlös verksamhetsåtgärden)
     └────────message─────► Assert (det förväntade meddelandet har kommit)
                            sedan ──► Stäng MQTT-anslutning

WebSocket

Åtgärd	Ingångar	Utgångar
WebSocket-anslutning	—	connected, message (varje mottagen ram)
WebSocket send	payload	—
Stäng WebSocket-anslutning	—	—
Stäng WebSocket-server	—	—

Se WebSocket.

Socket.IO

Åtgärd	Ingångar	Utgångar
Socket.IO-anslutning	—	connected, en port event:<namn> per deklarerad händelse, och others
Socket.IO send	channel, payload	—
Stäng Socket.IO-anslutning	—	—
Stäng Socket.IO-server	—	—

Det är den enda anslutningsåtgärden vars utgångar är konfigurerbara: deklarera listan över de händelser du är intresserad av, och var och en får sin egen port. Varje odeklarerad händelse hamnar på others.

Se Socket.IO.

MQTT

Åtgärd	Ingångar	Utgångar
MQTT connect	—	connected, message
MQTT publish	payload	—
Stäng MQTT-anslutning	—	—

Anslutningen prenumererar på begärans topic; sändningen publicerar med den QoS och den retain-inställning som konfigurerats. Se MQTT.

SSE

Åtgärd	Ingångar	Utgångar
SSE-anslutning	—	connected, message
Stäng SSE-anslutning	—	—

Bara mottagning: det finns ingen sändåtgärd. Se SSE.

STOMP

Åtgärd	Ingångar	Utgångar
STOMP-anslutning	—	connected, message
STOMP-sändning	payload	—
Stäng STOMP-anslutning	—	—

Anslutningen skickar CONNECT och därefter ett SUBSCRIBE per konfigurerad prenumeration; sändningen producerar en SEND-ram; stängningen en DISCONNECT. Se STOMP.

AMQP

Åtgärd	Ingångar	Utgångar
AMQP-anslutning	—	connected, message
AMQP-publicering	payload	—
Stäng AMQP-anslutning	—	—

Anslutningen konsumerar begärans kö (läget subscribe); publiceringen använder dess exchange och dess routingnyckel. Se AMQP.

Redis

Åtgärd	Ingångar	Utgångar
Redis subscribe	—	connected, message
Stäng Redis-anslutning	—	—

För ett enskilt kommando är det Redis command, som är en begäran/svar-åtgärd — se Begäranden och komposition.

Kafka

Åtgärd	Ingångar	Utgångar
Kafka consume	—	connected, message
Stäng Kafka-anslutning	—	—

Konsumtionen prenumererar via begärans konsumentgrupp. För att producera är det Kafka produce, en enskild åtgärd. Se Kafka.

Strömmande gRPC

Åtgärd	Ingångar	Utgångar
gRPC connect	—	connected, message
gRPC send	payload	—
Stäng gRPC-anslutning	—	—

För lägena server-stream, client-stream och bidirectional-stream: sändningen är bara meningsfull för de två sista, och stängningen utför halvstängningen på klientsidan. Ett unary-anrop gör du med HTTP-begäran. Se gRPC.

GraphQL-prenumerationer

Åtgärd	Ingångar	Utgångar
GraphQL-prenumeration	—	connected, message
Avsluta GraphQL-prenumeration	—	—

Se GraphQL.