| Package | Description |
|---|---|
| org.axonframework.axonserver.connector.query | |
| org.axonframework.axonserver.connector.query.subscription |
| Modifier and Type | Method and Description |
|---|---|
protected SubscriptionMessageSerializer |
AxonServerQueryBus.Builder.buildSubscriptionMessageSerializer()
Build a
SubscriptionMessageSerializer using the configured messageSerializer,
genericSerializer and configuration. |
| 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. |
DeserializedResult(SubscriptionQueryResult<io.axoniq.axonserver.grpc.query.QueryResponse,io.axoniq.axonserver.grpc.query.QueryUpdate> delegate,
SubscriptionMessageSerializer serializer)
Deprecated.
Instantiate a
DeserializedResult wrapping the delegate which will be serialized by the given
serializer. |
Copyright © 2010–2023. All rights reserved.