Téléchargement des produits


Version anglaise


 

      


      


EADELIA





(B) (C)

Paragraphe d'utilisation

onStart / onStop / onError / onMessage

Syntaxe

BRK_RECUP_CONF NomPropriété <variable résultat>

NomPropriété

ValeurSpéciale | NomPropriétéAlpha

ValeurSpéciale

*BRK_NOM | *BRK_PROTOCOL | *BRK_VERSION | *BRK_IMPL

Description

Cet ordre permet de récupérer des informations sur le contexte d'exécution du souscripteur Adélia. Chaque information est définie par une clé (le paramètre NomPropriété) et a une valeur associée (le paramètre variable résultat) typée.

La clé peut être définie soit par une valeur spéciale, soit dans le cas de NomPropriétéAlpha par une variable alphanumérique, une constante alphanumérique ou un littéral alphanumérique.


Clé valeur spéciale
Valeur SpécialeDescription de la propriétéType de la propriété
*BRK_NOMNom du courtier de message auquel le souscripteur est connectéALPHA(n)
*BRK_PROTOCOLNom du protocole utilisé pour l'échange de messages entre le courtier et le souscripteurALPHA(n)
*BRK_VERSIONVersion du protocole utilisé pour l'échange de messages entre le courtier et le souscripteurALPHA(n)
*BRK_IMPLIdentifiant d'implémentation du souscripteur natif assurant la communication entre le courtier et le souscripteur AdéliaALPHA(n)


En fonction du courtier de message ciblé, ces valeurs spéciales ont les valeurs suivantes :

Courtier*BRK_NOM*BRK_PROTOCOL*BRK_VERSION*BRK_IMPL
KafkaKAFKAKAFKA2.8.0org.apache.kafka:kafka-clients:2.8.0
MQTT v3MQTT_BROKERMQTT3.1.1org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5
MQTT v5MQTT_BROKERMQTT5org.eclipse.paho:org.eclipse.paho.mqttv5.client:1.2.5
Nats JetsteamNATS JETSTREAMNATS JETSTREAM2.10.4io.nats:jnats:2.17.1
RabbitMQ AMQPRABBITMQAMQP0.9.1com.rabbitmq:amqp-client:5.7.3
Redis Pub/SubREDISREDIS2.6io.lettuce:lettuce-core:6.1.6.RELEASE



Clé alphanumérique

Lorsque la clé est alphanumérique, elle peut soit désigner une propriété standard présente dans tous les souscripteurs Adélia, soit une propriété spécifique relative au courtier de messages associé.


Clé standard

La valeur est une chaine alphanumérique représentant une expression XPath et désignant une propriété relative à la définition d'un souscripteur.

Valeur de clé Description de la propriété Type de la propriété
subconf/id Identifiant du souscripteur Adélia ALPHA(n)
subconf/startOnCreation Indique si le souscripteur Adélia doit être démarré à sa création BOOL
subconf/config
subconf/config Configuration (exportable) du souscripteur Adélia N / A
subconf/config/adeliaPoolName Nom du pool nommé Adélia utilisé pour paramétrer les connexions BD au sein du programme EADELIA associé ALPHA(n)
subconf/config/adeliaPgm
subconf/config/adeliaPgm Configuration du programme EADELIA associé au souscripteur N / A
subconf/config/adeliaPgm/objectFileName Nom du fichier objet issu de la génération du programme EADELIA associé ALPHA(6)
subconf/config/adeliaPgm/javaPackage Nom du package Java défini pour la génération du programme EADELIA associé ALPHA(256)
subconf/config/adeliaPgm/parameters Liste des paramètres alphanumériques passés au programme EADELIA associé lors de son exécution Tableau de ALPHA(n)
subconf/config/adeliaPgm/parameters[<index commençant à 1] Valeur du paramètre d'index <index> dans la liste des paramètres alphanumériques passés au programme EADELIA associé lors de son exécution ALPHA(n)
subconf/config/adeliaPgm/customObjectMapper Identifiant du Java Bean défini dans le fichier beans-context.xml, permettant de configurer les propriétés de transformation d'object JSON en instance de classe Adélia ALPHA(n)
subconf/config/brokerConfig/factory
subconf/config/brokerConfig/factory Informations sur la fabrique en charge de la création du souscripteur Adélia N / A
subconf/config/brokerConfig/factory/id Identifiant de la fabrique utilisée pour la création du souscripteur Adélia ALPHA(n)
subconf/config/brokerConfig/factory/parameters/<nom parametre> Valeur associée au paramètre de nom <nom paramètre> passé à la fabrique associée lors de la création. Le nom du paramètre dépend de la fabrique. Le type dépend de la fabrique associée.
adelUtils:mapKeys(subconf/config/brokerConfig/factory/parameters) Liste des noms des paramètres passés à la fabrique associée lors de la création Tableau de ALPHA(n)
adelUtils:mapValues(subconf/config/brokerConfig/factory/parameters) Liste des valeurs des paramètres passés à la fabrique associée lors de la création Tableau à une dimension. Le type dépend de la fabrique associée. Ce type doit être homogène pour tous les paramètres



Clé spécifique

A l'instar d'une clé standard, sa valeur est une chaîne alphanumérique représentant une expression XPath. Une clé spécifique permet de désigner une propriété relative aux informations de connexion au courtier de messages ainsi qu'aux informations de souscription aux catégories de messages que le souscripteur veut traiter. Chaque clé spécifique dépend donc du courtier ciblé (et de la fabrique associée) :


.  Kafka

Kafka

Informations de connexion brokerConnection

Détails dans la documentation Kafka

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/brokerConnection/key.deserializerClasse Java utilisée pour la désérialisation de la clé du message.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/value.deserializerClasse Java utilisée pour la désérialisation de la charge utile du message.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/bootstrap.servers

Liste des URI des serveurs de courtier Kafka utilisé pour la connexion.

Tableau de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/fetch.min.bytes

