Interface FilteredMessageOutput

All Known Implementing Classes:
ElasticSearchOutput

public interface FilteredMessageOutput
Classes that implement this interface accept batches of FilteredMessages.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    writeFiltered(List<FilteredMessage> filteredMessages)
    Write the given filtered messages.
  • Method Details

    • writeFiltered

      void writeFiltered(List<FilteredMessage> filteredMessages) throws Exception
      Write the given filtered messages. Based on the filtered messages attributes, the output can decide to discard the message.
      Parameters:
      filteredMessages - the filtered messages
      Throws:
      Exception - if writing the messages fails