| Package | Description |
|---|---|
| org.axonframework.axonserver.connector.query | |
| org.axonframework.queryhandling |
| Modifier and Type | Method and Description |
|---|---|
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> |
AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query,
SubscriptionQueryBackpressure backPressure,
int updateBufferSize)
Deprecated.
in favor of using the {
AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)} |
| Modifier and Type | Method and Description |
|---|---|
static SubscriptionQueryBackpressure |
SubscriptionQueryBackpressure.defaultBackpressure()
Deprecated.
Creates default backpressure, using Project Reactor's FluxSink.OverflowStrategy ERROR strategy.
|
| Modifier and Type | Method and Description |
|---|---|
<U> UpdateHandlerRegistration<U> |
SimpleQueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favour of using {
SimpleQueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage, int)} |
<U> UpdateHandlerRegistration<U> |
QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favour of using {
QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage, int)} |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure)
Deprecated.
in favour of using {
QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType)}.
To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly.
Example: result.updates().onBackpressureBuffer(100) |
<Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favour of using {
QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, int)}.
To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly.
Example: result.updates().onBackpressureBuffer(100) |
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
|
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> |
SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favor use of {
SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage, int) |
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> |
QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favour of using {
QueryBus.subscriptionQuery(SubscriptionQueryMessage, int)} |
Copyright © 2010–2023. All rights reserved.