Cette fonction permet de modifier la configuration 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
| Options | Liste d'options de configuration du flux, sous la forme d'une liste de couples clé/valeur, séparés par des point-virgules.
Veuillez vous référencer à la documentation NATS pour une explication précise des options de configuration.
Les options acceptées sont :
description
|
Description du flux |
sealed |
Permet de verrouiller le flux qui ne pourra plus recevoir de messages. Booléen. |
compressionOption |
Option de compression (none, s2) |
discardPolicy |
Politique d'abandon (new, old) |
maxMsgs |
Nombre maximum de messages. Non renseigné par défaut (-1). |
maxMsgsPerSubject |
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ée par défaut. |
republish |
Configuration de la republication sous la forme d'une liste de couples clé/valeur, séparés par des virgules.
source |
Sujet source |
destination |
Sujet destination |
headersOnly |
Réplique uniquement les en-têtes |
|
|
|
subjectTransform |
Transformation de sujets sous la forme d'un couples clé/valeur. La clé est le nom du sujet source, la valeur le nom du sujet destination. |
consumerLimits |
Liste de transformation de sujets sous la forme d'une liste de couples clé/valeur, séparés par des virgules.
inactiveThreshold |
Temps au bout duquel le consommateur est considéré comme inactif (en millisecondes) |
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. |
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. Liste de couples clé/valeur, séparés par des virgules. |
|
ALPHA | Miroir | Description d'une source miroir sous la forme d'une liste de couples clé/valeur, séparés par des virgules. Ce paramètre ne peut pas être spécifié en même temps que le paramètre Sources, ou si le stream a des sources configurées.
Les options acceptées sont :
name |
Nom du stream source |
startSeq |
Numéro de séquence de démarrage |
startTime |
Heure de démarrage |
filterSubject |
Sujet à filtrer |
external |
Définition d'un external sous la forme d'une liste de couples clé/valeur, séparés par des virgules. Ce paramètre ne peut pas être spécifié en même temps que le paramètre domain.
api |
Préfixe API |
deliver |
Sujet deliver |
|
|
|
|
ALPHA[n]
| Sources | Tableau de définition des sources du flux. La description d'une source est identique au paramètre Miroir. Ce paramètre ne peut pas être spécifié en même temps que le paramètre Miroir, ou si le stream a un miroir configuré. |
NUM_BIN_4 | LongueurSource | Taille d'un élément du tableau des sources. |
NUM_BIN_4
| NombreSources | Nombre d'éléments à prendre en compte dans le tableau Sources. |
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' 'NatsUpdateStream' Handle 'ORDERS' 'subjects: order.*,custom_orders.*' *BLANK sources 250 0 Rc
↑ Haut de page