Kapcsolatok és folyamok

Ezek a műveletek két-három elemű családokba rendeződnek: kapcsolódás, küldés, bezárás. A kapcsolat nyitva marad a blokkok között, így közben más hívások is beszőhetők.

A közös minta

Egy kapcsolódási műveletnek két kimenete van:

Kimenet	Kibocsátás
connected	Egyetlen jelzés, egyszer, a kapcsolat létrejöttekor
message	Egy kibocsátás minden fogadott üzenetre

A művelethez kapcsolatnév tartozik (connectionName). A küldő és a bezáró műveletek ezután a blokk azonosítójával (connectionNodeId) hivatkoznak erre a kapcsolatra.

Minden üzenet feldolgozása

A message portra kötött blokk alapértelmezés szerint csak egyszer indul el. Ahhoz, hogy minden üzenetet feldolgozzon, be kell kapcsolni az „Újrajátszás minden fogadott eseménynél” lehetőséget a helyi menüjében. Lásd: Portok és társítások.

A klasszikus minta:

MQTT connect ──connected──► HTTP-kérés (az üzleti művelet kiváltása)
       └────────message─────► Assert (megjött a várt üzenet)
                              majd ──► MQTT-kapcsolat bezárása

WebSocket

Művelet	Bemenetek	Kimenetek
WebSocket-kapcsolat	—	connected, message (minden fogadott keret)
WebSocket send	payload	—
WebSocket-kapcsolat bezárása	—	—
WebSocket-kiszolgáló bezárása	—	—

Lásd: WebSocket.

Socket.IO

Művelet	Bemenetek	Kimenetek
Socket.IO-kapcsolat	—	connected, egy event:<name> port minden deklarált eseményhez, valamint others
Socket.IO send	channel, payload	—
Socket.IO-kapcsolat bezárása	—	—
Socket.IO-kiszolgáló bezárása	—	—

Ez az egyetlen kapcsolódási művelet, amelynek a kimenetei beállíthatók: a fontos események listáját deklarálni kell, és mindegyik saját portot kap. A nem deklarált események az others portra érkeznek.

Lásd: Socket.IO.

MQTT

Művelet	Bemenetek	Kimenetek
MQTT connect	—	connected, message
MQTT publish	payload	—
MQTT-kapcsolat bezárása	—	—

A kapcsolódás feliratkozik a kérés témájára (topic); a küldés a beállított QoS és megtartási beállítás szerint tesz közzé. Lásd: MQTT.

SSE

Művelet	Bemenetek	Kimenetek
SSE-kapcsolat	—	connected, message
SSE-kapcsolat bezárása	—	—

Csak fogadásra: nincs küldő művelet. Lásd: SSE.

STOMP

Művelet	Bemenetek	Kimenetek
STOMP kapcsolódás	—	connected, message
STOMP küldés	payload	—
STOMP-kapcsolat bezárása	—	—

A kapcsolódás kiadja a CONNECT üzenetet, majd beállított feliratkozásonként egy SUBSCRIBE üzenetet; a küldés SEND keretet állít elő; a bezárás pedig DISCONNECT üzenetet. Lásd: STOMP.

AMQP

Művelet	Bemenetek	Kimenetek
AMQP-kapcsolat	—	connected, message
AMQP-közzététel	payload	—
AMQP-kapcsolat bezárása	—	—

A kapcsolódás a kérés várólistájáról fogyaszt (subscribe mód); a közzététel a hozzá tartozó exchange-et és útválasztási kulcsot használja. Lásd: AMQP.

Redis

Művelet	Bemenetek	Kimenetek
Redis subscribe	—	connected, message
Redis-kapcsolat bezárása	—	—

Egyetlen parancshoz a Redis command művelet való, amely kérés/válasz típusú — lásd: Kérések és összeállítás.

Kafka

Művelet	Bemenetek	Kimenetek
Kafka consume	—	connected, message
Kafka-kapcsolat bezárása	—	—

A fogyasztás a kérés fogyasztói csoportján keresztül iratkozik fel. Közzétételhez a Kafka produce művelet való, amely egyszeri művelet. Lásd: Kafka.

gRPC folyam módban

Művelet	Bemenetek	Kimenetek
gRPC connect	—	connected, message
gRPC send	payload	—
gRPC-kapcsolat bezárása	—	—

A server-stream, client-stream és bidirectional-stream módokhoz: a küldésnek csak az utóbbi kettő esetén van értelme, a bezárás pedig a kliensoldali félig lezárást (half-close) végzi el. Egy unary hívás a HTTP-kérés művelettel történik. Lásd: gRPC.

GraphQL-feliratkozások

Művelet	Bemenetek	Kimenetek
GraphQL feliratkozás	—	connected, message
GraphQL leiratkozás	—	—

Lásd: GraphQL.