Package org.axonframework.extension.reactor.messaging.eventhandling.gateway

Interface ReactorEventGateway

All Superinterfaces:
DescribableComponent
All Known Implementing Classes:
DefaultReactorEventGateway
public interface ReactorEventGateway extends DescribableComponent
Reactor event gateway that runs dispatch interceptors inside the Reactor subscription.

Use this instead of EventGateway when interceptors need access to Reactor context (e.g., ReactiveSecurityContextHolder).

The interceptor chain is built and executed within the Reactor subscription, ensuring that the Reactor Context is available throughout the entire dispatch pipeline.

Since:
4.4.2
Author:
Milan Savic, Theo Emanuelsson
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    default reactor.core.publisher.Mono<Void>
    publish(Object... events)
    Publishes the given events and returns a Mono that completes when publishing is done.
    default reactor.core.publisher.Mono<Void>
    publish(List<?> events)
    Publishes the given list of events and returns a Mono that completes when publishing is done.
    default reactor.core.publisher.Mono<Void>
    publish(@Nullable ProcessingContext context, Object... events)
    Publishes the given events within the given context (if available) and returns a Mono that completes when publishing is done.
    reactor.core.publisher.Mono<Void>
    publish(@Nullable ProcessingContext context, List<?> events)
    Publishes the given list of events within the given context (if available) and returns a Mono that completes when publishing is done.

    Methods inherited from interface org.axonframework.common.infra.DescribableComponent

    describeTo

  • Method Details

    • publish

      default reactor.core.publisher.Mono<Void> publish(@Nullable ProcessingContext context, Object... events)
      Publishes the given events within the given context (if available) and returns a Mono that completes when publishing is done.
      Parameters:
      context - the processing context, if any, to publish the given events in
      events - the events to publish
      Returns:
      a Mono completing when the events have been published

    • publish

      reactor.core.publisher.Mono<Void> publish(@Nullable ProcessingContext context, List<?> events)
      Publishes the given list of events within the given context (if available) and returns a Mono that completes when publishing is done.
      Parameters:
      context - the processing context, if any, to publish the given events in
      events - the events to publish
      Returns:
      a Mono completing when the events have been published

    • publish

      default reactor.core.publisher.Mono<Void> publish(Object... events)
      Publishes the given events and returns a Mono that completes when publishing is done.
      Parameters:
      events - the events to publish
      Returns:
      a Mono completing when the events have been published
      See Also:

    • publish

      default reactor.core.publisher.Mono<Void> publish(List<?> events)
      Publishes the given list of events and returns a Mono that completes when publishing is done.
      Parameters:
      events - the events to publish
      Returns:
      a Mono completing when the events have been published
      See Also: