当通过apache-camel连接到风暴螺栓时创建Topic tibco ems的多个会话

Question

我正在使用apache风暴，我计划连接最后一个螺栓以通过一个单一的Apache-camel将消息传递给tibco-ems主题tibco-ems连接，但每个螺栓实例都应该有一个与主题分开的会话，以避免超载，因为要传输的消息数量巨大。我如何创建单独的会话？我已经在bolt类的prepare方法中实例化了camel-context，并且在配置文件中实例化了路由和tibco ems连接。

骆驼上下文是根据在下面的链接解决方案实例： Using Apache Camel ProducerTemplate in Apache Storm bolt

Answer 1

我有点困惑，当你说“TIBCO EMS连接在配置文件中被实例化”。

请记住prepare要执行一次螺栓的每个实例，因此这是您初始化与tibco ems的连接的位置。就像ProducerTemplate，您可以使您的连接transient，因为您将重复使用execute一遍又一遍。

看看我其他的答案在这里：Execution flow of a storm program

最后，你控制你的许多螺栓的情况下，希望在您设置的拓扑结构。