Cette fonction permet de créer 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érer à la documentation NATS pour une explication précise des options de configuration.
Les options acceptées 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). |
| 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é par défaut. |
| republish |
Configuration de la republication. 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 |
Liste de transformation de sujets. Liste de couples clé/valeur, séparés par des virgules. 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. |
| 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. Liste de couples clé/valeur, séparés par des virgules. |
| firstSequence |
Numéro de séquence du premier message. Entier positif, par défaut : 1. |
|
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.
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. |
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
ALPHA(250) mirror
ALPHA(250) sources(2)
...
APPELER_DLL 'NatsToolBx' 'NatsCreateStream' Handle 'ORDERS' 'description: Stream des commandes; subjects: order.*' *BLANK sources 250 0 Rc
APPELER_DLL 'NatsToolBx' 'NatsCreateStream' Handle 'RETURNS' 'description: Stream des retours; subjects: return.*' *BLANK sources 250 0 Rc
...
sources(1) = 'name:ORDERS'
sources(2) = 'name:RETURNS'
APPELER_DLL 'NatsToolBx' 'NatsCreateStream' Handle 'ARCHIVES' 'description: Archive des commandes' *BLANK sources 250 2 Rc
...
mirror = 'name:ARCHIVES'
APPELER_DLL 'NatsToolBx' 'NatsCreateStream' Handle 'REPORT' 'description: Reporting' mirror sources 250 0 Rc
↑ Haut de page
