| Package | Description |
|---|---|
| org.axonframework.axonserver.connector.query | |
| org.axonframework.config | |
| org.axonframework.queryhandling | |
| org.axonframework.spring.config |
| Modifier and Type | Method and Description |
|---|---|
QueryUpdateEmitter |
AxonServerQueryBus.queryUpdateEmitter() |
| Constructor and Description |
|---|
AxonServerQueryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
QueryUpdateEmitter updateEmitter,
QueryBus localSegment,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator)
Creates an instance of the AxonServerQueryBus
|
| Modifier and Type | Method and Description |
|---|---|
protected QueryUpdateEmitter |
DefaultConfigurer.defaultQueryUpdateEmitter(Configuration config)
Provides the default QueryUpdateEmitter implementation.
|
default QueryUpdateEmitter |
Configuration.queryUpdateEmitter()
Returns the Query Update Emitter in this Configuration.
|
| Modifier and Type | Method and Description |
|---|---|
default Configurer |
Configurer.configureQueryUpdateEmitter(Function<Configuration,QueryUpdateEmitter> queryUpdateEmitterBuilder)
Configures the given Query Update Emitter to use in this configuration.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SimpleQueryUpdateEmitter
Implementation of
QueryUpdateEmitter that uses Project Reactor to implement Update Handlers. |
| Modifier and Type | Method and Description |
|---|---|
QueryUpdateEmitter |
SimpleQueryBus.queryUpdateEmitter() |
QueryUpdateEmitter |
QueryBus.queryUpdateEmitter()
Gets the
QueryUpdateEmitter associated with this QueryBus. |
| Modifier and Type | Method and Description |
|---|---|
SimpleQueryBus.Builder |
SimpleQueryBus.Builder.queryUpdateEmitter(QueryUpdateEmitter queryUpdateEmitter)
Sets the
QueryUpdateEmitter used to emits updates for the
QueryBus.subscriptionQuery(SubscriptionQueryMessage). |
| Modifier and Type | Method and Description |
|---|---|
QueryUpdateEmitter |
AxonConfiguration.defaultQueryUpdateEmitter() |
QueryUpdateEmitter |
AxonConfiguration.queryUpdateEmitter() |
Copyright © 2010–2018. All rights reserved.