io.axoniq.axonserver.grpc.query

Class QueryProviderOutbound.Builder

java.lang.Object

com.google.protobuf.AbstractMessageLite.Builder

com.google.protobuf.AbstractMessage.Builder<BuilderType>

com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

io.axoniq.axonserver.grpc.query.QueryProviderOutbound.Builder

All Implemented Interfaces:

com.google.protobuf.Message.Builder, com.google.protobuf.MessageLite.Builder, com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder, QueryProviderOutboundOrBuilder, Cloneable

Enclosing class:

QueryProviderOutbound

public static final class QueryProviderOutbound.Builder
extends com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>
implements QueryProviderOutboundOrBuilder

 Message containing Query related instructions for Axon Server 
 

Protobuf type io.axoniq.axonserver.grpc.query.QueryProviderOutbound

Method Summary

Modifier and Type	Method and Description
QueryProviderOutbound.Builder	addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
QueryProviderOutbound	build()
QueryProviderOutbound	buildPartial()
QueryProviderOutbound.Builder	clear()
QueryProviderOutbound.Builder	clearAck() Acknowledgement of previously sent instruction via inbound stream
QueryProviderOutbound.Builder	clearField(com.google.protobuf.Descriptors.FieldDescriptor field)
QueryProviderOutbound.Builder	clearFlowControl() Grant permits to AxonServer to send a number of messages to the client
QueryProviderOutbound.Builder	clearInstructionId() Instruction identifier.
QueryProviderOutbound.Builder	clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)
QueryProviderOutbound.Builder	clearQueryComplete() Indicator that all responses for Query have been sent
QueryProviderOutbound.Builder	clearQueryResponse() Sends a Response to a Query received via the inbound stream
QueryProviderOutbound.Builder	clearRequest()
QueryProviderOutbound.Builder	clearSubscribe() Registers a Query Handler with AxonServer
QueryProviderOutbound.Builder	clearSubscriptionQueryResponse() Sends a response for a Subscription Query that has been received via the inbound stream
QueryProviderOutbound.Builder	clearUnsubscribe() Unregisters a Query Handler with AxonServer
QueryProviderOutbound.Builder	clone()
InstructionAck	getAck() Acknowledgement of previously sent instruction via inbound stream
InstructionAck.Builder	getAckBuilder() Acknowledgement of previously sent instruction via inbound stream
InstructionAckOrBuilder	getAckOrBuilder() Acknowledgement of previously sent instruction via inbound stream
QueryProviderOutbound	getDefaultInstanceForType()
static com.google.protobuf.Descriptors.Descriptor	getDescriptor()
com.google.protobuf.Descriptors.Descriptor	getDescriptorForType()
FlowControl	getFlowControl() Grant permits to AxonServer to send a number of messages to the client
FlowControl.Builder	getFlowControlBuilder() Grant permits to AxonServer to send a number of messages to the client
FlowControlOrBuilder	getFlowControlOrBuilder() Grant permits to AxonServer to send a number of messages to the client
String	getInstructionId() Instruction identifier.
com.google.protobuf.ByteString	getInstructionIdBytes() Instruction identifier.
QueryComplete	getQueryComplete() Indicator that all responses for Query have been sent
QueryComplete.Builder	getQueryCompleteBuilder() Indicator that all responses for Query have been sent
QueryCompleteOrBuilder	getQueryCompleteOrBuilder() Indicator that all responses for Query have been sent
QueryResponse	getQueryResponse() Sends a Response to a Query received via the inbound stream
QueryResponse.Builder	getQueryResponseBuilder() Sends a Response to a Query received via the inbound stream
QueryResponseOrBuilder	getQueryResponseOrBuilder() Sends a Response to a Query received via the inbound stream
QueryProviderOutbound.RequestCase	getRequestCase()
QuerySubscription	getSubscribe() Registers a Query Handler with AxonServer
QuerySubscription.Builder	getSubscribeBuilder() Registers a Query Handler with AxonServer
QuerySubscriptionOrBuilder	getSubscribeOrBuilder() Registers a Query Handler with AxonServer
SubscriptionQueryResponse	getSubscriptionQueryResponse() Sends a response for a Subscription Query that has been received via the inbound stream
SubscriptionQueryResponse.Builder	getSubscriptionQueryResponseBuilder() Sends a response for a Subscription Query that has been received via the inbound stream
SubscriptionQueryResponseOrBuilder	getSubscriptionQueryResponseOrBuilder() Sends a response for a Subscription Query that has been received via the inbound stream
QuerySubscription	getUnsubscribe() Unregisters a Query Handler with AxonServer
QuerySubscription.Builder	getUnsubscribeBuilder() Unregisters a Query Handler with AxonServer
QuerySubscriptionOrBuilder	getUnsubscribeOrBuilder() Unregisters a Query Handler with AxonServer
boolean	hasAck() Acknowledgement of previously sent instruction via inbound stream
boolean	hasFlowControl() Grant permits to AxonServer to send a number of messages to the client
boolean	hasQueryComplete() Indicator that all responses for Query have been sent
boolean	hasQueryResponse() Sends a Response to a Query received via the inbound stream
boolean	hasSubscribe() Registers a Query Handler with AxonServer
boolean	hasSubscriptionQueryResponse() Sends a response for a Subscription Query that has been received via the inbound stream
boolean	hasUnsubscribe() Unregisters a Query Handler with AxonServer
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable	internalGetFieldAccessorTable()
boolean	isInitialized()
QueryProviderOutbound.Builder	mergeAck(InstructionAck value) Acknowledgement of previously sent instruction via inbound stream
QueryProviderOutbound.Builder	mergeFlowControl(FlowControl value) Grant permits to AxonServer to send a number of messages to the client
QueryProviderOutbound.Builder	mergeFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
QueryProviderOutbound.Builder	mergeFrom(com.google.protobuf.Message other)
QueryProviderOutbound.Builder	mergeFrom(QueryProviderOutbound other)
QueryProviderOutbound.Builder	mergeQueryComplete(QueryComplete value) Indicator that all responses for Query have been sent
QueryProviderOutbound.Builder	mergeQueryResponse(QueryResponse value) Sends a Response to a Query received via the inbound stream
QueryProviderOutbound.Builder	mergeSubscribe(QuerySubscription value) Registers a Query Handler with AxonServer
QueryProviderOutbound.Builder	mergeSubscriptionQueryResponse(SubscriptionQueryResponse value) Sends a response for a Subscription Query that has been received via the inbound stream
QueryProviderOutbound.Builder	mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
QueryProviderOutbound.Builder	mergeUnsubscribe(QuerySubscription value) Unregisters a Query Handler with AxonServer
QueryProviderOutbound.Builder	setAck(InstructionAck.Builder builderForValue) Acknowledgement of previously sent instruction via inbound stream
QueryProviderOutbound.Builder	setAck(InstructionAck value) Acknowledgement of previously sent instruction via inbound stream
QueryProviderOutbound.Builder	setField(com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
QueryProviderOutbound.Builder	setFlowControl(FlowControl.Builder builderForValue) Grant permits to AxonServer to send a number of messages to the client
QueryProviderOutbound.Builder	setFlowControl(FlowControl value) Grant permits to AxonServer to send a number of messages to the client
QueryProviderOutbound.Builder	setInstructionId(String value) Instruction identifier.
QueryProviderOutbound.Builder	setInstructionIdBytes(com.google.protobuf.ByteString value) Instruction identifier.
QueryProviderOutbound.Builder	setQueryComplete(QueryComplete.Builder builderForValue) Indicator that all responses for Query have been sent
QueryProviderOutbound.Builder	setQueryComplete(QueryComplete value) Indicator that all responses for Query have been sent
QueryProviderOutbound.Builder	setQueryResponse(QueryResponse.Builder builderForValue) Sends a Response to a Query received via the inbound stream
QueryProviderOutbound.Builder	setQueryResponse(QueryResponse value) Sends a Response to a Query received via the inbound stream
QueryProviderOutbound.Builder	setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
QueryProviderOutbound.Builder	setSubscribe(QuerySubscription.Builder builderForValue) Registers a Query Handler with AxonServer
QueryProviderOutbound.Builder	setSubscribe(QuerySubscription value) Registers a Query Handler with AxonServer
QueryProviderOutbound.Builder	setSubscriptionQueryResponse(SubscriptionQueryResponse.Builder builderForValue) Sends a response for a Subscription Query that has been received via the inbound stream
QueryProviderOutbound.Builder	setSubscriptionQueryResponse(SubscriptionQueryResponse value) Sends a response for a Subscription Query that has been received via the inbound stream
QueryProviderOutbound.Builder	setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)
QueryProviderOutbound.Builder	setUnsubscribe(QuerySubscription.Builder builderForValue) Unregisters a Query Handler with AxonServer
QueryProviderOutbound.Builder	setUnsubscribe(QuerySubscription value) Unregisters a Query Handler with AxonServer

