Q
- the type of streaming query payloadR
- the type of the result streamed via Publisher
public interface StreamingQueryMessage<Q,R> extends QueryMessage<Q,org.reactivestreams.Publisher<R>>
QueryMessage
used for initiating streaming queries. It's special since it hard codes the
response type to PublisherResponseType
.Modifier and Type | Method and Description |
---|---|
StreamingQueryMessage<Q,R> |
andMetaData(Map<String,?> additionalMetaData)
Returns a copy of this QueryMessage with its MetaData merged with given
metaData . |
ResponseType<org.reactivestreams.Publisher<R>> |
getResponseType()
The type of response expected by the sender of the query
|
StreamingQueryMessage<Q,R> |
withMetaData(Map<String,?> metaData)
Returns a copy of this QueryMessage with the given
metaData . |
getQueryName, queryName
getIdentifier, getMetaData, getPayload, getPayloadType, serializeMetaData, serializePayload
ResponseType<org.reactivestreams.Publisher<R>> getResponseType()
QueryMessage
getResponseType
in interface QueryMessage<Q,org.reactivestreams.Publisher<R>>
StreamingQueryMessage<Q,R> withMetaData(Map<String,?> metaData)
QueryMessage
metaData
. The payload remains unchanged.withMetaData
in interface Message<Q>
withMetaData
in interface QueryMessage<Q,org.reactivestreams.Publisher<R>>
metaData
- The new MetaData for the QueryMessageStreamingQueryMessage<Q,R> andMetaData(Map<String,?> additionalMetaData)
QueryMessage
metaData
. The payload remains
unchanged.andMetaData
in interface Message<Q>
andMetaData
in interface QueryMessage<Q,org.reactivestreams.Publisher<R>>
additionalMetaData
- The MetaData to merge into the QueryMessageCopyright © 2010–2023. All rights reserved.