Quantité minimale de données que le serveur doit renvoyer pour une requête de type fetch.

NUM_BIN_4

subconf/config/brokerConfig/brokerConnection/group.id

Chaîne unique identifiant le groupe de consommateurs auquel appartient ce souscripteur.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/heartbeat.interval.ms

Intervalle en millisecondes entre les vérifications des pulsations au coordinateur du groupe de consommateurs pour indiquer qu'un souscripteur est actif et connecté.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/max.partition.fetch.bytes

Quantité maximale de données par partition que le serveur renverra au souscripteur

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/session.timeout.ms

Durée maximale en millisecondes pendant laquelle un consommateur au sein d'un groupe de consommateurs peut être hors de contact avec un courtier avant d'être considéré comme inactif et qu'un rééquilibrage soit déclenché entre les consommateurs actifs du groupe.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/allow.auto.create.topics

Permet d'autoriser la création automatique de sujets sur le courtier lors de l'abonnement à un sujet.

BOOL
subconf/config/brokerConfig/brokerConnection/auto.offset.reset

Indique ce qu'il faut faire lorsqu'il n'y a pas d'offset initial dans Kafka ou si l'offset actuel n'existe plus sur le serveur (par exemple parce que ces données ont été supprimées).

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/client.dns.lookup

Contrôle la façon dont le souscripteur utilise les recherches DNS.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/connections.max.idle.ms

Ferme les connexions inactives après le nombre de millisecondes spécifié par cette configuration.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/default.api.timeout.ms

Délai d'attente (en millisecondes) pour les API client. Cette configuration est utilisée comme délai d'expiration par défaut pour toutes les opérations client qui ne spécifient pas de paramètre de délai d'expiration.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/enable.auto.commit

Si vrai, l'offset du consommateur sera périodiquement validé en arrière-plan.

BOOL
subconf/config/brokerConfig/brokerConnection/exclude.internal.topics

Indique si les topics internes correspondant à un modèle d'abonnement (pattern) doivent être exclus de l'abonnement. Il est toujours possible de s'abonner explicitement à un sujet interne.

BOOL
subconf/config/brokerConfig/brokerConnection/fetch.max.bytesQuantité maximale de données que le serveur doit renvoyer pour une requête de type fetch.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/group.instance.id

Identifiant unique de l'instance de consommateur fourni par l'utilisateur final.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/isolation.level

Contrôle comment lire les messages écrits de manière transactionnelle.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/max.poll.interval.ms

Délai maximal entre les invocations de poll() lors de l'utilisation de la gestion des groupes de consommateurs.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/max.poll.records

Nombre maximum d'enregistrements renvoyés dans un seul appel à poll().

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/partition.assignment.strategy

Liste de noms de classe ou de types de classe, classés par préférence, des stratégies d'attribution de partition prises en charge que le client utilisera pour répartir la propriété de la partition entre les instances de consommateur lorsque la gestion de groupe est utilisée.

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/receive.buffer.bytes

Taille du tampon de réception TCP (SO_RCVBUF) à utiliser lors de la lecture des données.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/request.timeout.ms

Durée maximale pendant laquelle le client attendra la réponse d'une requête.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/security.protocol

Protocole utilisé pour communiquer avec les courtiers.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/send.buffer.bytes

Taille du tampon d'envoi TCP (SO_SNDBUF) à utiliser lors de l'envoi de données.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/socket.connection.setup.timeout.max.ms

Durée maximale pendant laquelle le client attendra que la connexion socket soit établie.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/socket.connection.setup.timeout.ms

Durée pendant laquelle le client attendra que la connexion socket soit établie.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/ssl.enabled.protocols

Liste des protocoles activés pour les connexions SSL

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.keystore.type

Format de fichier du fichier de magasin de clés.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.protocol

Protocole SSL utilisé pour générer le SSLContext.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.provider

Nom du fournisseur de sécurité utilisé pour les connexions SSL.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/ssl.truststore.type

Format de fichier du fichier Trust Store.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/auto.commit.interval.ms

Fréquence en millisecondes à laquelle les offsets du consommateur sont validés automatiquement dans Kafka si enable.auto.commit est défini à "true".

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/check.crcs

Vérifie automatiquement le CRC32 des messages consommés.

BOOL
subconf/config/brokerConfig/brokerConnection/client.id

Chaîne d'identifiant à transmettre au serveur lors des requêtes..

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/client.rack

Identifiant de rack pour ce client. Il peut s'agir de n'importe quelle valeur de chaîne indiquant l'emplacement physique de ce client. Il correspond à la configuration du courtier "broker.rack".

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/fetch.max.wait.ms

Durée maximale pendant laquelle le serveur bloquera avant de répondre à la demande de fetch s'il n'y a pas suffisamment de données pour satisfaire immédiatement l'exigence donnée par "fetch.min.bytes".

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/interceptor.classes

Liste de classes à utiliser comme intercepteurs. L'implémentation de l'interface org.apache.kafka.clients.consumer.ConsumerInterceptor vous permet d'intercepter (et éventuellement de muter) les enregistrements reçus par le consommateur

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/metadata.max.age.ms

Période de temps en millisecondes après laquelle nous forçons une actualisation des métadonnées, même si nous n'avons vu aucun changement de direction de partition pour découvrir de manière proactive de nouveaux courtiers ou partitions.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/metric.reporters

Liste de classes à utiliser comme rapporteurs de métriques.

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/metrics.num.samples

Nombre d'échantillons conservés pour calculer les métriques.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/metrics.recording.level

Niveau d'enregistrement le plus élevé pour les métriques.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/metrics.sample.window.ms

Fenêtre de temps pendant laquelle un échantillon de métriques est calculé.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/reconnect.backoff.max.ms

Durée maximale d'attente en millisecondes lors de la reconnexion à un courtier qui a échoué à plusieurs reprises à se connecter

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/reconnect.backoff.ms

