QueueHandler実装サービス jp.ossc.nimbus.service.queue.BeanFlowInvokerCallQueueHandlerService

jp.ossc.nimbus.service.queue.BeanFlowInvokerCallQueueHandlerServiceは、非同期処理を業務フローによって実現するQueueHandler実装サービスです。

どの業務フローを呼び出すかを設定によって選択することができます。

  • 特定の業務フローを呼び出す。
  • キューにエントリされたオブジェクトの型に対してマッピングされた業務フローを呼び出す。
  • キューにエントリされたオブジェクトのプロパティ値を業務フロー名として、業務フローを呼び出す。
  • キューにエントリされたオブジェクトを条件としてマッピングされた業務フローを呼び出す。

このサービスは、複合的なサービスで、以下のサービスを下位サービスとして使用します。

下位サービスインタフェース用途
jp.ossc.nimbus.service.beancontrol.BeanFlowInvokerFactory業務フローサービス。

以下に特定の業務フローを呼び出すサービス定義を示します。

  1. <?xml version="1.0" encoding="Shift_JIS"?>
  2. <!DOCTYPE server PUBLIC
  3. "-//Nimbus//DTD Nimbus 1.0//JA"
  4. "http://nimbus.sourceforge.jp/dtd/nimbus-service_1_0.dtd">
  5. <server>
  6. <manager>
  7. <!-- 並列非同期処理を行うQueueHandlerサービス -->
  8. <service name="QueueHandler"
  9. code="jp.ossc.nimbus.service.queue.BeanFlowInvokerCallQueueHandlerService">
  10. <!-- 非同期処理を行う業務フロー名を設定する -->
  11. <attribute name="DefaultBeanFlowKey">SampleFlow</attribute>
  12. <!-- 業務フローを生成するBeanFlowInvokerFactoryサービスのサービス名を設定する -->
  13. <attribute name="BeanFlowInvokerFactoryServiceName">#BeanFlowInvokerFactory</attribute>
  14. <depends>BeanFlowInvokerFactory</depends>
  15. </service>
  16. <!-- 業務フローを生成するBeanFlowInvokerFactoryサービス -->
  17. <service name="BeanFlowInvokerFactory"
  18. code="jp.ossc.nimbus.service.beancontrol.DefaultBeanFlowInvokerFactoryService">
  19. <attribute name="DirPaths">flows</attribute>
  20. <attribute name="BeanFlowInvokerAccessClass">jp.ossc.nimbus.service.beancontrol.BeanFlowInvokerAccessImpl2</attribute>
  21. <attribute name="Validate">true</attribute>
  22. </service>
  23. </manager>
  24. </server>


キュー/QueueHandler