Package | Description |
---|---|
org.axonframework.axonserver.connector.query | |
org.axonframework.queryhandling |
Modifier and Type | Method and Description |
---|---|
<Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>> |
AxonServerQueryBus.streamingQuery(StreamingQueryMessage<Q,R> query) |
Modifier and Type | Class and Description |
---|---|
class |
GenericStreamingQueryMessage<Q,R>
Generic implementation of the
StreamingQueryMessage . |
Modifier and Type | Method and Description |
---|---|
StreamingQueryMessage<Q,R> |
StreamingQueryMessage.andMetaData(Map<String,?> additionalMetaData) |
StreamingQueryMessage<Q,R> |
GenericStreamingQueryMessage.andMetaData(Map<String,?> metaData) |
StreamingQueryMessage<Q,R> |
StreamingQueryMessage.withMetaData(Map<String,?> metaData) |
StreamingQueryMessage<Q,R> |
GenericStreamingQueryMessage.withMetaData(Map<String,?> metaData) |
Modifier and Type | Method and Description |
---|---|
<Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>> |
SimpleQueryBus.streamingQuery(StreamingQueryMessage<Q,R> query) |
default <Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>> |
QueryBus.streamingQuery(StreamingQueryMessage<Q,R> query)
Builds a
Publisher of responses to the given query . |
Copyright © 2010–2023. All rights reserved.