Temps d'attente de base avant de tenter de se reconnecter à un hôte donné.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/retry.backoff.ms

Temps d'attente avant de tenter de réessayer une demande ayant échoué à une partition de rubrique donnée.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/security.providers

Liste de classes de créateurs configurables renvoyant chacune un fournisseur implémentant des algorithmes de sécurité.

Tableau d'ALPHA(n)
subconf/config/brokerConfig/brokerConnection/schema.registry.url

URL de l'instance Schema Registry.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/specific.avro.reader

Indique à Kafka / Schema Registry d'utiliser un type Avro spécifique (type d'utilisateur dans ce cas, issu de la génération Avro d'une classe Adélia), sinon Kafka s'attendra à ce que GenericRecord soit utilisé pour le topic.

BOOL

Kafka

Informations de souscription subscribeTopic

Détails dans la documentation Kafka Spring

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/subscribeTopic/patternModèle d'abonnement définissant un pattern de topics avec lesquels souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/topicsListe des noms de topics à souscrire.Tableau d'ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/partitionsListe de couples <topic, numéro de partition> à souscrire.N / A
adelUtils:collectionSize(subconf/config/brokerConfig/subscribeTopic/partitions)Taille de la liste des couples <topic, numéro de partition> à souscrire.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/partitions[<index commençant à 1>]/topicValeur du champ "topic" du couple d'index <index> dans la liste des couples <topic, numéro de partition> à souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/partitions[<index commençant à 1>]/partitionValeur du champ "numéro de partition" du couple d'index <index> dans la liste des couples <topic, numéro de partition> à souscrire.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/ackModeMode de consommation et d'acquittement de messages.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/ackTimeTemps en millisecondes à partir du dernier acquittement après lequel l'acquittement de messages (le commit d'offsets) sera déclenché. Pris en compte si ackMode vaut "TIME" ou "COUNT_TIME".NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/ackCountLe nombre de messages (d'enregistrements) en attente de commit après le dernier acquittement à partir duquel sera déclenché l'acquittement de messages. Pris en compte si ackMode vaut "COUNT" ou "COUNT_TIME".NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/typeMsgHandlingType de consommation de message (un à un ou par lot) lorsque ackMode vaut "MANUAL" ou "MANUAL_IMMEDIATE".ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pollTimeoutDélai d'attente passé dans la fonction poll().NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/commitLogLevel

Niveau de journalisation des logs relatifs aux commits des offsets.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/missingTopicsFatal

Indique si le souscripteur doit démarrer si le ou les sujets configurés ne sont pas présents sur le courtier.

BOOL
subconf/config/brokerConfig/subscribeTopic/onlyLogRecordMetadata

Fixer à false pour logger l'intégralité de l'enregistrement du consommateur au lieu de simplement topic-partition@offset.

BOOL
subconf/config/brokerConfig/subscribeTopic/stopImmediate

Quand le souscripteur est arrêté, permet d'arrêter le traitement après le message courant (true) au lieu d'arrêter après avoir traité tous les messages retournés par le précédent appel à poll() (false).

BOOL


. MQTT v3

MQTT v3

Informations de connexion brokerConnection

Détails dans la documentation Apache Paho MQTTv3

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/brokerConnection/automaticReconnect

Indique si le client tentera automatiquement de se reconnecter au serveur si la connexion est perdue.

BOOL
subconf/config/brokerConfig/brokerConnection/reconnectCloseTimeoutDélai d'attente de tentative de reconnexion réussie avant de fermer définitivement le souscripteur.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/cleanSession

Indique si le client et le serveur doivent se souvenir de l'état du client lors des reconnexions.

BOOL
subconf/config/brokerConfig/brokerConnection/connectionTimeout

Valeur du délai d'expiration de la connexion. Cette valeur, mesurée en secondes, définit l'intervalle de temps maximal pendant lequel le client attendra que la connexion réseau au serveur MQTT soit établie.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/keepAliveInterval

Intervalle "keep alive". Cette valeur, mesurée en secondes, définit l'intervalle de temps maximal entre les messages envoyés ou reçus. Il permet au client de détecter si le serveur n'est plus disponible, sans avoir à attendre le timeout TCP/IP.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/maxInflight

Nombre maximal de messages que le courtier peut envoyer sans recevoir d'accusé de réception.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/mqttVersionFixe la version du protocole MQTT v3 à utiliser (3.1 ou 3.1.1).ALPHA(n)
subconf/config/brokerConfig/brokerConnection/serverURIs

Liste d'un ou plusieurs URI de serveur MQTT auxquels le client peut se connecter.

Tableau de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/userName

Nom d'utilisateur à utiliser pour la connexion.

ALPHA(n)
brokerConnection/will
subconf/config/brokerConfig/brokerConnection/will

Message "Last Will and Testament" (LWT) pour la connexion.

N / A
subconf/config/brokerConfig/brokerConnection/will/topicTopic du LWT.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/payloadCharge utile du message LWT.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/qosNiveau de qualité de service de publication du message LWT.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/will/retainedIndique si le message LWT doit être conservé.BOOL

MQTT v3

Informations de souscription subscribeTopic

Détails dans la documentation Apache Paho MQTTv3

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/subscribeTopic/clientId

Identifiant du client.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistanceMécanisme de persistance des messages.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistantFileDirectory

Répertoire de stockage des messages. Pris en compte lorsque "persistance" vaut "file".

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/manualAcks

Indique si l'acquittement de message est automatique ou manuel.

BOOL
subconf/config/brokerConfig/subscribeTopic/timeToWait

Temps d'attente maximal pour qu'une action avec le courtier se termine.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/topics

Liste sur les informations des topics à souscrire.

N / A
adelUtils:collectionSize(subconf/config/brokerConfig/subscribeTopic/topics)Taille de la liste sur les informations des topics à souscrire.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/topicFilterNom du topic d'index <index> dans la liste sur les informations des topics à souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/qosNiveau de qualité de service de réception des messages du topic d'index <index> dans la liste sur les informations des topics à souscrire.NUM_BIN_4


