Cette fonction permet de récupérer la valeur des paramètres d'un stream (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
| Cle | Nom du paramètre à récupérer. Les valeurs possibles sont :
description
|
Description du flux |
| retentionPolicy |
Politique de rétention (limits, interest, workqueue) |
| compressionOption |
Option de compression (none, s2) |
| storageType |
Type de stockage (file, memory) |
| discardPolicy |
Politique d'abandon (new, old) |
| maxConsumers |
Nombre maximum de consommateurs associés. Non renseigné par défaut (-1). |
| maxMessages |
Nombre maximum de messages. Non renseigné par défaut (-1). |
| maxMessagesPerSubject |
Nombre maximum de messages par sujet. Non renseigné par défaut (-1). |
| maxBytes |
Taille maximale du flux. Non renseigné par défaut (-1). |
| maxAge |
Durée de vie maximum d'un message en millisecondes. Non renseigné par défaut (0). |
| maxMsgSize |
Taille maximum d'un message. Non renseigné par défaut (-1). |
| replicas |
Nombre de répliques stockées (de 1 à 5) |
| noAck |
Désactivation des acquittements du client. Booléen. Par défaut : false. |
| duplicateWindow |
Fenêtre de vérification des doublons en millisecondes. Désactivé par défaut (0). |
| subjects |
Liste des sujets du flux, séparés par une virgule |
| placement |
Directive de placement. Liste de valeurs séparées par des virgules, constituée d'un nom de cluster suivi d'une liste d'étiquettes. Non renseigné par défaut. |
| republish.source |
Source de la republication |
| republish.destination |
Destination de la republication |
republish.headersOnly
|
Republication des headers uniquement |
| subjectTransform |
Liste de transformation de sujets Vous pouvez récupérer la taille de la liste avec la clé subjectTransform [?] et une valeur discrète avec subjectTransform [index] |
| consumerLimits.inactiveThreshold |
Temps au bout duquel le consommateur est considéré comme inactif (en millisecondes) |
| consumerLimits.maxAckPending |
Nombre maximum d'acquittements en attente |
| allowRollup |
Autorise le cumul. Booléen, false par défaut. |
| allowDirect |
Autorise l'accès direct. Booléen, false par défaut. |
| mirrorDirect |
Autorise l'accès direct pour les miroirs. Booléen, false par défaut. |
| denyDelete |
Empêche la suppression des messages. Booléen, false par défaut. |
| denyPurge |
Empêche la purge des messages du stream. Booléen, false par défaut. |
| discardNewPerSubject |
Définit si le paramètre discardPolicy "new" s'applique à tous les sujets. Par défaut, il s'applique uniquement aux nouveaux sujets. Booléen, false par défaut. |
| metaData |
Métadonnées du stream. Vous pouvez récupérer le nombre d'éléments avec la clé metadata [?] et la valeur d'une métadonnées metadata ['clé']. |
| firstSequence |
Numéro de séquence du premier message. Entier positif. Par défaut : 1. |
mirror.name
|
Nom du stream source |
mirror.startSeq
|
Numéro de séquence de démarrage |
mirror.startTime
|
Heure de démarrage |
mirror.filterSubject
|
Sujet à filtrer |
mirror.external.api
|
Préfixe API |
mirror.external.deliver
|
Sujet deliver |
sources[?]
|
Nombre de sources |
| sources[index].name |
Nom du stream source |
sources[index].startSeq
|
Numéro de séquence de démarrage |
sources[index].startTime
|
Heure de démarrage |
sources[index].filterSubject
|
Sujet à filtrer |
sources[index].external.api
|
Préfixe API |
sources[index].external.deliver
|
Sujet deliver |
|
ALPHA | Valeur | Valeur du paramètre. Paramètre en sortie. |
NUM_BIN_4
| LgValeur | Longueur du paramètre 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 NombreSources
/* liste les sources du stream
APPELER_DLL 'NatsToolBx' 'NatsQueryStream' Handle 'ORDERS' 'Sources[?]' Buffer 128 Rc
NombreSources= &ALPHA_NUM(Buffer)
I = 1
TANT_QUE i <= NombreSources
Param = 'Sources[' /// &NUM_ALPHA(I) /// '].name'
APPELER_DLL 'NatsToolBx' 'NatsQueryStream' Handle 'ORDERS' Param Buffer 128 Rc
...
I = I + 1
REFAIRE
↑ Haut de page