Methods inherited from class com.google.protobuf.GeneratedMessageV3.Builder

getAllFields, getField, getFieldBuilder, getOneofFieldDescriptor, getParentForChildren, getRepeatedField, getRepeatedFieldBuilder, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof, internalGetMapField, internalGetMutableMapField, isClean, markClean, newBuilderForField, onBuilt, onChanged, setUnknownFieldsProto3

Methods inherited from class com.google.protobuf.AbstractMessage.Builder

findInitializationErrors, getInitializationErrorString, internalMergeFrom, mergeDelimitedFrom, mergeDelimitedFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, mergeFrom, newUninitializedMessageException, toString

Methods inherited from class com.google.protobuf.AbstractMessageLite.Builder

addAll, addAll, mergeFrom, newUninitializedMessageException

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.google.protobuf.MessageOrBuilder

findInitializationErrors, getAllFields, getField, getInitializationErrorString, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, getUnknownFields, hasField, hasOneof

Methods inherited from interface com.google.protobuf.MessageLite.Builder

mergeFrom

Method Detail

getDescriptor

public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()

internalGetFieldAccessorTable

protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()

Specified by:

internalGetFieldAccessorTable in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

clear

public QueryProviderOutbound.Builder clear()

Specified by:

clear in interface com.google.protobuf.Message.Builder

