Aller au contenu
Restorm Documentation Restorm

Connexions et flux

Ces actions vont par familles de deux ou trois : connecter, envoyer, fermer. La connexion reste ouverte entre les boîtes, ce qui permet d’entrelacer d’autres appels au milieu.

Le motif commun

Section titled “Le motif commun”

Une action de connexion a deux sorties :

SortieÉmission
connectedUn signal, une fois, à l’établissement de la connexion
messageUne émission par message reçu

Elle porte un nom de connexion (connectionName). Les actions d’envoi et de fermeture désignent ensuite cette connexion par son identifiant de boîte (connectionNodeId).

Le motif classique :

Connexion MQTT ──connected──► Requête HTTP (déclencher l'action métier)
       └────────message─────► Assert (le message attendu est arrivé)
                              puis ──► Fermeture connexion MQTT

WebSocket

Section titled “WebSocket”
ActionEntréesSorties
Connexion WebSocket—connected, message (toute trame reçue)
Envoi WebSocketpayload—
Fermeture connexion WebSocket——
Fermeture serveur WebSocket——

Voir WebSocket.

Socket.IO

Section titled “Socket.IO”
ActionEntréesSorties
Connexion Socket.IO—connected, un port event:<nom> par événement déclaré, et others
Envoi Socket.IOchannel, payload—
Fermeture connexion Socket.IO——
Fermeture serveur Socket.IO——

C’est la seule action de connexion dont les sorties sont configurables : déclarez la liste des événements qui vous intéressent et chacun obtient son port. Tout événement non déclaré arrive sur others.

Voir Socket.IO.

MQTT

Section titled “MQTT”
ActionEntréesSorties
Connexion MQTT—connected, message
Publication MQTTpayload—
Fermeture connexion MQTT——

La connexion s’abonne au sujet de la requête ; l’envoi publie avec la QoS et l’option de rétention configurées. Voir MQTT.

SSE

Section titled “SSE”
ActionEntréesSorties
Connexion SSE—connected, message
Fermeture connexion SSE——

En réception seule : il n’y a pas d’action d’envoi. Voir SSE.

STOMP

Section titled “STOMP”
ActionEntréesSorties
Connexion STOMP—connected, message
Envoi STOMPpayload—
Fermeture connexion STOMP——

La connexion émet le CONNECT puis un SUBSCRIBE par abonnement configuré ; l’envoi produit une trame SEND ; la fermeture un DISCONNECT. Voir STOMP.

AMQP

Section titled “AMQP”
ActionEntréesSorties
Connexion AMQP—connected, message
Publication AMQPpayload—
Fermeture connexion AMQP——

La connexion consomme la file de la requête (mode subscribe) ; la publication utilise son échange et sa clé de routage. Voir AMQP.

Redis

Section titled “Redis”
ActionEntréesSorties
Abonnement Redis—connected, message
Fermeture connexion Redis——

Pour une commande unitaire, c’est Commande Redis, qui est une action requête / réponse — voir Requêtes et composition.

Kafka

Section titled “Kafka”
ActionEntréesSorties
Consommation Kafka—connected, message
Fermeture connexion Kafka——

La consommation s’abonne via le groupe de consommateurs de la requête. Pour produire, c’est Production Kafka, une action unitaire. Voir Kafka.

gRPC en flux

Section titled “gRPC en flux”
ActionEntréesSorties
Connexion gRPC—connected, message
Envoi gRPCpayload—
Fermeture connexion gRPC——

Pour les modes server-stream, client-stream et bidirectional-stream : l’envoi n’a de sens que pour les deux derniers, la fermeture effectue la demi-fermeture côté client. Un appel unary se fait avec Requête HTTP. Voir gRPC.

Abonnements GraphQL

Section titled “Abonnements GraphQL”
ActionEntréesSorties
Abonnement GraphQL—connected, message
Désabonnement GraphQL——

Voir GraphQL.