public class AxonServerSubscriptionQueryResult<I,U> extends Object implements SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>
SubscriptionQueryResult
that emits initial response and update when subscription query response message is
received.Constructor and Description |
---|
AxonServerSubscriptionQueryResult(SubscriptionQueryMessage<?,?,?> queryMessage,
io.axoniq.axonserver.connector.query.SubscriptionQueryResult result,
SubscriptionMessageSerializer subscriptionSerializer,
SpanFactory spanFactory,
Span parentSpan)
Instantiate a
AxonServerSubscriptionQueryResult which will emit its initial response and the updates of
the subscription query. |
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 . |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel()
Cancels this Registration.
|
reactor.core.publisher.Mono<QueryResponseMessage<I>> |
initialResult()
Subscribing to this mono will trigger invocation of query handler.
|
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> |
updates()
When there is an update to the subscription query, it will be emitted to this flux.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handle
close
@Deprecated public AxonServerSubscriptionQueryResult(io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer)
SpanFactory
. This constructor defaults to a
NoOpSpanFactory
.AxonServerSubscriptionQueryResult
which will emit its initial response and the updates of
the subscription query.public AxonServerSubscriptionQueryResult(SubscriptionQueryMessage<?,?,?> queryMessage, io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer, SpanFactory spanFactory, Span parentSpan)
AxonServerSubscriptionQueryResult
which will emit its initial response and the updates of
the subscription query.public reactor.core.publisher.Mono<QueryResponseMessage<I>> initialResult()
SubscriptionQueryResult
initialResult
in interface SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>
public reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates()
SubscriptionQueryResult
updates
in interface SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>
public boolean cancel()
Registration
cancel
in interface Registration
true
if this handler is successfully deregistered, false
if this handler
was not currently registered.Copyright © 2010–2023. All rights reserved.