0

ディスラプター 2.10.4 の使用を検討しています。ディスラプタ/リングバッファは、ユーザー定義クラス内の属性です。何らかの理由で、ハンドラーが呼び出されているように見えません

    final EventHandler<Message> handler = new EventHandler<Message>() { 
        public void onEvent(final UserDefinedMessage event, final long sequence, final boolean endOfBatch) throws Exception {
            log.info("Sequence: " + sequence);
            log.info("disruptor message: " + event.getValue());
        }
    };  

//    disruptor = new Disruptor<UserDefinedMessage>(UserDefinedMessage.EVENT_FACTORY, 1024, exec);  
      disruptor = new Disruptor<UserDefinedMessage>(UserDefinedMessage.EVENT_FACTORY, exec, new SingleThreadedClaimStrategy(50), new SleepingWaitStrategy());
    disruptor.handleEventsWith(handler); 
    ringBuffer = disruptor.start();

更新: パイロット エラー - メッセージがリング バッファーに発行されているとは思えません。

4

0 に答える 0