Création de plusieurs sessions de Topic tibco ems lors de la connexion à des boulons d'orage par apache-chameau

Question

Je travaille sur Apache Storm et je prévois de connecter les boulons d'extrémité pour passer des messages à un sujet de tibco-ems en utilisant Apache-chameau à travers un seul connexion tibco-ems, mais chaque instance du boulon devrait avoir une session séparée avec le sujet pour éviter la surcharge, car la quantité de messages à transférer est énorme. Comment créer des sessions séparées? J'ai instancié le contexte camel dans la méthode prepare de la classe bolt et la connexion routes et tibco ems est instanciée dans le fichier de configuration.

chameau contexte est instancié selon la solution dans le lien ci-dessous: Using Apache Camel ProducerTemplate in Apache Storm bolt

Answer 1

Je suis un peu confus quand vous dites « la connexion est ems TIBCO instancié dans le fichier de configuration ».

Rappelez-vous prepare va exécuter une fois pour chaque instance de votre boulon, donc c'est où vous initialiser votre connexion à TIBCO ems. Tout comme ProducerTemplate vous pourriez faire votre connexion transient puisque vous réutiliserez encore et encore dans execute.

Jetez un oeil à mon autre réponse ici: Execution flow of a storm program

Enfin, vous contrôlez le nombre de cas de votre boulon que vous voulez quand vous configurez la topologie.