Package dev.getelements.elements.sdk.service.topic

Interface Topic.Publisher<U>

Type Parameters:
U -
All Superinterfaces:
AutoCloseable, Consumer<U>
Enclosing interface:
Topic<T>
public static interface Topic.Publisher<U> extends Consumer<U>, AutoCloseable
The Publisher type which is returned by Topic.getPublisher(). This will keep a connection open to the underlying topic service and publish messages consumed by the Consumer.accept(Object) mnethod until it is closed using close().

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    close()
    For the sake of convenience, this omits the Exception specification.

    Methods inherited from interface java.util.function.Consumer

    accept, andThen

  • Method Details

    • close

      default void close()
      For the sake of convenience, this omits the Exception specification.
      Specified by:
      close in interface AutoCloseable