Specified by:

clear in interface com.google.protobuf.MessageLite.Builder

Overrides:

clear in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

getDescriptorForType

public com.google.protobuf.Descriptors.Descriptor getDescriptorForType()

Specified by:

getDescriptorForType in interface com.google.protobuf.Message.Builder

Specified by:

getDescriptorForType in interface com.google.protobuf.MessageOrBuilder

Overrides:

getDescriptorForType in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

getDefaultInstanceForType

public QueryProviderOutbound getDefaultInstanceForType()

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageLiteOrBuilder

Specified by:

getDefaultInstanceForType in interface com.google.protobuf.MessageOrBuilder

build

public QueryProviderOutbound build()

Specified by:

build in interface com.google.protobuf.Message.Builder

Specified by:

build in interface com.google.protobuf.MessageLite.Builder

buildPartial

public QueryProviderOutbound buildPartial()

Specified by:

buildPartial in interface com.google.protobuf.Message.Builder

Specified by:

buildPartial in interface com.google.protobuf.MessageLite.Builder

clone

public QueryProviderOutbound.Builder clone()

Specified by:

clone in interface com.google.protobuf.Message.Builder

Specified by:

clone in interface com.google.protobuf.MessageLite.Builder

Overrides:

clone in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

setField

public QueryProviderOutbound.Builder setField(com.google.protobuf.Descriptors.FieldDescriptor field,
                                              Object value)

Specified by:

setField in interface com.google.protobuf.Message.Builder

Overrides:

setField in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

clearField

public QueryProviderOutbound.Builder clearField(com.google.protobuf.Descriptors.FieldDescriptor field)

Specified by:

clearField in interface com.google.protobuf.Message.Builder

Overrides:

clearField in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

clearOneof

public QueryProviderOutbound.Builder clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof)

Specified by:

clearOneof in interface com.google.protobuf.Message.Builder

Overrides:

clearOneof in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

setRepeatedField

public QueryProviderOutbound.Builder setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
                                                      int index,
                                                      Object value)

Specified by:

setRepeatedField in interface com.google.protobuf.Message.Builder

Overrides:

setRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

addRepeatedField

public QueryProviderOutbound.Builder addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
                                                      Object value)

Specified by:

addRepeatedField in interface com.google.protobuf.Message.Builder

Overrides:

addRepeatedField in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

mergeFrom

public QueryProviderOutbound.Builder mergeFrom(com.google.protobuf.Message other)

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<QueryProviderOutbound.Builder>

mergeFrom

public QueryProviderOutbound.Builder mergeFrom(QueryProviderOutbound other)

isInitialized

public final boolean isInitialized()

Specified by:

isInitialized in interface com.google.protobuf.MessageLiteOrBuilder

Overrides:

isInitialized in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

mergeFrom

public QueryProviderOutbound.Builder mergeFrom(com.google.protobuf.CodedInputStream input,
                                               com.google.protobuf.ExtensionRegistryLite extensionRegistry)
                                        throws IOException

Specified by:

mergeFrom in interface com.google.protobuf.Message.Builder

Specified by:

mergeFrom in interface com.google.protobuf.MessageLite.Builder

Overrides:

mergeFrom in class com.google.protobuf.AbstractMessage.Builder<QueryProviderOutbound.Builder>

Throws:

IOException

getRequestCase

public QueryProviderOutbound.RequestCase getRequestCase()

Specified by:

getRequestCase in interface QueryProviderOutboundOrBuilder

clearRequest

public QueryProviderOutbound.Builder clearRequest()

hasSubscribe

public boolean hasSubscribe()

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

