Package io.smallrye.reactive.messaging.providers.extension

Class LegacyEmitterImpl<T>

java.lang.Object
io.smallrye.reactive.messaging.providers.extension.LegacyEmitterImpl<T>
Type Parameters:
T - the type of payload or message
All Implemented Interfaces:
io.smallrye.reactive.messaging.annotations.Emitter<T>, io.smallrye.reactive.messaging.EmitterType, io.smallrye.reactive.messaging.MessagePublisherProvider<T>
public class LegacyEmitterImpl<T> extends Object implements io.smallrye.reactive.messaging.annotations.Emitter<T>, io.smallrye.reactive.messaging.MessagePublisherProvider<T>
Implementation of the old (legacy) Emitter interface. This implementation delegates to the new implementation.

  • Method Details

    • getPublisher

      public Flow.Publisher<org.eclipse.microprofile.reactive.messaging.Message<? extends T>> getPublisher()
      Specified by:
      getPublisher in interface io.smallrye.reactive.messaging.MessagePublisherProvider<T>

    • complete

      public void complete()
      Specified by:
      complete in interface io.smallrye.reactive.messaging.annotations.Emitter<T>

    • error

      public void error(Exception e)
      Specified by:
      error in interface io.smallrye.reactive.messaging.annotations.Emitter<T>

    • isCancelled

      public boolean isCancelled()
      Specified by:
      isCancelled in interface io.smallrye.reactive.messaging.annotations.Emitter<T>

    • isRequested

      public boolean isRequested()
      Specified by:
      isRequested in interface io.smallrye.reactive.messaging.annotations.Emitter<T>

    • send

      public io.smallrye.reactive.messaging.annotations.Emitter<T> send(T msg)
      Specified by:
      send in interface io.smallrye.reactive.messaging.annotations.Emitter<T>