io.axoniq.axonserver.grpc.query

Interface QueryProviderOutboundOrBuilder

All Superinterfaces:

com.google.protobuf.MessageLiteOrBuilder, com.google.protobuf.MessageOrBuilder

All Known Implementing Classes:

QueryProviderOutbound, QueryProviderOutbound.Builder

public interface QueryProviderOutboundOrBuilder
extends com.google.protobuf.MessageOrBuilder

Method Summary

Modifier and Type	Method and Description
InstructionAck	getAck() Acknowledgement of previously sent instruction via inbound stream
InstructionAckOrBuilder	getAckOrBuilder() Acknowledgement of previously sent instruction via inbound stream
FlowControl	getFlowControl() 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
QueryCompleteOrBuilder	getQueryCompleteOrBuilder() Indicator that all responses for Query have been sent
QueryResponse	getQueryResponse() 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
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
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
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

Methods inherited from interface com.google.protobuf.MessageOrBuilder

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

Methods inherited from interface com.google.protobuf.MessageLiteOrBuilder

isInitialized

Method Detail

hasSubscribe

boolean hasSubscribe()

 Registers a Query Handler with AxonServer 
 

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

getSubscribe

QuerySubscription getSubscribe()

 Registers a Query Handler with AxonServer 
 

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

getSubscribeOrBuilder

QuerySubscriptionOrBuilder getSubscribeOrBuilder()

 Registers a Query Handler with AxonServer 
 

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

hasUnsubscribe

boolean hasUnsubscribe()

 Unregisters a Query Handler with AxonServer 
 

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

getUnsubscribe

QuerySubscription getUnsubscribe()

 Unregisters a Query Handler with AxonServer 
 

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

getUnsubscribeOrBuilder

QuerySubscriptionOrBuilder getUnsubscribeOrBuilder()

 Unregisters a Query Handler with AxonServer 
 

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

hasFlowControl

boolean hasFlowControl()

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

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

getFlowControl

FlowControl getFlowControl()

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

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

getFlowControlOrBuilder

FlowControlOrBuilder getFlowControlOrBuilder()

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

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

hasQueryResponse

boolean hasQueryResponse()

 Sends a Response to a Query received via the inbound stream 
 

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

getQueryResponse

QueryResponse getQueryResponse()

 Sends a Response to a Query received via the inbound stream 
 

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

getQueryResponseOrBuilder

QueryResponseOrBuilder getQueryResponseOrBuilder()

 Sends a Response to a Query received via the inbound stream 
 

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

hasQueryComplete

boolean hasQueryComplete()

 Indicator that all responses for Query have been sent 
 

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

getQueryComplete

QueryComplete getQueryComplete()

 Indicator that all responses for Query have been sent 
 

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

getQueryCompleteOrBuilder

QueryCompleteOrBuilder getQueryCompleteOrBuilder()

 Indicator that all responses for Query have been sent 
 

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

hasSubscriptionQueryResponse

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;

getSubscriptionQueryResponse

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;

getSubscriptionQueryResponseOrBuilder

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;

hasAck

boolean hasAck()

 Acknowledgement of previously sent instruction via inbound stream 
 

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

getAck

InstructionAck getAck()

 Acknowledgement of previously sent instruction via inbound stream 
 

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

getAckOrBuilder

InstructionAckOrBuilder getAckOrBuilder()

 Acknowledgement of previously sent instruction via inbound stream 
 

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

getInstructionId

String getInstructionId()

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

string instruction_id = 8;

getInstructionIdBytes

com.google.protobuf.ByteString getInstructionIdBytes()

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

string instruction_id = 8;

getRequestCase

QueryProviderOutbound.RequestCase getRequestCase()