Tilkoblinger og strømmer

Disse handlingene kommer i familier på to eller tre: koble til, sende, lukke. Tilkoblingen blir stående åpen mellom boksene, slik at du kan flette inn andre kall underveis.

Det felles mønsteret

En tilkoblingshandling har to utganger:

Utgang	Sending
connected	Ett signal, én gang, når tilkoblingen er opprettet
message	Én sending per mottatt melding

Den bærer et tilkoblingsnavn (connectionName). Sende- og lukkehandlingene peker deretter på denne tilkoblingen via boks-ID-en (connectionNodeId).

Behandle hver melding

En boks som er koblet til message, utløses bare én gang som standard. For at den skal behandle alle meldingene, slår du på «Kjør ved hver mottatt hendelse» i kontekstmenyen. Se Porter og forbindelser.

Det klassiske mønsteret:

MQTT connect ──connected──► HTTP-forespørsel (utløs forretningshandlingen)
      └────────message─────► Assert (den forventede meldingen kom)
                             deretter ──► Lukk MQTT-tilkobling

WebSocket

Handling	Inndata	Utdata
WebSocket-tilkobling	—	connected, message (enhver mottatt ramme)
WebSocket send	payload	—
Lukk WebSocket-tilkobling	—	—
Lukk WebSocket-server	—	—

Se WebSocket.

Socket.IO

Handling	Inndata	Utdata
Socket.IO-tilkobling	—	connected, én event:<navn>-port per deklarert hendelse, og others
Socket.IO send	channel, payload	—
Lukk Socket.IO-tilkobling	—	—
Lukk Socket.IO-server	—	—

Dette er den eneste tilkoblingshandlingen der utgangene er konfigurerbare: deklarer listen over hendelsene du er interessert i, og hver av dem får sin egen port. Enhver hendelse som ikke er deklarert, kommer inn på others.

Se Socket.IO.

MQTT

Handling	Inndata	Utdata
MQTT connect	—	connected, message
MQTT publish	payload	—
Lukk MQTT-tilkobling	—	—

Tilkoblingen abonnerer på emnet i forespørselen; sendingen publiserer med den QoS-en og den retensjonsinnstillingen som er konfigurert. Se MQTT.

SSE

Handling	Inndata	Utdata
SSE-tilkobling	—	connected, message
Lukk SSE-tilkobling	—	—

Kun mottak: det finnes ingen sendehandling. Se SSE.

STOMP

Handling	Inndata	Utdata
STOMP-tilkobling	—	connected, message
STOMP-sending	payload	—
Lukk STOMP-tilkobling	—	—

Tilkoblingen sender CONNECT og deretter én SUBSCRIBE per konfigurert abonnement; sendingen produserer en SEND-ramme; lukkingen en DISCONNECT. Se STOMP.

AMQP

Handling	Inndata	Utdata
AMQP-tilkobling	—	connected, message
AMQP-publisering	payload	—
Lukk AMQP-tilkobling	—	—

Tilkoblingen konsumerer køen i forespørselen (modusen subscribe); publiseringen bruker exchange og routing key fra den. Se AMQP.

Redis

Handling	Inndata	Utdata
Redis subscribe	—	connected, message
Lukk Redis-tilkobling	—	—

For én enkelt kommando er det Redis command, som er en forespørsel/svar-handling — se Forespørsler og komposisjon.

Kafka

Handling	Inndata	Utdata
Kafka consume	—	connected, message
Lukk Kafka-tilkobling	—	—

Konsumeringen abonnerer via forbrukergruppen i forespørselen. For å produsere er det Kafka produce, en enkeltstående handling. Se Kafka.

gRPC som strøm

Handling	Inndata	Utdata
gRPC connect	—	connected, message
gRPC send	payload	—
Lukk gRPC-tilkobling	—	—

For modusene server-stream, client-stream og bidirectional-stream: sendingen gir bare mening for de to siste, og lukkingen utfører halvlukkingen på klientsiden. Et unary-kall gjøres med HTTP-forespørsel. Se gRPC.

GraphQL-abonnementer

Handling	Inndata	Utdata
GraphQL-abonnement	—	connected, message
Si opp GraphQL-abonnement	—	—

Se GraphQL.