Package org.axonframework.axonserver.connector.query.subscription

Class AxonServerSubscriptionQueryResult<I,U>

java.lang.Object
org.axonframework.axonserver.connector.query.subscription.AxonServerSubscriptionQueryResult<I,U>
All Implemented Interfaces:
AutoCloseable, org.axonframework.common.Registration, org.axonframework.queryhandling.SubscriptionQueryResult<org.axonframework.queryhandling.QueryResponseMessage<I>,org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>>
public class AxonServerSubscriptionQueryResult<I,U> extends Object implements org.axonframework.queryhandling.SubscriptionQueryResult<org.axonframework.queryhandling.QueryResponseMessage<I>,org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>>
A SubscriptionQueryResult that emits initial response and update when subscription query response message is received.
Since:
4.0
Author:
Sara Pellegrini, Stefan Dragisic, Steven van Beelen, Allard Buijze

  • Constructor Summary

    Constructors
    Constructor
    Description
    AxonServerSubscriptionQueryResult(io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer)
    Deprecated.
    Deprecated in favor of constructor with a SpanFactory.
    AxonServerSubscriptionQueryResult(io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, org.axonframework.tracing.SpanFactory spanFactory, SubscriptionMessageSerializer subscriptionSerializer)
    Deprecated.
    Deprecated in favor of constructor with a QueryBusSpanFactory.
    AxonServerSubscriptionQueryResult(org.axonframework.queryhandling.SubscriptionQueryMessage<?,?,?> queryMessage, io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer, org.axonframework.queryhandling.QueryBusSpanFactory spanFactory, org.axonframework.tracing.Span parentSpan)
    Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    cancel()
     
    reactor.core.publisher.Mono<org.axonframework.queryhandling.QueryResponseMessage<I>>
    initialResult()
     
    reactor.core.publisher.Flux<org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>>
    updates()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.axonframework.common.Registration

    close

    Methods inherited from interface org.axonframework.queryhandling.SubscriptionQueryResult

    handle, handle

  • Constructor Details

    • AxonServerSubscriptionQueryResult

      @Deprecated public AxonServerSubscriptionQueryResult(io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer)
      Deprecated.
      Deprecated in favor of constructor with a SpanFactory. This constructor defaults to a NoOpSpanFactory.
      Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

    • AxonServerSubscriptionQueryResult

      @Deprecated public AxonServerSubscriptionQueryResult(io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, org.axonframework.tracing.SpanFactory spanFactory, SubscriptionMessageSerializer subscriptionSerializer)
      Deprecated.
      Deprecated in favor of constructor with a QueryBusSpanFactory. This constructor defaults to a DefaultQueryBusSpanFactory with the provided SpanFactory.
      Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

    • AxonServerSubscriptionQueryResult

      public AxonServerSubscriptionQueryResult(org.axonframework.queryhandling.SubscriptionQueryMessage<?,?,?> queryMessage, io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer, org.axonframework.queryhandling.QueryBusSpanFactory spanFactory, org.axonframework.tracing.Span parentSpan)
      Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

  • Method Details

    • initialResult

      public reactor.core.publisher.Mono<org.axonframework.queryhandling.QueryResponseMessage<I>> initialResult()
      Specified by:
      initialResult in interface org.axonframework.queryhandling.SubscriptionQueryResult<I,U>

    • updates

      public reactor.core.publisher.Flux<org.axonframework.queryhandling.SubscriptionQueryUpdateMessage<U>> updates()
      Specified by:
      updates in interface org.axonframework.queryhandling.SubscriptionQueryResult<I,U>

    • cancel

      public boolean cancel()
      Specified by:
      cancel in interface org.axonframework.common.Registration