Propriétés du cAggregate Standard

Ces propriétés sont utilisées pour configurer le cAggregate s'exécutant dans le framework de Jobs Standard.

Le composant cAggregate Standard appartient à la famille Routing.

Basic settings

langue	Sélectionnez le langage de l'expression que vous souhaitez utiliser pour filtrer vos messages, entre None, Bean, CONSTANT, ESBCorrelationID, EL, GROOVY, HEADER, JoSQL, JSonPath, JXPATH, MVEL, OGNL, PHP, PROPERTY, PYTHON, RUBY, SIMPLE, SpEL, SQL, XPATH et XQUERY. Sélectionnez CorrelationID pour utiliser l'ID de corrélation existant du message comme clé de corrélation si l'ID de corrélation est disponible dans le cSOAP connecté le plus proche à ce composant. Pour plus d'informations concernant le composant cSOAP, consultez cSOAP.
Correlation expression/Expression	Saisissez l'expression évaluant la clé de corrélation à utiliser pour l'agrégation. Ce champ disparaît lorsque l'option Correlation ID est sélectionnée dans la liste Language. Dans ce cas, l'ID de corrélation existant du cSOAP le plus proche connecté à ce composant est utilisé. Pour plus d'informations concernant le composant cSOAP, consultez cSOAP.
Correlation expression/Add Namespaces	Cette option apparaît lorsque XPath est sélectionné dans la liste Language. Cochez cette case pour ajouter des espaces de noms pour l'expression Xpath. Cliquez sur [+] pour ajouter autant d'espaces de noms que nécessaire dans la table et configurer le préfixe et l'URI dans les colonnes correspondantes.
Stratégie	Spécifiez un bean Java à utiliser comme catégorie d'agrégation ou sélectionnez une stratégie d'agrégation prédéfinie. UseOriginalAggregationStrategy : utilisez l'échange d'origine. UseLatestAggregationStrategy : utilisez le dernier échange. GroupedMessageAggregationStrategy : agrégez tous les messages en un seul échange combiné contenant la liste de tous les messages agrégés, en tant que corps de message. GroupedExchangeAggregationStrategy : agrégez tous les échanges en un seul échange combiné contenant la liste de tous les échanges agrégés, en tant que corps de message. GroupedBodyAggregationStrategy : agrégez le corps des messages d'entrée en un seul échange combiné contenant tous les corps agrégés dans une liste d'objets de type, en tant que corps de message. Note InformationsRemarque : Les stratégies d'agrégation prédéfinies sont disponibles uniquement si vous avez installé la mise à jour mensuelle R2024-10 du Studio Talend ou une mise à jour plus récente fournie par Talend. Pour plus d'informations, contactez votre administrateur ou administratrice.
Completion conditions/Number of messages	Cochez cette case pour spécifier le nombre de messages à agréger par lot avant que l'opération d'agrégation soit complète. Note InformationsRemarque : Cette case est cochée par défaut et le nombre de messages est défini à 3. Si vous décochez cette case et qu'au moins l'une des quatre autres conditions de complétion est rencontrée, tous les messages récupérés sont agrégés en un lot.
Completion conditions/Inactivity timeout (in milliseconds)	Cochez cette case pour spécifier la durée (en millisecondes) qu'un échange agrégé doit rester inactif pour être complet. Cette option peut être définie soit comme une valeur fixe, soit à l'aide d'une expression qui vous permet d'évaluer dynamiquement le délai avant suspension. Note InformationsRemarque : Vous ne pouvez utiliser cette option avec Scheduled interval. Une seule d'entre elles peut être utilisée à la fois.
Completion conditions/Scheduled interval (in milliseconds)	Cochez cette case pour spécifier un intervalle de temps répété (en millisecondes) à la fin duquel les échanges de messages seront agrégés par l'agrégateur. Note InformationsRemarque : Vous ne pouvez utiliser cette option avec Inactivity timeout. Une seule d'entre elles peut être utilisée à la fois.
Completion conditions/Predicate matched	Cochez cette case pour spécifier un prédicat à indiquer lorsqu'un échange agrégé est terminé.
Completion conditions/Batch consumer	Cochez cette case pour agréger tous les fichiers consommés à partir de l'endpoint de fichiers à l'emplacement spécifié.

Advanced settings

Check completion before aggregating	Cochez cette case afin de vérifier la complétion lorsqu'un nouvel échange entrant est reçu. Cette option influence le comportement de l'option Predicate matched car l'échange passé change également. Lorsque cette option est désactivée, l'échange passé dans le prédicat est l'échange aggregated, ce qui signifie que toute information stockée dans l'échange agrégé par la stratégie d'agrégation est disponible pour le prédicat. Lorsque cette option est activée, l'échange passé dans le prédicat est l'échange incoming, ce qui signifie que vous pouvez accéder aux données de l'échange entrant.
Close correlation group	Cochez cette case pour indiquer qu'une clé de corrélation à déjà été complétée. Tout échange ayant la même clé de corrélation sera refusé. Lorsque vous utilisez cette option, saisissez un nombre dans le champ Maximum bound afin de n'avoir qu'un nombre fermé de clés de corrélation.
Ignore invalid correlation key	Cochez cette case pour ignorer une clé de corrélation invalide ne pouvant être évaluée comme une valeur. Par défaut Camel va retourner une Exception lorsqu'il rencontre une clé de corrélation invalide.
Group arriving exchange	Cochez cette case pour grouper tous les échanges agrégés en un seul objet contenant tous les échanges agrégés. Un seul message Exchange est envoyé depuis l'Aggregator. Cette option peut être utilisée pour combiner plusieurs échanges entrants en un seul échange de sortie.
Use persistence	Cochez cette case pour sélectionner votre propre implémentation du référentiel conservant une trace des échanges agrégés en cours d'agrégation. Par défaut, Camel utilise une implémentation basée mémoire.
Repository	Ce champ apparaît lorsque la case Use persistence est cochée. Le référentiel est AggregationRepository ou RecoverableAggregationRepository. AggregationRepository : le référentiel par défaut utilisé par Camel est une implémentation basée mémoire. Saisissez le nom du référentiel dans le champ. RecoverableAggregationRepository : RecoverableAggregationRepository est un JDBC basé sur un AggregationRepository faisant persister les messages agrégés à la volée. Cela vous assure de ne pas perdre vos messages. Saisissez le nom du référentiel dans le champ. En sélectionnant ce référentiel, les options suivantes apparaissent : Recovery/Use recovery : cochez cette case pour récupérer les échanges agrégés ayant échoué et les soumettre à nouveau automatiquement. Dans le champ Recovery interval, saisissez l'intervalle (en millisecondes) de temps au bout duquel chercher les échanges échoués à reprendre et à soumettre à nouveau. Cet intervalle est par défaut de 5 000 millisecondes. Dans le champ Dead letter channel, saisissez une URI d'endpoint pour un canal des messages perdus dans lequel tous les messages Exchange récupérés seront déplacés. Dans le champ Maximum redeliveries, saisissez le nombre maximal de tentatives de relivraison pour un échange récupéré.

Utilisation

Règle d'utilisation	Le composant cAggregate peut être utilisé comme composant intermédiaire ou de fin dans une Route.
Connections	Aggregate : sélectionnez ce lien pour router des messages vers l'endpoint suivant, selon la stratégie d'agrégation sélectionnée. Route : sélectionnez ce lien pour router tous les messages de l'émetteur vers l'endpoint suivant.

Règle d'utilisation

Le composant cAggregate peut être utilisé comme composant intermédiaire ou de fin dans une Route.

Connections

Aggregate : sélectionnez ce lien pour router des messages vers l'endpoint suivant, selon la stratégie d'agrégation sélectionnée.

Route : sélectionnez ce lien pour router tous les messages de l'émetteur vers l'endpoint suivant.

Cette page vous a-t-elle aidé ?

Si vous rencontrez des problèmes sur cette page ou dans son contenu – une faute de frappe, une étape manquante ou une erreur technique – faites-le-nous savoir.

Laissez vos commentaires ici