Připojení a streamy

Tyto akce chodí po rodinách o dvou nebo třech: připojit, odeslat, zavřít. Připojení zůstává mezi bloky otevřené, což umožňuje vkládat mezi ně další volání.

Společný vzor

Připojovací akce má dva výstupy:

Výstup	Vysílání
`connected`	Signál, jednou, při navázání připojení
`message`	Jedno vyslání na každou přijatou zprávu

Nese název připojení (connectionName). Akce odesílání a zavírání pak toto připojení určují jeho identifikátorem bloku (connectionNodeId).

Klasický vzor:

Připojení MQTT ──connected──► Požadavek HTTP (spustit obchodní akci)
       └────────message─────► Assert (očekávaná zpráva dorazila)
                              poté ──► Zavřít připojení MQTT

WebSocket

Akce	Vstupy	Výstupy
Připojení WebSocket	—	`connected`, `message` (každý přijatý rámec)
Odeslání WebSocket	`payload`	—
Zavřít připojení WebSocket	—	—
Zavřít server WebSocket	—	—

Viz WebSocket.

Socket.IO

Akce	Vstupy	Výstupy
Připojení Socket.IO	—	`connected`, jeden port `event:<name>` na každou deklarovanou událost a `others`
Odeslání Socket.IO	`channel`, `payload`	—
Zavřít připojení Socket.IO	—	—
Zavřít server Socket.IO	—	—

Je to jediná připojovací akce, jejíž výstupy jsou nastavitelné: deklarujte seznam událostí, které vás zajímají, a každá z nich dostane svůj port. Každá nedeklarovaná událost přijde na others.

Viz Socket.IO.

MQTT

Akce	Vstupy	Výstupy
Připojení MQTT	—	`connected`, `message`
Publikace MQTT	`payload`	—
Zavřít připojení MQTT	—	—

Připojení se přihlásí k odběru tématu z požadavku; odeslání publikuje s nastavenou QoS a volbou uchování. Viz MQTT.

SSE

Akce	Vstupy	Výstupy
Připojení SSE	—	`connected`, `message`
Zavřít připojení SSE	—	—

Pouze příjem: žádná akce odesílání neexistuje. Viz SSE.

STOMP

Akce	Vstupy	Výstupy
Připojení STOMP	—	`connected`, `message`
Odeslání STOMP	`payload`	—
Zavřít připojení STOMP	—	—

Připojení vyšle CONNECT a poté jeden SUBSCRIBE na každý nastavený odběr; odeslání vytvoří rámec SEND; zavření pak DISCONNECT. Viz STOMP.

AMQP

Akce	Vstupy	Výstupy
Připojení AMQP	—	`connected`, `message`
Publikace AMQP	`payload`	—
Zavřít připojení AMQP	—	—

Připojení konzumuje frontu z požadavku (režim subscribe); publikace používá jeho exchange a směrovací klíč. Viz AMQP.

Redis

Akce	Vstupy	Výstupy
Odběr Redis	—	`connected`, `message`
Zavřít připojení Redis	—	—

Na jediný příkaz slouží Příkaz Redis, což je akce typu požadavek / odpověď — viz Požadavky a jejich skládání.

Kafka

Akce	Vstupy	Výstupy
Konzumace Kafka	—	`connected`, `message`
Zavřít připojení Kafka	—	—

Konzumace se přihlašuje přes skupinu konzumentů z požadavku. K produkci slouží Produkce Kafka, což je jednorázová akce. Viz Kafka.

Streamované gRPC

Akce	Vstupy	Výstupy
Připojení gRPC	—	`connected`, `message`
Odeslání gRPC	`payload`	—
Zavřít připojení gRPC	—	—

Pro režimy server-stream, client-stream a bidirectional-stream: odeslání má smysl jen u posledních dvou, zavření provede poloviční uzavření na straně klienta. Volání unary se provádí blokem Požadavek HTTP. Viz gRPC.

Odběry GraphQL

Akce	Vstupy	Výstupy
Odběr GraphQL	—	`connected`, `message`
Zrušení odběru GraphQL	—	—

Viz GraphQL.