. MQTT v5

MQTT v5

Informations de connexion brokerConnection

Détails dans la documentation Apache Paho MQTTv3

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/brokerConnection/authDataDonnées d'authentification.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/authMethodMéthode d'authentification.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/automaticReconnect

Indique si le client tentera automatiquement de se reconnecter au serveur si la connexion est perdue.

BOOL
subconf/config/brokerConfig/brokerConnection/automaticReconnectMinDelay

Nombre minimum de secondes à attendre avant de tenter de se reconnecter automatiquement.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/automaticReconnectMaxDelayNombre maximum de secondes à attendre avant de tenter de se reconnecter automatiquement.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/reconnectCloseTimeoutDélai d'attente de tentative de reconnexion réussie avant de fermer définitivement le souscripteur.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/cleanStart

Indique si le client et le serveur doivent se souvenir de l'état de la session lors des redémarrages et des reconnexions.

BOOL
subconf/config/brokerConfig/brokerConnection/connectionTimeout

Valeur du délai d'expiration de la connexion. Cette valeur, mesurée en secondes, définit l'intervalle de temps maximal pendant lequel le client attendra que la connexion réseau au serveur MQTT soit établie.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/httpsHostnameVerificationEnabledActive la vérification de l'hôte lors d'une connexion HTTPS.BOOL
subconf/config/brokerConfig/brokerConnection/keepAliveInterval

Intervalle "keep alive". Cette valeur, mesurée en secondes, définit l'intervalle de temps maximal entre les messages envoyés ou reçus. Il permet au client de détecter si le serveur n'est plus disponible, sans avoir à attendre le timeout TCP/IP.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/maximumPacketSize

Taille maximale de paquet.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/maxReconnectDelay

Temps d'attente maximal entre les reconnexions.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/receiveMaximum

Nombre maximum de réceptions. Cette valeur représente la limite des publications QoS 1 et QoS 2 que le client est prêt à traiter simultanément.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/requestProblemInfo

Fixe l'indicateur de demande d'informations sur les problèmes rencontrés dans le protocole de communication.

BOOL
subconf/config/brokerConfig/brokerConnection/requestResponseInfo

Fixe l'indicateur d'informations de réponse à la demande.

BOOL
subconf/config/brokerConfig/brokerConnection/serverURIs

Liste d'un ou plusieurs URI de serveur MQTT auxquels le client peut se connecter.

Tableau de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/sessionExpiryInterval

Intervalle d'expiration de la session. Cette valeur, mesurée en secondes, définit la durée maximale pendant laquelle le courtier maintiendra la session une fois que le client se déconnectera. Les clients ne doivent se connecter avec un long intervalle d'expiration de session que s'ils ont l'intention de se connecter au serveur ultérieurement.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/sSLProperties

