Cette fonction permet de récupérer la valeur des paramètres d'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 |
ALPHA | Cle | Nom du paramètre à récupérer. Les valeurs possibles 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) |
| durable |
Nom du durable |
| 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 max 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 transmet 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 la forme d'une liste de numériques entiers séparée par des virgules. Surcharge le paramètre ackWait. Vous pouvez récupérer la taille de la liste avec la clé backoff[?] et une valeur discrète avec backoff[index]. |
| metadata |
Métadonnées du consommateur. Vous pouvez récupérer le nombre d'éléments avec la clé metadata[?] et la valeur d'une métadonnées metadata['clé']. |
| filterSubjects |
Liste de sujets à filtrer dans le consommateur. Vous pouvez récupérer la taille de la liste avec la clé filterSubjects[?] et une valeur discrète avec filterSubjects[index]. |
|
ALPHA
| Valeur | Valeur du paramètre. Paramètre en sortie. |
NUM_BIN_4 | LgValeur | Taille de la variable valeur |
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
ALPHA(128) Param
ALPHA(128) Buffer
NUM_BIN_4 NombreSujets
/* liste les sujets filtrés par le consommateur
APPELER_DLL 'NatsToolBx' 'NatsQueryConsumer' Handle 'ORDERS' 'Orders' 'filterSubjets[?]' Buffer 128 Rc
NombreSujets = &ALPHA_NUM(Buffer)
I = 1
TANT_QUE i <= NombreSujets
Param = 'filterSubjets[' /// &NUM_ALPHA(I) /// ']'
APPELER_DLL 'NatsToolBx' 'NatsQueryConsumer' Handle 'ORDERS' 'Orders' Param Buffer 128 Rc
...
I = I + 1
REFAIRE
↑ Haut de page
