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–2022. All rights reserved.