Propriétés SSL de la connexion (sous la forme d'une table de hachage).

N / A
adelUtils:mapKeys(subconf/config/brokerConfig/brokerConnection/sSLProperties)Liste des noms de propriétés SSL de la connexion.Tableau de ALPHA(n)
adelUtils:mapValues(subconf/config/brokerConfig/brokerConnection/sSLProperties)Liste des valeurs de propriétés SSL de la connexion.Tableau de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/topicAliasMaximum

Maximum d'alias de sujet. Cette valeur, si elle est présente, représente la valeur la plus élevée que le client acceptera comme alias de sujet envoyé par le serveur.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/userName

Nom d'utilisateur à utiliser pour la connexion.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/userProperties

Propriétés de l'utilisateur. Une propriété utilisateur est une paire de chaînes UTF-8, le même nom peut apparaître plusieurs fois.

Tableau à deux dimensions de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/useSubscriptionIdentifiers

Indique s'il faut attribuer automatiquement des identifiants d'abonnement lors de l'abonnement à une rubrique.

BOOL
brokerConnection/will
subconf/config/brokerConfig/brokerConnection/will

Message "Last Will and Testament" (LWT) pour la connexion.

N / A
subconf/config/brokerConfig/brokerConnection/will/topicTopic du LWT.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/payloadCharge utile du message LWT.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/will/qosNiveau de qualité de service de publication du message LWT.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/will/retainedIndique si le message LWT doit être conservé.BOOL

MQTT v5

Informations de souscription subscribeTopic

Détails dans la documentation Apache Paho MQTTv3

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/subscribeTopic/clientId

Identifiant du client.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistanceMécanisme de persistance des messages.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/persistantFileDirectory

Répertoire de stockage des messages. Pris en compte lorsque "persistance" vaut "file".

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/manualAcks

Indique si l'acquittement de message est automatique ou manuel.

BOOL
subconf/config/brokerConfig/subscribeTopic/timeToWait

Temps d'attente maximal pour qu'une action avec le courtier se termine.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/topics

Liste sur les informations des topics à souscrire.

N / A
adelUtils:collectionSize(subconf/config/brokerConfig/subscribeTopic/topics)Taille de la liste sur les informations des topics à souscrire.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/topicFilterNom du topic d'index <index> dans la liste sur les informations des topics à souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/qosNiveau de qualité de service de réception des messages du topic d'index <index> dans la liste sur les informations des topics à souscrire.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/retainAsPublishIndique si le courtier conserve le flag "retain" lors de l'envoi d'un message conservé au souscripteur.BOOL
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/noLocalPermet de ne pas recevoir les messages que le souscripteur a publié.BOOL
subconf/config/brokerConfig/subscribeTopic/topics[<index commençant à 1>]/retainHandling

Permet de spécifier si le serveur transmet le message retenu au client lors de l'établissement d'un abonnement (valeurs 0 à 2).

NUM_BIN_4


. Nats Jetstream

Nats Jetstream

Informations de connexion brokerConnection

Détails dans la documentation Apache Paho MQTTv3

Valeur de cléDescription de la propriétéType de la propriété
brokerConnection/jetStreamCtx
subconf/config/brokerConfig/brokerConnection/jetStreamCtxContexte de connexion Jetstream.N / A
subconf/config/brokerConfig/brokerConnection/jetStreamCtx/prefix

Préfixe pour les sujets JetStream.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/jetStreamCtx/requestTimeout

Délai d'expiration de la demande pour les appels d'API JetStream.

ALPHA(n)
brokerConnection/natsCon
subconf/config/brokerConfig/brokerConnection/natsConParamètres de la connexion Nats.N / A
subconf/config/brokerConfig/brokerConnection/natsCon/bufferSize

Taille initiale des tampons dans la connexion, principalement pour les tests.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/connectionNameNom de la connexion.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/connectionTimeout

Délai d'expiration des tentatives de connexion.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/dataPortType

Classe Java à utiliser pour ce port de données de connexion.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/discardMessagesWhenOutgoingQueueFull

Active les messages de suppression lorsque la file d'attente sortante est pleine.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/inboxPrefix

Préfixe de la boîte de réception de la connexion.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/maxControlLine

Longueur maximale d'une ligne de contrôle envoyée par cette connexion.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/maxMessagesInOutgoingQueue

Nombre maximal de messages dans la file d'attente sortante.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/maxPingsOut

Nombre maximum de pings que le client peut avoir en vol.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/maxReconnects

Nombre maximal de tentatives de reconnexion.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/natsCon/noEcho

Désactive l'écho.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/noHeaders

Désactive la prise en charge des en-têtes.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/noNoResponders

Désactive l'assistance sans réponse.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/noRandomize

Désactive la randomisation du pool de serveurs.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/oldRequestStyle

Active l'ancien style de demande qui utilise une nouvelle boîte de réception et un nouvel abonné pour chaque demande.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/opentls

Contexte SSL sur un contexte qui accepte n'importe quel certificat de serveur et n'a aucun certificat client.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/pedantic

Active le mode pédant pour le serveur, par rapport à cette connexion.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/pingInterval

Intervalle entre les tentatives de ping du serveur.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectBufferSize

Nombre maximal d'octets à mettre en mémoire tampon dans le client lors d'une tentative de reconnexion.

NUM_BIN_8
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectJitter

Délai d'attente entre les tentatives de reconnexion au même serveur.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectJitterTls

Délai d'attente d'une connexion tls/sécurisée entre les tentatives de reconnexion au même serveur.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/reconnectWait

Délai d'attente entre les tentatives de reconnexion au même serveur..

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/requestCleanupInterval

Intervalle entre les passes de nettoyage des requêtes (request futures) en attente qui sont annulées ou ont expiré dans le code de l'application.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/secure

Options pour utiliser le contexte SSL par défaut, s'il existe.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/serversListe des URI des serveurs auxquels se connecter.Tableau de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/traceConnection

Active les messages de trace de connexion.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/turnOnAdvancedStats

Active les statistiques avancées, principalement pour les tests/benchmarks.

BOOL
subconf/config/brokerConfig/brokerConnection/natsCon/verbose

Active le mode détaillé avec le serveur.

BOOL
brokerConnection/natsCon/userInfo
subconf/config/brokerConfig/brokerConnection/natsCon/userInfoInformations utilisateur.N / A
subconf/config/brokerConfig/brokerConnection/natsCon/userInfo/userNameNom d'utilisateur pour l'authentification basique.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/natsCon/userInfo/passwordMot de passe pour l'authentification basique.ALPHA(n)

Nats Jetstream

Informations de souscription subscribeTopic

Détails dans la documentation Apache Paho MQTTv3

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/subscribeTopic/subjectNom du sujet à souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queueGroupNameNom de groupe de queue à rejoindre.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/subscribeTypeType de souscription aux messages.ALPHA(n)
subscribeTopic/pushSubOpts
subconf/config/brokerConfig/subscribeTopic/pushSubOptsInformations de souscription de type "PUSH".N / A
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/deliverGroupFixe le groupe de livraison.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/deliverSubjectFixe le sujet de livraison.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/durableFixe un nom de souscripteur durable.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/streamNom du flux auquel appartient le sujet à souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/bindLie le souscripteur durable au flux.BOOL
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/pendingMessageLimit

Limites sur le nombre maximal de messages que le consommateur conservera avant de commencer à supprimer de nouveaux messages en attendant que l'application vide la file d'attente.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/pendingByteLimitLimites sur la taille maximale des messages que ce consommateur conservera avant de commencer à supprimer de nouveaux messages en attendant que l'application vide la file d'attente.NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/pushMaxWaitDélai d'attente maximale pour la réception d'un message.ALPHA(n)
subscribeTopic/pushSubOpts/consumerConfig
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfigInformations de configuration du consommateur.N / A
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/ackPolicyMode d'acquittement des messages.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/ackWait

Durée d'attente de l'accusé de réception.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/deliverPolicy

Stratégie de livraison des messages au consommateur.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/descriptionFixe une description à cette configuration.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/filterSubject

Sujet du filtre.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/flowControl

Active le contrôle de flux .

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/idleHeartbeat

Temps d'attente des signaux de présence inactifs du consommateur.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/maxAckPending

Maximum d'accusés de réception en attente.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/maxDeliver

Nombre maximal de livraisons de messages.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/maxPullWaiting

Attente d'extraction maximale : nombre d'extractions qui peuvent être en attente sur un consommateur en mode "PULL", les extractions reçues après que ce nombre est atteint sont ignorées.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/rateLimit

Limite de débit (nombre de messages par seconde).

NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/replayPolicy

Stratégie de relecture des messages.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/sampleFrequency

Fréquence d'échantillonnage.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/startSequence

Séquence de démarrage d'acquisition des messages dans le flux.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pushSubOpts/consumerConfig/startTimeHeure de début d'acquisition des messages dans le flux.ALPHA(n)
subscribeTopic/pullSubOpts
subconf/config/brokerConfig/subscribeTopic/pullSubOptsInformations de souscription de type "PULL".N / A
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/durableNom de souscripteur durable.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/streamNom du flux auquel appartient le sujet à souscrire.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/bindLie le souscripteur durable au flux.BOOL
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/pullTypeMode d'acquisition des messages en mode "PULL".ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/pullBatchSizeNombre maximum de messages récupérés au sein d'un lot.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/pullMaxWaitDélai d'attente maximale pour la réception des messages par lot.ALPHA(n)
subscribeTopic/pullSubOpts/consumerConfig
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfigInformations de configuration du consommateur.N / A
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/ackPolicyMode d'aquittement des messages.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/ackWait

Durée d'attente de l'accusé de réception.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/deliverPolicy

Stratégie de livraison des messages au consommateur.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/descriptionFixe une description à cette configuration.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/filterSubject

Sujet du filtre.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/flowControl

Active le contrôle de flux.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/idleHeartbeat

Temps d'attente des signaux de présence inactifs du consommateur.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/maxAckPending

Maximum d'accusés de réception en attente.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/maxDeliver

Nombre maximal de livraisons de messages.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/maxPullWaiting

Attente d'extraction maximale, le nombre d'extractions qui peuvent être en attente sur un consommateur en mode 'PULL', les extractions reçues après que celle-ci est atteinte sont ignorées

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/rateLimit

Limite de débit (nombre de messages par seconde).

NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/replayPolicy

Stratégie de relecture des messages.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/sampleFrequency

Fréquence d'échantillonnage.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/startSequence

Séquence de démarrage d'acquisition des messages dans le flux.

NUM_BIN_8
subconf/config/brokerConfig/subscribeTopic/pullSubOpts/consumerConfig/startTimeHeure de début d'acquisition des messages dans le flux.ALPHA(n)


. RabbitMQ AMQP

RabbitMQ AMQP

Informations de connexion brokerConnection

Détails dans la documentation Lettuce Redis Client

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/brokerConnection/username

Nom d'utilisateur à utiliser pour la connexion au serveur.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/passwordMot de passe à utiliser pour la connexion au serveur.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/encryptedPasswordIndique si le mot de passe est crypté.BOOL
subconf/config/brokerConfig/brokerConnection/virtualHostNom d'hôte virtuel auquel se connecter.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/hostNom d'hôte auquel se connecter.ALPHA(n)
subconf/config/brokerConfig/brokerconnection/portNuméro de port TCP utilisé pour la connexion au serveur.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/handshakeTimeout

Délai d'expiration de l'établissement de la connexion.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/shutdownTimeout

Délai d'attente maximal pour l'arrêt du client.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/clientPropertiesTable de hachage des propriétés du client.N / A
adelUtils:mapKeys(subconf/config/brokerConfig/brokerConnection/clientProperties)

Liste des noms des propriétés de la table de hachage des propriétés du client.

Tableau de ALPHA(n)
adelUtils:mapValues(subconf/config/brokerConfig/brokerConnection/clientProperties)Liste des valeurs associées aux propriétés de la table de hachage des propriétés du client.Tableau de ALPHA(n)
subconf/config/brokerConfig/brokerConnection/topologyRecoveryEnabled

Active la récupération de la topologie (queues, exchange, binding, etc.) lors d'une perte de connexion au serveur.

BOOL
subconf/config/brokerConfig/brokerConnection/useSslActive le protocole TLS avec les paramètres par défaut pour la connexion au serveur.BOOL
brokerConnection/ssl
subconf/config/brokerConfig/brokerConnection/sslParamètres de connexion SSL/TLS.N / A
subconf/config/brokerConfig/brokerConnection/ssl/hostnameVerificationActive la vérification du nom d'hôte.BOOL
subconf/config/brokerConfig/brokerConnection/ssl/peerVerificationActive la vérification des pairs.BOOL
brokerConnection/connection
subconf/config/brokerConfig/brokerConnection/connectionParamètres de la connexion TCP.N / A
subconf/config/brokerConfig/brokerConnection/connection/channelMax

Numéro de canal maximal demandé.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/frameMax

Taille de trame maximale demandée.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/heartbeatIntervalle en secondes entre les vérifications des pulsations entre client et serveur.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/timeout

Délai d'expiration de la connexion TCP.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/connection/recoveryEnabled

Active la récupération automatique de la connexion.

BOOL
subconf/config/brokerConfig/brokerConnection/connection/recoveryInterval

Intervalle de récupération de la connexion.

NUM_BIN_8
brokerConnection/channel
subconf/config/brokerConfig/brokerConnection/channelParamètres des canaux utilisés dans la connexion au serveur.N / A
subconf/config/brokerConfig/brokerConnection/channel/rpcTimeout

Délai de continuation pour les appels RPC dans les canaux.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/channel/shouldCheckRpcResponseType

Active la vérification du type de réponse des appels RPC.

BOOL
subconf/config/brokerConfig/brokerConnection/useNio

Utilise des E/S non bloquantes (NIO) pour communiquer avec le serveur.

BOOL
brokerConnection/nio
subconf/config/brokerConfig/brokerConnection/nioParamètres de NIO.N / A
subconf/config/brokerConfig/brokerConnection/nio/readByteBufferSize

Taille en octets du ByteBuffer de lecture utilisé dans la boucle NIO.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/writeByteBufferSize

Taille en octets du ByteBuffer d'écriture utilisé dans la boucle NIO.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/nbIoThreads

Nombre maximum de threads/tâches utilisés pour NIO.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/writeEnqueuingTimeoutInMs

Délai d'attente pour la mise en file d'attente des trames sortantes.

NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/nio/writeQueueCapacity

Capacité de la file d'attente utilisée pour les trames sortantes.

NUM_BIN_4

RabbitMQ AMQP

Informations de souscription subscribeTopic

Détails dans la documentation Lettuce Redis Client

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/subscribeTopic/consumerTag

Identifiant du souscripteur.

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/consumerPrefetchCount

Nombre maximum de messages que le serveur délivrera.

NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/autoAckActive l'acquittement automatique des messages.BOOL
subconf/config/brokerConfig/subscribeTopic/exclusiveConsumerSouscripteur comme étant le consommateur exclusif de la queue associée.BOOL
subscribeTopic/consumerArgs
subconf/config/brokerConfig/subscribeTopic/consumerArgsPropriétés du consommateur.N / A
subconf/config/brokerConfig/subscribeTopic/consumerArgs/xPriorityPriorité du consommateur au sein d'un groupe.NUM_BIN_4
subscribeTopic/queue
subconf/config/brokerConfig/subscribeTopic/queuePropriétés de la queue associée au consommateur.N / A
subconf/config/brokerConfig/subscribeTopic/queue/nameNom de la queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/declarePassiveUtilise une queue existante dans la topologie ou crée une nouvelle queue.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/durablePersistance de la queue.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/autoDeleteDurée de vie de la queue.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/exclusiveExclusivité de la queueBOOL
subscribeTopic/queue/queueArgs
subconf/config/brokerConfig/subscribeTopic/queue/queueArgsInformations complémentaires sur le comportement de la queue.N / A
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMessageTtlDurée de vie des messages dans la queue.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xExpiresDurée maximale d'inactivité (pas de souscripteur associé) de la queue avant suppression.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMaxLengthNombre maximal de messages contenus dans la queue.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMaxLengthBytesNombre maximal d'octets contenus dans la queueNUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xOverflowComportement d'une queue pleine lorsqu'elle recçoit un nouveau message.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xDeadLetterExchange

Nom d'un routeur (exchange) vers lequel republier les messages d'une file d'attente "en lettres mortes" (les messages reçus par la queue dans des conditions particulières).

ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xDeadLetterRoutingKeyClé de routage à utiliser dans le cas des messages "en lettres mortes".ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xMaxPriorityNiveau de priorité de la queue.NUM_BIN_4
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xQueueModeMode de sauvegarde des messages dans la queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/queueArgs/xQueueMasterLocatorEmplacement de la queue maître dans un environnement serveur distribué.ALPHA(n)
subscribeTopic/queue/bind
subconf/config/brokerConfig/subscribeTopic/queue/bindListe des informations de liaison de la queue à un routeur.N / A
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/routingKeyClé de routage utilisée pour lier le routeur à la queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/bindArgsTable de hachage des propriétés de liaison entre le routeur et la queue.

N / A

adelUtils:mapKeys(subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/bindArgs)Liste des noms des propriétés dans la table de hachage des propriétés de liaison entre le routeur et la queue.Tableau de ALPHA(n)
adelUtils:mapValues(subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/bindArgs)Liste des valeurs associés aux propriétés dans la table de hachage des propriétés de liaison entre le routeur et la queue.Tableau de ALPHA(n)
subscribeTopic/queue/bind[<index>]/exchange
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchangeInformation sur le routeur lié à la queue.N / A
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/nameNom du routeur lié à la queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/typeType de routeur lié à la queue.ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/durablePersistance du routeur.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/autoDeleteDurée de vie du routeur.BOOL
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/declarePassiveUtilise un routeur existant dans la topologie ou crée un nouveau routeur.BOOL
subscribeTopic/queue/bind[<index>]/exchange/exchangeArgs
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/exchangeArgsInformations complémentaires sur le comportement du routeur.N / A
subconf/config/brokerConfig/subscribeTopic/queue/bind[<index>]/exchange/exchangeArgs/alternateExchangeNom d'un routeur alternatif utilisé lorsque le routeur n'est pas capable de router un message.ALPHA(n)


. Redis Pub/Sub

Redis Pub/Sub

Informations de connexion brokerConnection

Détails dans la documentation Lettuce Redis Client

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/brokerConnection/redisType

Indique le type de serveur Redis à utiliser.

ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIURI du serveur Redis utilisée pour la connexion.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/clientNameNom du client.ALPHA(n)
brokerConnection/redisURIObj
subconf/config/brokerConfig/brokerConnection/redisURIObjInformations de connexion utilisée pour la connexion à un serveur Redis. Pris en compte si "redisURI" n'est pas renseigné.N / A
subconf/config/brokerConfig/brokerConnection/redisURIObj/usernameNom d'utilisateur utilisé pour la connexion.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/passwordMot de passe utilisé pour la connexion.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/databaseBase de données à laquelle se connecter sur le serveur Redis.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/redisURIObj/sslUtilise une connexion SSL.BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/startTlsActive StartTLS avec la connexion SSL.BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/timeoutTemps d'attente maximum pour l'établissement de la connexion.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/sslVerifyPeer

Active la vérification par les pairs.

BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/sslVerifyPeerModeMode de vérification par les pairs.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/encryptedPasswordIndique si le mot de passe est crypté.BOOL
subconf/config/brokerConfig/brokerConnection/redisURIObj/hostNom d'hôte du serveur Redis.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/redisURIObj/portNuméro de port TCP utilisé pour la connexion au serveur.NUM_BIN_4
brokerConnection/clientOptions
subconf/config/brokerConfig/brokerConnection/clientOptions

Options permettant le contrôle du comportement du client Redis.

N / A
subconf/config/brokerConfig/brokerConnection/clientOptions/autoReconnect

Active la reconnexion automatique en cas de perte de connexion.

BOOL
subconf/config/brokerConfig/brokerConnection/clientOptions/reconnectCloseTimeoutDélai d'attente de tentative de reconnexion réussie avant de fermer définitivement le souscripteur.NUM_BIN_4
subconf/config/brokerConfig/brokerConnection/clientOptions/protocolVersionVersion du protocole à utiliser pour la connexion.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/clientOptions/commandsTimeoutDélai d'attente maximal à une réponse de commande au serveur.ALPHA(n)
subconf/config/brokerConfig/brokerConnection/clientOptions/pingBeforeActivateConnection

Définit l'envoi d'un PING avant d'activer la connexion.

BOOL

Redis Pub/Sub

Informations de souscription subscribeTopic

Détails dans la documentation Lettuce Redis Client

Valeur de cléDescription de la propriétéType de la propriété
subconf/config/brokerConfig/subscribeTopic/channels

Liste des channels auxquels souscrire.

Tableau de ALPHA(n)
subconf/config/brokerConfig/subscribeTopic/patternsListe des pattern de channels auxquels souscrire.Tableau de ALPHA(n)


Après l'exécution de cet ordre, le mot réservé *CODE_RETOUR peut prendre les valeurs suivantes :

0 (*NORMAL)

L'opération s'est bien déroulée.

-1

Erreur interne.

-2

Erreur de syntaxe XPath lors de l'évaluation du paramètre NomPropriété.

-3

Le paramètre mot réservé est inconnu.

-4

La clé correspond à une information qui n'existe pas ou qui n'a pas de valeur.

-11 La valeur associée à la clé ne peut pas être convertie en type Adélia.
-32 La variable résultat doit être une variable de type ALPHA ou REF_CLASSE.
-33 La variable résultat ALPHA a une longueur trop petite.
-53 La variable résultat doit être une variable numérique.
-54 La variable résultat NUM_E / NUM_P a une taille trop petite.
-55 La variable résultat NUM_E / NUM_P a une partie entière trop petite.
-56 La variable résultat NUM_E / NUM_P a une partie décimale trop petite.
-57 La variable résultat a un type non compatible avec une valeur numérique.
-58 La variable résultat NUM_BIN_2 a une taille trop petite.
-59 La variable résultat NUM_BIN_4 a une taille trop petite.
-60 La variable résultat NUM_BIN_8 a une taille trop petite.
-61 La valeur associée à la clé ne peut pas être convertie en type TIMESTAMP.
-74 La variable résultat doit être une variable booléenne.
-95 La variable résultat doit être une variable DATE, TIME ou TIMESTAMP.
-116 La variable résultat doit être une variable IMAGE.
-117

La valeur associée à la clé ne peut pas être convertie en tableau d'octets.

-137 La variable résulta doit être une variable REF_CLASSE.
-138 La valeur associée à la clé ne peut pas être converti en classe Adélia.
-300 La variable résultat doit être une variable tableau.
-301 La variable résultat doit être une variable tableau à une dimension.
-302 La variable résultat tableau a une taille trop petite.
-303 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur numérique.
-304 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur alphanumérique.
-305 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur booléenne.
-306 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur image.
-307 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur de classe Adélia.
-308 Le type de la variable résultat n'est pas supporté.
-309 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur date/time/timestamp.
-332 La variable tableau résultat doit être de type ALPHA ou REF_CLASSE.
-333 La variable tableau résultat ALPHA a une longueur alphanumérique trop petite.
-353 La variable tableau résultat doit être de type numérique.
-354 La variable tableau résultat NUM_E / NUM_P définit des numériques de taille trop petite.
-355 La variable tableau résultat NUM_E / NUM_P définit des numériques de partie entière trop petite.
-356 La variable tableau résultat NUM_E / NUM_P définit des numériques de partie décimale trop petite.
-357 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en valeur numérique.
-358 La variable tableau résultat NUM_BIN_2 définit des entiers de taille trop petite.
-359 La variable tableau résultat NUM_BIN_4 définit des entiers de taille trop petite.
-360 La variable tableau résultat NUM_BIN_8 définit des entiers de taille trop petite.
-361 Les items de la liste valeur de la clé ont une valeur qui ne peut pas être converti en type TIMESTAMP.
-374 La variable tableau résultat doit être de type booléen.
-395 La variable tableau résultat doit être de type date, time ou timestamp.
-416 La variable tableau résultat doit être de type image.
-417 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en tableau d'octets.
-437 La variable tableau résultat doit être de type REF_CLASSE.
-438 Les items de la liste valeur de la clé ont un type qui ne peut pas être converti en classe Adélia.
-600 La valeur associée à la clé ne peut pas être convertie en type Adélia.
-621 La valeur alphanumérique associée à la clé ne peut pas être désérialisée en classe Adélia.
-642 La valeur numérique associée à la clé ne peut pas être convertie en type numérique Adélia.
-705 Erreur lors de la récupération du tableau d'octets depuis une instance ByteBuffer.
-706

L'instance de ByteBuffer n'a pas de tableau d'octets accessible.

-707 La valeur tableau d'octets associée à la clé ne peut pas être désérialisée en classe Adélia.
-900 La valeur associée à la clé ne peut pas être convertie en type Adélia.
-1521 La valeur alphanumérique associée à la clé ne peut pas être désérialisée en classe Adélia.
-1542 La valeur numérique associée à la clé ne peut pas être convertie en type numérique Adélia.
-1605 Erreur lors de la récupération du tableau d'octets depuis une instance ByteBuffer.
-1606 L'instance de ByteBuffer n'a pas de tableau d'octets accessible.
-1607 La valeur tableau d'octets associée à la clé ne peut pas être désérialisée en classe Adélia.

Par exemple

* Récupération du nom du courtier

ALPHA(128) BROKER_NAME

BRK_RECUP_CONF *BRK_NOM BROKER_NAME


* Récupération du nom du souscripteur

ALPHA(128) SUBSCRIBER_ID

BRK_RECUP_CONF 'subconf/id' SUBSCRIBER_ID


* Récupération de la liste des topics souscrits

ALPHA(64) TOPICS_ARRAY (3)

BRK_RECUP_CONF 'subconf/config/brokerConfig/subscribeTopic/topics' TOPICS_ARRAY


↑ Haut de page


  • Aucune étiquette