Camel，Spring，OSGI：有没有一种方法可以指定stop方法？

Ya. 发表于 Dev

是。

我正在运行Camel Spring OSGI应用程序。Camel上下文是通过Spring初始化的。当捆绑包停止时，我需要进行一些清理活动，例如注销消息侦听器。我怎么做？有没有可以覆盖的方法？我知道OSGI捆绑包必须提供激活器的启动和停止方法，但我的理解还在于Camel / Spring / OSGI框架会覆盖这些方法。

我的beanx.xml：

<beans>
  <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
    <routeBuilder ref="outboundBuilder" />
  </camelContext>
</beans>

我的Java代码：

public class MyRouteBuilder extends RouteBuilder {
    public void configure() {
           .....
    }
}

南皮比

只是为了扩大对Bilgin Ibryam的回答，这是正确的。

骆驼能够将策略应用于路由。此策略在运行时控制路由。这将使您能够在路线生命周期的某些事件中执行自定义逻辑。

实施路由策略。

声明一个扩展RoutePolicySupport的新类，然后覆盖您感兴趣的方法是非常简单的。

public class MyRoutePolicy extends RoutePolicySupport{

    @Override
        public void onStart(Route route) {
        // TODO Auto-generated method stub
        super.onStart(route);
    } 

    @Override
    public void onStop(Route route) {
        // TODO Auto-generated method stub
        super.onStop(route);
    }

    @Override
    public void onExchangeBegin(Route route, Exchange exchange) {
        // TODO Auto-generated method stub
        super.onExchangeBegin(route, exchange);
    }


}

现在，在您的routebuilder configure（）方法中使用该路由，如下所示：

 RoutePolicy policy = new MyRoutePolicy();
 from("timer://blah")
   .routeId("Test1").routePolicy(policy)
   .setBody().constant("A Message Like Hello World")
   .to("mock:meh");

如果您仅使用带有路径的Spring XML，请添加以下内容：

<bean id="policy" class="MyRoutePolicy"/>


<camelContext xmlns="http://camel.apache.org/schema/spring">
   <route id="foo" routePolicyRef="MyRoutePolicy">
     <from uri="timer://blah"/>
     <setBody><constant>A Message Like Hello World</constant></setBody>        
     <to uri="mock:meh"/>
   </route>
 </camelContext>

本文收集自互联网，转载请注明来源。

如有侵权，请联系[email protected] 删除。