NatsSubscribe

Cette fonction permet de créer une souscription à un sujet NATS. La consommation des messages se fera obligatoirement de façon synchrone.

Seule la souscription à un consommateur JetStream est possible dans le cas de la toolbox NATS. La consommation synchrone de messages NATS core n'est pas possible, vous devez vous tourner vers l'objet graphique NATS dans ce cas de figure.

Domaine d'application

Client Windows
Serveur Windows
Client Java
Serveur Java
Client Adélia Web
Client Adélia Cloud
Client Event Adélia

Paramètres

NUM_BIN_4

Handle

Identifiant de la connexion

ALPHA

Sujet

Sujet NATS

NUM_BIN_4

TypeSouscription

Type de la souscription

_NATS_CONS_TYPE_PUSH	Consommateur JetStream PUSH
_NATS_CONS_TYPE_PULL	Consommateur JetStream PULL

ALPHA

Options

Liste d'options pour les souscripteurs JetStream, sous la forme d'une liste de couples clé/valeur, séparés par des point-virgules.

Les options acceptées sont :

name	Nom du consommateur
stream	Nom du stream NATS
durable	Nom du durable du consommateur
bind	Lié à un consommateur existant (name doit référencer le nom du consommateur). Ignoré en version Windows.
messageAlarmTime	Temps d'attente entre deux messages ou battements de cœur avant de déclencher une erreur. Non supporté en version Windows.
ordered	Délivrance ordonnée des messages (PUSH uniquement)
deliverSubject	Sujet destinataire (PUSH uniquement)
deliverGroup	Groupe destinataire (PUSH uniquement). Doit correspondre au paramètre "queue" si les deux sont spécifiés.
pendingMessageLimit	Nombre maximum de messages en attente (PUSH uniquement). Non supporté en version Windows.
pendingByteLimit	Taille maximum des messages en attente (PUSH uniquement). Non supporté en version Windows.
queue	Queue à utiliser (PUSH uniquement)
fastBind	Liaison rapide. La concordance des paramètres du consommateur n'est pas validée (PULL uniquement). Ignoré en version Windows.

NUM_BIN_4

Rc

Code retour de la fonction. Les valeurs possibles sont indiquées dans la documentation de la fonction NatsLastError. Paramètre en sortie.

Par exemple

APPELER_DLL 'NatsToolBx' 'NatsSubscrible' Handle 'orders.france' 'durable: Orders' Rc

↑ Haut de page