Specified by:

hasSubscribe in interface QueryProviderOutboundOrBuilder

getSubscribe

public QuerySubscription getSubscribe()

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

Specified by:

getSubscribe in interface QueryProviderOutboundOrBuilder

setSubscribe

public QueryProviderOutbound.Builder setSubscribe(QuerySubscription value)

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

setSubscribe

public QueryProviderOutbound.Builder setSubscribe(QuerySubscription.Builder builderForValue)

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

mergeSubscribe

public QueryProviderOutbound.Builder mergeSubscribe(QuerySubscription value)

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

clearSubscribe

public QueryProviderOutbound.Builder clearSubscribe()

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

getSubscribeBuilder

public QuerySubscription.Builder getSubscribeBuilder()

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

getSubscribeOrBuilder

public QuerySubscriptionOrBuilder getSubscribeOrBuilder()

 Registers a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;

Specified by:

getSubscribeOrBuilder in interface QueryProviderOutboundOrBuilder

hasUnsubscribe

public boolean hasUnsubscribe()

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

Specified by:

hasUnsubscribe in interface QueryProviderOutboundOrBuilder

getUnsubscribe

public QuerySubscription getUnsubscribe()

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

Specified by:

getUnsubscribe in interface QueryProviderOutboundOrBuilder

setUnsubscribe

public QueryProviderOutbound.Builder setUnsubscribe(QuerySubscription value)

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

setUnsubscribe

public QueryProviderOutbound.Builder setUnsubscribe(QuerySubscription.Builder builderForValue)

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

mergeUnsubscribe

public QueryProviderOutbound.Builder mergeUnsubscribe(QuerySubscription value)

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

clearUnsubscribe

public QueryProviderOutbound.Builder clearUnsubscribe()

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

getUnsubscribeBuilder

public QuerySubscription.Builder getUnsubscribeBuilder()

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

getUnsubscribeOrBuilder

public QuerySubscriptionOrBuilder getUnsubscribeOrBuilder()

 Unregisters a Query Handler with AxonServer 
 

.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;

Specified by:

getUnsubscribeOrBuilder in interface QueryProviderOutboundOrBuilder

hasFlowControl

public boolean hasFlowControl()

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

Specified by:

hasFlowControl in interface QueryProviderOutboundOrBuilder

getFlowControl

public FlowControl getFlowControl()

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

Specified by:

getFlowControl in interface QueryProviderOutboundOrBuilder

setFlowControl

public QueryProviderOutbound.Builder setFlowControl(FlowControl value)

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

setFlowControl

public QueryProviderOutbound.Builder setFlowControl(FlowControl.Builder builderForValue)

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

mergeFlowControl

public QueryProviderOutbound.Builder mergeFlowControl(FlowControl value)

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

clearFlowControl

public QueryProviderOutbound.Builder clearFlowControl()

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

getFlowControlBuilder

public FlowControl.Builder getFlowControlBuilder()

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

getFlowControlOrBuilder

public FlowControlOrBuilder getFlowControlOrBuilder()

 Grant permits to AxonServer to send a number of messages to the client 
 

.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;

Specified by:

getFlowControlOrBuilder in interface QueryProviderOutboundOrBuilder

hasQueryResponse

public boolean hasQueryResponse()

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

Specified by:

hasQueryResponse in interface QueryProviderOutboundOrBuilder

getQueryResponse

public QueryResponse getQueryResponse()

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

Specified by:

getQueryResponse in interface QueryProviderOutboundOrBuilder

setQueryResponse

public QueryProviderOutbound.Builder setQueryResponse(QueryResponse value)

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

setQueryResponse

public QueryProviderOutbound.Builder setQueryResponse(QueryResponse.Builder builderForValue)

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

mergeQueryResponse

public QueryProviderOutbound.Builder mergeQueryResponse(QueryResponse value)

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

clearQueryResponse

public QueryProviderOutbound.Builder clearQueryResponse()

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

getQueryResponseBuilder

public QueryResponse.Builder getQueryResponseBuilder()

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

getQueryResponseOrBuilder

public QueryResponseOrBuilder getQueryResponseOrBuilder()

 Sends a Response to a Query received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;

Specified by:

getQueryResponseOrBuilder in interface QueryProviderOutboundOrBuilder

hasQueryComplete

public boolean hasQueryComplete()

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

Specified by:

hasQueryComplete in interface QueryProviderOutboundOrBuilder

getQueryComplete

public QueryComplete getQueryComplete()

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

Specified by:

getQueryComplete in interface QueryProviderOutboundOrBuilder

setQueryComplete

public QueryProviderOutbound.Builder setQueryComplete(QueryComplete value)

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

