Function/service/queue/AbstractDistributedQueueSelectorService - Nimbus Wiki - Nimbus

DistributedQueueSelector抽象サービス jp.ossc.nimbus.service.queue.AbstractDistributedQueueSelectorService

jp.ossc.nimbus.service.queue.AbstractDistributedQueueSelectorServiceは、キューの分流を行うDistributedQueueSelector抽象サービスです。
このクラスを継承してDistributedQueueSelector実装サービスを実装する事で、簡単に独自のキューの分流を実装する事ができます。

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

下位サービスインタフェース	用途
jp.ossc.nimbus.service.queue.Queue	分流させるキュー。

以下に簡単な実装方法を示します。

 import jp.ossc.nimbus.service.queue.AbstractDistributedQueueSelectorService;
 
 public class SampleDistributedQueueSelectorService extends AbstractDistributedQueueSelectorService{
     
     protected Object getKey(Object obj){
         String id = (String)obj;
         
         // キューにエントリされたIDの頭３文字で分流する
         return id.substring(0, 3);
     }
 }

---

キュー/DistributedQueueSelector