Package io.smallrye.reactive.messaging.providers.locals

Interface ContextAwareMessage<T>

All Superinterfaces:
org.eclipse.microprofile.reactive.messaging.Message<T>
public interface ContextAwareMessage<T> extends org.eclipse.microprofile.reactive.messaging.Message<T>

  • Field Summary

    Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message

    EMPTY_ACK, EMPTY_NACK, LOGGER

  • Method Summary

    Modifier and Type
    Method
    Description
    static org.eclipse.microprofile.reactive.messaging.Metadata
    captureContextMetadata(Iterable<Object> metadata)
     
    static org.eclipse.microprofile.reactive.messaging.Metadata
    captureContextMetadata(Object... metadata)
     
    static org.eclipse.microprofile.reactive.messaging.Metadata
    captureContextMetadata(org.eclipse.microprofile.reactive.messaging.Metadata metadata)
     
    static LocalContextMetadata
    captureLocalContextMetadata()
     
    default Optional<LocalContextMetadata>
    getContextMetadata()
     
    static <T> ContextAwareMessage<T>
    of(T payload)
     
    default void
    runOnMessageContext(Runnable runnable)
     
    static <T> org.eclipse.microprofile.reactive.messaging.Message<T>
    withContextMetadata(org.eclipse.microprofile.reactive.messaging.Message<T> message)
     

    Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Message

    ack, ack, addMetadata, getAck, getAckWithMetadata, getMetadata, getMetadata, getNack, getNackWithMetadata, getPayload, nack, nack, thenApply, unwrap, withAck, withAckWithMetadata, withMetadata, withMetadata, withNack, withNackWithMetadata, withPayload

  • Method Details

    • captureLocalContextMetadata

      @Nullable static LocalContextMetadata captureLocalContextMetadata()

    • of

      static <T> ContextAwareMessage<T> of(T payload)

    • withContextMetadata

      static <T> org.eclipse.microprofile.reactive.messaging.Message<T> withContextMetadata(org.eclipse.microprofile.reactive.messaging.Message<T> message)

    • captureContextMetadata

      @CheckReturnValue static org.eclipse.microprofile.reactive.messaging.Metadata captureContextMetadata(org.eclipse.microprofile.reactive.messaging.Metadata metadata)

    • captureContextMetadata

      @CheckReturnValue static org.eclipse.microprofile.reactive.messaging.Metadata captureContextMetadata(Object... metadata)

    • captureContextMetadata

      @CheckReturnValue static org.eclipse.microprofile.reactive.messaging.Metadata captureContextMetadata(Iterable<Object> metadata)

    • getContextMetadata

      default Optional<LocalContextMetadata> getContextMetadata()

    • runOnMessageContext

      default void runOnMessageContext(Runnable runnable)