Veze i tokovi

Ove akcije dolaze u obiteljima po dvije ili tri: spoji, pošalji, zatvori. Veza ostaje otvorena između kutija, što omogućuje da se u sredinu umetnu drugi pozivi.

Zajednički obrazac

Akcija povezivanja ima dva izlaza:

Izlaz	Emitiranje
connected	Signal, jednom, pri uspostavi veze
message	Po jedna emisija za svaku primljenu poruku

Nosi naziv veze (connectionName). Akcije slanja i zatvaranja tu vezu zatim označavaju identifikatorom njezine kutije (connectionNodeId).

Obrada svake poruke

Kutija priključena na message prema zadanome se okida samo jednom. Da bi obradila sve poruke, u njezinu kontekstnom izborniku uključite „Ponovi pri svakom primljenom događaju”. Pogledajte Portove i veze.

Klasičan obrazac:

MQTT veza ──connected──► HTTP zahtjev (pokreni poslovnu radnju)
     └──────message────► Assert (očekivana poruka je stigla)
                         zatim ──► Zatvaranje MQTT veze

WebSocket

Akcija	Ulazi	Izlazi
WebSocket veza	—	connected, message (svaki primljeni okvir)
WebSocket slanje	payload	—
Zatvaranje WebSocket veze	—	—
Zatvaranje WebSocket poslužitelja	—	—

Pogledajte WebSocket.

Socket.IO

Akcija	Ulazi	Izlazi
Socket.IO veza	—	connected, po jedan port event:<name> za svaki deklarirani događaj i others
Socket.IO slanje	channel, payload	—
Zatvaranje Socket.IO veze	—	—
Zatvaranje Socket.IO poslužitelja	—	—

To je jedina akcija povezivanja čiji su izlazi podesivi: deklarirate popis događaja koji vas zanimaju i svaki dobiva svoj port. Svaki nedeklarirani događaj stiže na others.

Pogledajte Socket.IO.

MQTT

Akcija	Ulazi	Izlazi
MQTT veza	—	connected, message
MQTT objava	payload	—
Zatvaranje MQTT veze	—	—

Veza se pretplaćuje na temu zahtjeva; slanje objavljuje s podešenim QoS-om i opcijom zadržavanja. Pogledajte MQTT.

SSE

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

Samo za primanje: nema akcije slanja. Pogledajte SSE.

STOMP

Akcija	Ulazi	Izlazi
STOMP veza	—	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 DISCONNECT. Pogledajte STOMP.

AMQP

Akcija	Ulazi	Izlazi
AMQP veza	—	connected, message
AMQP objava	payload	—
Zatvaranje AMQP veze	—	—

Veza troši red iz zahtjeva (način subscribe); objava koristi njegovu razmjenu i njegov ključ usmjeravanja. Pogledajte AMQP.

Redis

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

Za pojedinačnu naredbu tu je Redis naredba, koja je akcija zahtjev / odgovor — pogledajte Zahtjeve i kompoziciju.

Kafka

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

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

gRPC u toku

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

Za načine server-stream, client-stream i bidirectional-stream: slanje ima smisla samo za posljednja dva, a zatvaranje obavlja polu-zatvaranje na strani klijenta. Unarni poziv (unary) izvodi se kutijom HTTP zahtjev. Pogledajte gRPC.

GraphQL pretplate

Akcija	Ulazi	Izlazi
Pretplati se GraphQL	—	connected, message
Odjavi pretplatu GraphQL	—	—

Pogledajte GraphQL.