インターフェース BatchingStrategy

  • すべての既知の実装クラス:
    SimpleBatchingStrategy

    public interface BatchingStrategy
    メッセージをバッチ処理するための戦略。メソッドが同時に呼び出されることはありません。

    実験用 - API は変更される場合があります。

    導入:
    1.4.1
    作成者:
    Gary Russell
    • メソッドの詳細

      • addToBatch

        MessageBatch addToBatch​(StringSE exchange,
                                StringSE routingKey,
                                Message message)
        バッチにメッセージを追加し、必要に応じてバッチを解放します。
        パラメーター:
        exchange - 交換。
        routingKey - ルーティングキー。
        message - メッセージ。
        戻り値:
        バッチ処理されたメッセージ ( MessageBatch )、または解放する準備ができていない場合は null。
      • nextRelease

        DateSE nextRelease()
        戻り値:
        次にスケジュールされたリリースが実行される日付、またはリリースするデータがない場合は null。
      • releaseBatches

        CollectionSE<MessageBatch> releaseBatches()
        おそらくタイムアウトが原因で、バッチをリリースします。
        戻り値:
        バッチ処理されたメッセージ。
      • canDebatch

        default boolean canDebatch​(MessageProperties properties)
        この戦略がメッセージ本文からメッセージのバッチをデコードできる場合は true を返します。true を返すということは、deBatch(Message, Consumer) をオーバーライドする必要があることを意味します。
        パラメーター:
        properties - メッセージのプロパティ。
        戻り値:
        メッセージをデコードできる場合は true。
        導入:
        2.2
        関連事項:
        deBatch(Message, Consumer)
      • deBatch

        default void deBatch​(Message message,
                             ConsumerSE<Message> fragmentConsumer)
        メッセージをフラグメントにデコードします。
        パラメーター:
        message - メッセージ。
        fragmentConsumer - フラグメントのコンシューマー。
        導入:
        2.2
        関連事項:
        canDebatch(MessageProperties)