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.