Veze i tokovi

Ove akcije dolaze u porodicama od dve ili tri: poveži, pošalji, zatvori. Veza ostaje otvorena između kutija, što omogućava da se u sredinu ubace drugi pozivi.

Zajednički obrazac

Akcija povezivanja ima dva izlaza:

Izlaz	Emisija
connected	Signal, jednom, pri uspostavljanju veze
message	Po jedna emisija za svaku primljenu poruku

Ona nosi naziv veze (connectionName). Akcije slanja i zatvaranja zatim označavaju tu vezu njenim identifikatorom kutije (connectionNodeId).

Obrada svake poruke

Kutija povezana na message podrazumevano se aktivira samo jednom. Da bi obrađivala sve poruke, uključite „Odigraj ponovo pri svakom primljenom događaju” u njenom kontekstnom meniju. Vidite Portovi i veze.

Klasičan obrazac:

MQTT konekcija ──connected──► HTTP zahtev (pokreni poslovnu akciju)
       └────────message─────► Assert (očekivana poruka je stigla)
                              pa ──► Zatvaranje MQTT veze

WebSocket

Akcija	Ulazi	Izlazi
WebSocket konekcija	—	connected, message (svaki primljeni okvir)
WebSocket slanje	payload	—
Zatvaranje WebSocket veze	—	—
Zatvaranje WebSocket servera	—	—

Vidite WebSocket.

Socket.IO

Akcija	Ulazi	Izlazi
Socket.IO konekcija	—	connected, po jedan port event:<ime> za svaki deklarisani događaj i others
Socket.IO slanje	channel, payload	—
Zatvaranje Socket.IO veze	—	—
Zatvaranje Socket.IO servera	—	—

To je jedina akcija povezivanja čiji su izlazi podesivi: deklarišite listu događaja koji vas zanimaju i svaki dobija svoj port. Svaki nedeklarisani događaj stiže na others.

Vidite Socket.IO.

MQTT

Akcija	Ulazi	Izlazi
MQTT konekcija	—	connected, message
MQTT objavljivanje	payload	—
Zatvaranje MQTT veze	—	—

Veza se pretplaćuje na temu zahteva; slanje objavljuje sa podešenim QoS-om i opcijom zadržavanja. Vidite MQTT.

SSE

Akcija	Ulazi	Izlazi
SSE konekcija	—	connected, message
Zatvaranje SSE veze	—	—

Samo za prijem: nema akcije slanja. Vidite SSE.

STOMP

Akcija	Ulazi	Izlazi
STOMP konekcija	—	connected, message
STOMP slanje	payload	—
Zatvaranje STOMP veze	—	—

Veza šalje CONNECT, pa po jedan SUBSCRIBE za svaku podešenu pretplatu; slanje proizvodi okvir SEND; zatvaranje šalje DISCONNECT. Vidite STOMP.

AMQP

Akcija	Ulazi	Izlazi
AMQP konekcija	—	connected, message
AMQP objavljivanje	payload	—
Zatvaranje AMQP veze	—	—

Veza troši red iz zahteva (režim subscribe); objavljivanje koristi njegovu razmenu i njegov ključ rutiranja. Vidite AMQP.

Redis

Akcija	Ulazi	Izlazi
Redis pretplata	—	connected, message
Zatvaranje Redis veze	—	—

Za pojedinačnu komandu tu je Redis komanda, koja je akcija zahtev / odgovor — vidite Zahtevi i kompozicija.

Kafka

Akcija	Ulazi	Izlazi
Kafka potrošnja	—	connected, message
Zatvaranje Kafka veze	—	—

Potrošnja se pretplaćuje preko grupe potrošača iz zahteva. Za proizvodnju tu je Kafka proizvodnja, pojedinačna akcija. Vidite Kafka.

gRPC u tokovnom režimu

Akcija	Ulazi	Izlazi
gRPC konekcija	—	connected, message
gRPC slanje	payload	—
Zatvaranje gRPC veze	—	—

Za režime server-stream, client-stream i bidirectional-stream: slanje ima smisla samo za poslednja dva, a zatvaranje izvodi polu-zatvaranje na strani klijenta. unary poziv izvodi se pomoću HTTP zahteva. Vidite gRPC.

GraphQL pretplate

Akcija	Ulazi	Izlazi
GraphQL pretplata	—	connected, message
Otkazivanje GraphQL pretplate	—	—

Vidite GraphQL.