Package app.l2nx.gs.adapter.core.events

Interface EventsPublisher.ProducerFlusher

Enclosing class:
EventsPublisher
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public static interface EventsPublisher.ProducerFlusher
Bridge to a synchronous producer flush. Production wires this to NxKafka.instance()::flush; a no-op is used where the producer is not reachable (tests). Blocks until in-flight sends reach the broker.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    flush()
     

  • Method Details

    • flush

      void flush()