組み合わせは、[キャメル] ShutdownAwareと[キャメル]プロセッサは

Question

に動作しません。私は私がアプリケーションにTERM信号（グレースフルシャットダウン）を送信すると、このProcessorは春ShutdownAware を実装Thread を開始しているラクダProcessorを持っていますどんな情報も受け取らない - ShutdownAwareインターフェイスのメソッドが呼び出された。 私はそれを正しく停止したいので、Threadについて言及しました。

import org.apache.camel.Processor; 
import org.apache.camel.spi.ShutdownAware; 

public class MyProcessor implements Processor, ShutdownAware { 
... 
} 

どうすればこのプロセッサを登録する必要がありますか？

Answer 1

ShutdownAwareは、SpringではなくCamelインターフェイスです。

MyProcessorの場合は、Spring Beanが、それはDisposableBeanを実装、または@PreDestroy方法を持っている、またはその他の春は、コンテキストがシャットダウンしているときに呼び出す理解する何かで注釈を付けることができます。

あなたはXMLを使用している場合は、おそらくもちろんMyProcessorの

@Bean(destroyMethod = "shutdown") 
public MyProcessor myProcessor() { ... } 

がshutdown方法が必要になります@Beanを使用している場合、あなたはこの

<bean class="...MyProcessor" destroy-method="shutdown"/> 

を行う可能性があります。 ShutdownAwareには何も表示されません。

Springコンテキストはどのように作成されますか？おそらくあなたは、例えば、シャットダウンフックを登録する必要があります。context.registerShutdownHook();本当に、これに対処する方法はCamelContextは春がシャットダウンされていることを意識することですJavadoc

を参照してください。それはあなたのプロセッサーに通知する必要があります。

Answer 2

ソリューションは、次のとおりです。その後、

import org.apache.camel.Processor; 
import org.apache.camel.Service; 
import org.apache.camel.spi.ShutdownAware; 

public class MyProcessor implements Processor, ShutdownAware, Service { 
... 
} 

ShutdownAwareからの方法でもstart()シャットダウン時に呼び出されます、「サービス」のインターフェースからstop()方法が使用されていません。