Cette fonction permet de créer un consommateur JetStream.
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 | Stream | Nom du stream. |
ALPHA
| Consommateur | Nom du consommateur (durable). Si ce paramètre n'est pas spécifié, le consommateur créé sera de type éphémère et aura un nom assigné par le système. Paramètre en entrée/sortie. |
ALPHA | Options | Paramètres du consommateur sous la forme d'une liste de couples clé/valeur, séparés par des point-virgules.
Les options acceptées sont :
| description |
Description du consommateur |
| deliverPolicy |
Politique de livraison (all, last, new, by_start_sequence, by_start_time, last_per_subject) |
| ackPolicy |
Politique d'acquittement (none, all, explicit) |
| replayPolicy |
Politique de rediffusion (original, instant) |
| name |
Permet d'affecter un nom au consommateur. Doit être égal à la valeur du paramètre "consumerName" si celle-ci est spécifiée. Nécessite NATS 2.9 ou supérieur. |
| deliverSubject |
Sujet de livraison |
deliverGroup
|
Groupe de livraison |
| sampleFrequency |
Fréquence d'échantillonnage (chaîne) |
| startTime |
Date de démarrage, sous la forme d'un timestamp ISO avec timezone (par exemple : 2007-12-03T10:15Z ou 2007-12-03T11:15+01:00). |
| ackWait |
Délai d'attente en millisecondes des acquittements (0 par défaut) |
| idleHeartbeat |
Délai d'attente en millisecondes du message sur inactivité (0 par défaut) |
| maxExpires |
Temps maximum d'expiration en millisecondes sur une requête "pull" (0 par défaut) |
| inactiveThreshold |
Temps d'attente en millisecondes avant que le consommateur soit considéré inactif (0 par défaut) |
| startSequence |
Numéro de séquence de démarrage du consommateur (0 par défaut) |
| maxDeliver |
Nombre maximum de message livrés au consommateur (0 par défaut) |
| rateLimit |
Limite de débit en bits par seconde (0 par défaut) |
| maxAckPending |
Nombre maximum d'acquittements en attente (0 par défaut) |
| maxPullWaiting |
Nombre maximum de pulls en attente (0 par défaut) |
| maxBatch |
Taille maximale d'un batch pour une requête pull (0 par défaut) |
| maxBytes |
Taille maximale des données (en octets) pour une requête pull (0 par défaut) |
| numReplicas |
Nombre maximum de répliques (0 par défaut) |
| flowControl |
Active le contrôle de flux et définit le délai du battement de cœur d'inactivité (0 par défaut). |
| headersOnly |
Ne transmets que les en-têtes de message. Booléen. Par défaut : false. |
| memStorage |
Force la conservation de l'état du consommateur en mémoire au lieu d'hériter le paramétrage du stream. Booléen. Par défaut : false. |
| backoff |
Liste de délais sous forme d'une liste de numériques entiers séparée par des virgules. Surcharge le paramètre ackWait. |
| metadata |
Métadonnées du consommateur. Liste de couples clé/valeur, séparés par des virgules. |
| filterSubjects |
Liste de sujets à filtrer dans le consommateur |
|
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' 'NatsCreateConsumer' Handle 'ORDERS' 'Orders' 'description: consommation des commandes; durable: Orders; ackPolicy: all' Rc
↑ Haut de page