setQueryComplete

public QueryProviderOutbound.Builder setQueryComplete(QueryComplete.Builder builderForValue)

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

mergeQueryComplete

public QueryProviderOutbound.Builder mergeQueryComplete(QueryComplete value)

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

clearQueryComplete

public QueryProviderOutbound.Builder clearQueryComplete()

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

getQueryCompleteBuilder

public QueryComplete.Builder getQueryCompleteBuilder()

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

getQueryCompleteOrBuilder

public QueryCompleteOrBuilder getQueryCompleteOrBuilder()

 Indicator that all responses for Query have been sent 
 

.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;

Specified by:

getQueryCompleteOrBuilder in interface QueryProviderOutboundOrBuilder

hasSubscriptionQueryResponse

public boolean hasSubscriptionQueryResponse()

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

Specified by:

hasSubscriptionQueryResponse in interface QueryProviderOutboundOrBuilder

getSubscriptionQueryResponse

public SubscriptionQueryResponse getSubscriptionQueryResponse()

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

Specified by:

getSubscriptionQueryResponse in interface QueryProviderOutboundOrBuilder

setSubscriptionQueryResponse

public QueryProviderOutbound.Builder setSubscriptionQueryResponse(SubscriptionQueryResponse value)

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

setSubscriptionQueryResponse

public QueryProviderOutbound.Builder setSubscriptionQueryResponse(SubscriptionQueryResponse.Builder builderForValue)

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

mergeSubscriptionQueryResponse

public QueryProviderOutbound.Builder mergeSubscriptionQueryResponse(SubscriptionQueryResponse value)

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

clearSubscriptionQueryResponse

public QueryProviderOutbound.Builder clearSubscriptionQueryResponse()

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

getSubscriptionQueryResponseBuilder

public SubscriptionQueryResponse.Builder getSubscriptionQueryResponseBuilder()

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

getSubscriptionQueryResponseOrBuilder

public SubscriptionQueryResponseOrBuilder getSubscriptionQueryResponseOrBuilder()

 Sends a response for a Subscription Query that has been received via the inbound stream 
 

.io.axoniq.axonserver.grpc.query.SubscriptionQueryResponse subscription_query_response = 6;

Specified by:

getSubscriptionQueryResponseOrBuilder in interface QueryProviderOutboundOrBuilder

hasAck

public boolean hasAck()

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

Specified by:

hasAck in interface QueryProviderOutboundOrBuilder

getAck

public InstructionAck getAck()

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

Specified by:

getAck in interface QueryProviderOutboundOrBuilder

setAck

public QueryProviderOutbound.Builder setAck(InstructionAck value)

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

setAck

public QueryProviderOutbound.Builder setAck(InstructionAck.Builder builderForValue)

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

mergeAck

public QueryProviderOutbound.Builder mergeAck(InstructionAck value)

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

clearAck

public QueryProviderOutbound.Builder clearAck()

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

getAckBuilder

public InstructionAck.Builder getAckBuilder()

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

getAckOrBuilder

public InstructionAckOrBuilder getAckOrBuilder()

 Acknowledgement of previously sent instruction via inbound stream 
 

.io.axoniq.axonserver.grpc.InstructionAck ack = 7;

Specified by:

getAckOrBuilder in interface QueryProviderOutboundOrBuilder

getInstructionId

public String getInstructionId()

 Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream 
 

string instruction_id = 8;

Specified by:

getInstructionId in interface QueryProviderOutboundOrBuilder

getInstructionIdBytes

public com.google.protobuf.ByteString getInstructionIdBytes()

 Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream 
 

string instruction_id = 8;

Specified by:

getInstructionIdBytes in interface QueryProviderOutboundOrBuilder

setInstructionId

public QueryProviderOutbound.Builder setInstructionId(String value)

 Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream 
 

string instruction_id = 8;

clearInstructionId

public QueryProviderOutbound.Builder clearInstructionId()

 Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream 
 

string instruction_id = 8;

setInstructionIdBytes

public QueryProviderOutbound.Builder setInstructionIdBytes(com.google.protobuf.ByteString value)

 Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream 
 

string instruction_id = 8;

setUnknownFields

public final QueryProviderOutbound.Builder setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

Specified by:

setUnknownFields in interface com.google.protobuf.Message.Builder

Overrides:

setUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>

mergeUnknownFields

public final QueryProviderOutbound.Builder mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields)

Specified by:

mergeUnknownFields in interface com.google.protobuf.Message.Builder

Overrides:

mergeUnknownFields in class com.google.protobuf.GeneratedMessageV3.Builder<QueryProviderOutbound.Builder>