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 | Class and Description |
---|---|
class |
GrpcBackedSubscriptionQueryMessage<Q,I,U>
Wrapper that allows clients to access a gRPC
SubscriptionQuery message as a SubscriptionQueryMessage . |
Modifier and Type | Method and Description |
---|---|
SubscriptionQuery |
SubscriptionMessageSerializer.serialize(SubscriptionQueryMessage subscriptionQueryMessage)
Convert a
SubscriptionQueryMessage into a SubscriptionQuery . |
Modifier and Type | Class and Description |
---|---|
class |
GenericSubscriptionQueryMessage<Q,I,U>
Generic implementation of the
SubscriptionQueryMessage . |
Modifier and Type | Method and Description |
---|---|
SubscriptionQueryMessage<Q,I,U> |
SubscriptionQueryMessage.andMetaData(Map<String,?> additionalMetaData)
Returns a copy of this SubscriptionQueryMessage with its MetaData merged with given
metaData . |
SubscriptionQueryMessage<Q,I,U> |
SubscriptionQueryMessage.withMetaData(Map<String,?> metaData)
Returns a copy of this SubscriptionQueryMessage with the given
metaData . |
Modifier and Type | Method and Description |
---|---|
Set<SubscriptionQueryMessage<?,?,?>> |
SimpleQueryUpdateEmitter.activeSubscriptions()
Provides the set of running subscription queries.
|
Modifier and Type | Method and Description |
---|---|
boolean |
SimpleQueryUpdateEmitter.queryUpdateHandlerRegistered(SubscriptionQueryMessage<?,?,?> query) |
boolean |
QueryUpdateEmitter.queryUpdateHandlerRegistered(SubscriptionQueryMessage<?,?,?> query)
Checks whether there is a query update handler for a given
query . |
<U> UpdateHandlerRegistration<U> |
SimpleQueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize) |
<U> UpdateHandlerRegistration<U> |
QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Registers an Update Handler for given
query with given backpressure and updateBufferSize . |
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 |
---|---|
void |
SimpleQueryUpdateEmitter.complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter) |
void |
QueryUpdateEmitter.complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter)
Completes subscription queries matching given filter.
|
void |
SimpleQueryUpdateEmitter.completeExceptionally(Predicate<SubscriptionQueryMessage<?,?,?>> filter,
Throwable cause) |
void |
QueryUpdateEmitter.completeExceptionally(Predicate<SubscriptionQueryMessage<?,?,?>> filter,
Throwable cause)
Completes with an error subscription queries matching given 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.
|
default <U> void |
QueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter,
U update)
Emits given incremental update to subscription queries matching given filter.
|
Copyright © 2010–2019. All rights reserved.