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 |
DeserializedResult<I,U>
A decorator of the
SubscriptionQueryUpdateMessage to deserialize a QueryResponseMessage and
QueryUpdate messages. |
class |
DisposableResult<I,U>
A decorator of the
SubscriptionQueryResult which adds the DisposableResult.cancel() operation. |
Modifier and Type | Method and Description |
---|---|
SubscriptionQueryResult<QueryResponse,QueryUpdate> |
AxonServerSubscriptionQueryResult.get() |
Constructor and Description |
---|
DeserializedResult(SubscriptionQueryResult<QueryResponse,QueryUpdate> delegate,
SubscriptionMessageSerializer serializer)
Instantiate a
DeserializedResult wrapping the delegate which will be serialized by the given
serializer . |
DisposableResult(SubscriptionQueryResult<I,U> delegate,
Registration registration)
Instantiate a
DisposableResult wrapping the delegate , opening up the capability to
DisposableResult.cancel() it. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultSubscriptionQueryResult<I,U>
Default implementation of
SubscriptionQueryResult . |
Modifier and Type | Method and Description |
---|---|
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(Q query,
Class<I> initialResponseType,
Class<U> updateResponseType)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
Class<I> initialResponseType,
Class<U> updateResponseType)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize) |
<Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
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. |
Copyright © 2010–2019. All rights reserved.