Package | Description |
---|---|
org.axonframework.axonserver.connector.query | |
org.axonframework.axonserver.connector.query.subscription | |
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) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> |
DeserializedResult.updates() |
Modifier and Type | Class and Description |
---|---|
class |
GenericSubscriptionQueryUpdateMessage<U>
Generic
SubscriptionQueryUpdateMessage which holds incremental update of an subscription query. |
Modifier and Type | Method and Description |
---|---|
SubscriptionQueryUpdateMessage<U> |
SubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData) |
SubscriptionQueryUpdateMessage<U> |
GenericSubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData) |
static <T> SubscriptionQueryUpdateMessage<T> |
GenericSubscriptionQueryUpdateMessage.asUpdateMessage(Object payload)
Creates
GenericSubscriptionQueryUpdateMessage from provided payload which represents incremental
update. |
SubscriptionQueryUpdateMessage<U> |
SubscriptionQueryUpdateMessage.withMetaData(Map<String,?> metaData) |
SubscriptionQueryUpdateMessage<U> |
GenericSubscriptionQueryUpdateMessage.withMetaData(Map<String,?> metaData) |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> |
UpdateHandlerRegistration.getUpdates()
Gets the updates.
|
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> |
QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query)
Dispatch the given
query to a single QueryHandler subscribed to the given query 's
queryName/initialResponseType/updateResponseType. |
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> |
SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize) |
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>> |
QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Dispatch the given
query to a single QueryHandler subscribed to the given query 's
queryName/initialResponseType/updateResponseType. |
Modifier and Type | Method and Description |
---|---|
default <Q,U> void |
QueryUpdateEmitter.emit(Class<Q> queryType,
Predicate<? super Q> filter,
SubscriptionQueryUpdateMessage<U> update)
Emits given incremental update to subscription queries matching given query type and filter.
|
<U> void |
SimpleQueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter,
SubscriptionQueryUpdateMessage<U> update) |
<U> void |
QueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter,
SubscriptionQueryUpdateMessage<U> update)
Emits incremental update (as return value of provided update function) to subscription queries matching given
filter.
|
Modifier and Type | Method and Description |
---|---|
Registration |
SimpleQueryUpdateEmitter.registerDispatchInterceptor(MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage<?>> interceptor) |
SimpleQueryUpdateEmitter.Builder |
SimpleQueryUpdateEmitter.Builder.updateMessageMonitor(MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor)
Sets the
MessageMonitor used to monitor SubscriptionQueryUpdateMessage s being processed. |
Constructor and Description |
---|
UpdateHandlerRegistration(Registration registration,
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates)
|
Copyright © 2010–2019. All rights reserved.