public final class QueryProviderOutbound extends com.google.protobuf.GeneratedMessageV3 implements QueryProviderOutboundOrBuilder
Message containing Query related instructions for Axon ServerProtobuf type
io.axoniq.axonserver.grpc.query.QueryProviderOutbound
Modifier and Type | Class and Description |
---|---|
static class |
QueryProviderOutbound.Builder
Message containing Query related instructions for Axon Server
|
static class |
QueryProviderOutbound.RequestCase |
com.google.protobuf.GeneratedMessageV3.BuilderParent, com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage,BuilderType extends com.google.protobuf.GeneratedMessageV3.ExtendableBuilder<MessageType,BuilderType>>, com.google.protobuf.GeneratedMessageV3.ExtendableMessage<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.ExtendableMessageOrBuilder<MessageType extends com.google.protobuf.GeneratedMessageV3.ExtendableMessage>, com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
Modifier and Type | Field and Description |
---|---|
static int |
ACK_FIELD_NUMBER |
static int |
FLOW_CONTROL_FIELD_NUMBER |
static int |
INSTRUCTION_ID_FIELD_NUMBER |
static int |
QUERY_COMPLETE_FIELD_NUMBER |
static int |
QUERY_RESPONSE_FIELD_NUMBER |
static int |
SUBSCRIBE_FIELD_NUMBER |
static int |
SUBSCRIPTION_QUERY_RESPONSE_FIELD_NUMBER |
static int |
UNSUBSCRIBE_FIELD_NUMBER |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
InstructionAck |
getAck()
Acknowledgement of previously sent instruction via inbound stream
|
InstructionAckOrBuilder |
getAckOrBuilder()
Acknowledgement of previously sent instruction via inbound stream
|
static QueryProviderOutbound |
getDefaultInstance() |
QueryProviderOutbound |
getDefaultInstanceForType() |
static com.google.protobuf.Descriptors.Descriptor |
getDescriptor() |
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.
|
com.google.protobuf.Parser<QueryProviderOutbound> |
getParserForType() |
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() |
int |
getSerializedSize() |
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
|
com.google.protobuf.UnknownFieldSet |
getUnknownFields() |
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
|
int |
hashCode() |
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() |
static QueryProviderOutbound.Builder |
newBuilder() |
static QueryProviderOutbound.Builder |
newBuilder(QueryProviderOutbound prototype) |
QueryProviderOutbound.Builder |
newBuilderForType() |
protected QueryProviderOutbound.Builder |
newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
static QueryProviderOutbound |
parseDelimitedFrom(InputStream input) |
static QueryProviderOutbound |
parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryProviderOutbound |
parseFrom(byte[] data) |
static QueryProviderOutbound |
parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryProviderOutbound |
parseFrom(ByteBuffer data) |
static QueryProviderOutbound |
parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryProviderOutbound |
parseFrom(com.google.protobuf.ByteString data) |
static QueryProviderOutbound |
parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryProviderOutbound |
parseFrom(com.google.protobuf.CodedInputStream input) |
static QueryProviderOutbound |
parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static QueryProviderOutbound |
parseFrom(InputStream input) |
static QueryProviderOutbound |
parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static com.google.protobuf.Parser<QueryProviderOutbound> |
parser() |
QueryProviderOutbound.Builder |
toBuilder() |
void |
writeTo(com.google.protobuf.CodedOutputStream output) |
canUseUnsafe, computeStringSize, computeStringSizeNoTag, emptyBooleanList, emptyDoubleList, emptyFloatList, emptyIntList, emptyLongList, getAllFields, getDescriptorForType, getField, getOneofFieldDescriptor, getRepeatedField, getRepeatedFieldCount, hasField, hasOneof, internalGetMapField, makeExtensionsImmutable, mutableCopy, mutableCopy, mutableCopy, mutableCopy, mutableCopy, newBooleanList, newBuilderForType, newDoubleList, newFloatList, newIntList, newLongList, parseDelimitedWithIOException, parseDelimitedWithIOException, parseUnknownField, parseUnknownFieldProto3, parseWithIOException, parseWithIOException, parseWithIOException, parseWithIOException, serializeBooleanMapTo, serializeIntegerMapTo, serializeLongMapTo, serializeStringMapTo, writeReplace, writeString, writeStringNoTag
findInitializationErrors, getInitializationErrorString, hashBoolean, hashEnum, hashEnumList, hashFields, hashLong, toString
addAll, addAll, checkByteStringIsUtf8, toByteArray, toByteString, writeDelimitedTo, writeTo
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
public static final int SUBSCRIBE_FIELD_NUMBER
public static final int UNSUBSCRIBE_FIELD_NUMBER
public static final int FLOW_CONTROL_FIELD_NUMBER
public static final int QUERY_RESPONSE_FIELD_NUMBER
public static final int QUERY_COMPLETE_FIELD_NUMBER
public static final int SUBSCRIPTION_QUERY_RESPONSE_FIELD_NUMBER
public static final int ACK_FIELD_NUMBER
public static final int INSTRUCTION_ID_FIELD_NUMBER
public final com.google.protobuf.UnknownFieldSet getUnknownFields()
getUnknownFields
in interface com.google.protobuf.MessageOrBuilder
getUnknownFields
in class com.google.protobuf.GeneratedMessageV3
public static final com.google.protobuf.Descriptors.Descriptor getDescriptor()
protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable internalGetFieldAccessorTable()
internalGetFieldAccessorTable
in class com.google.protobuf.GeneratedMessageV3
public QueryProviderOutbound.RequestCase getRequestCase()
getRequestCase
in interface QueryProviderOutboundOrBuilder
public boolean hasSubscribe()
Registers a Query Handler with AxonServer
.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;
hasSubscribe
in interface QueryProviderOutboundOrBuilder
public QuerySubscription getSubscribe()
Registers a Query Handler with AxonServer
.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;
getSubscribe
in interface QueryProviderOutboundOrBuilder
public QuerySubscriptionOrBuilder getSubscribeOrBuilder()
Registers a Query Handler with AxonServer
.io.axoniq.axonserver.grpc.query.QuerySubscription subscribe = 1;
getSubscribeOrBuilder
in interface QueryProviderOutboundOrBuilder
public boolean hasUnsubscribe()
Unregisters a Query Handler with AxonServer
.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;
hasUnsubscribe
in interface QueryProviderOutboundOrBuilder
public QuerySubscription getUnsubscribe()
Unregisters a Query Handler with AxonServer
.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;
getUnsubscribe
in interface QueryProviderOutboundOrBuilder
public QuerySubscriptionOrBuilder getUnsubscribeOrBuilder()
Unregisters a Query Handler with AxonServer
.io.axoniq.axonserver.grpc.query.QuerySubscription unsubscribe = 2;
getUnsubscribeOrBuilder
in interface QueryProviderOutboundOrBuilder
public boolean hasFlowControl()
Grant permits to AxonServer to send a number of messages to the client
.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
hasFlowControl
in interface QueryProviderOutboundOrBuilder
public FlowControl getFlowControl()
Grant permits to AxonServer to send a number of messages to the client
.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
getFlowControl
in interface QueryProviderOutboundOrBuilder
public FlowControlOrBuilder getFlowControlOrBuilder()
Grant permits to AxonServer to send a number of messages to the client
.io.axoniq.axonserver.grpc.FlowControl flow_control = 3;
getFlowControlOrBuilder
in interface QueryProviderOutboundOrBuilder
public boolean hasQueryResponse()
Sends a Response to a Query received via the inbound stream
.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;
hasQueryResponse
in interface QueryProviderOutboundOrBuilder
public QueryResponse getQueryResponse()
Sends a Response to a Query received via the inbound stream
.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;
getQueryResponse
in interface QueryProviderOutboundOrBuilder
public QueryResponseOrBuilder getQueryResponseOrBuilder()
Sends a Response to a Query received via the inbound stream
.io.axoniq.axonserver.grpc.query.QueryResponse query_response = 4;
getQueryResponseOrBuilder
in interface QueryProviderOutboundOrBuilder
public boolean hasQueryComplete()
Indicator that all responses for Query have been sent
.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;
hasQueryComplete
in interface QueryProviderOutboundOrBuilder
public QueryComplete getQueryComplete()
Indicator that all responses for Query have been sent
.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;
getQueryComplete
in interface QueryProviderOutboundOrBuilder
public QueryCompleteOrBuilder getQueryCompleteOrBuilder()
Indicator that all responses for Query have been sent
.io.axoniq.axonserver.grpc.query.QueryComplete query_complete = 5;
getQueryCompleteOrBuilder
in interface QueryProviderOutboundOrBuilder
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;
hasSubscriptionQueryResponse
in interface QueryProviderOutboundOrBuilder
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;
getSubscriptionQueryResponse
in interface QueryProviderOutboundOrBuilder
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;
getSubscriptionQueryResponseOrBuilder
in interface QueryProviderOutboundOrBuilder
public boolean hasAck()
Acknowledgement of previously sent instruction via inbound stream
.io.axoniq.axonserver.grpc.InstructionAck ack = 7;
hasAck
in interface QueryProviderOutboundOrBuilder
public InstructionAck getAck()
Acknowledgement of previously sent instruction via inbound stream
.io.axoniq.axonserver.grpc.InstructionAck ack = 7;
getAck
in interface QueryProviderOutboundOrBuilder
public InstructionAckOrBuilder getAckOrBuilder()
Acknowledgement of previously sent instruction via inbound stream
.io.axoniq.axonserver.grpc.InstructionAck ack = 7;
getAckOrBuilder
in interface QueryProviderOutboundOrBuilder
public String getInstructionId()
Instruction identifier. If this identifier is set, this instruction will be acknowledged via inbound stream
string instruction_id = 8;
getInstructionId
in interface QueryProviderOutboundOrBuilder
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;
getInstructionIdBytes
in interface QueryProviderOutboundOrBuilder
public final boolean isInitialized()
isInitialized
in interface com.google.protobuf.MessageLiteOrBuilder
isInitialized
in class com.google.protobuf.GeneratedMessageV3
public void writeTo(com.google.protobuf.CodedOutputStream output) throws IOException
writeTo
in interface com.google.protobuf.MessageLite
writeTo
in class com.google.protobuf.GeneratedMessageV3
IOException
public int getSerializedSize()
getSerializedSize
in interface com.google.protobuf.MessageLite
getSerializedSize
in class com.google.protobuf.GeneratedMessageV3
public boolean equals(Object obj)
equals
in interface com.google.protobuf.Message
equals
in class com.google.protobuf.AbstractMessage
public int hashCode()
hashCode
in interface com.google.protobuf.Message
hashCode
in class com.google.protobuf.AbstractMessage
public static QueryProviderOutbound parseFrom(ByteBuffer data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static QueryProviderOutbound parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static QueryProviderOutbound parseFrom(com.google.protobuf.ByteString data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static QueryProviderOutbound parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static QueryProviderOutbound parseFrom(byte[] data) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static QueryProviderOutbound parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws com.google.protobuf.InvalidProtocolBufferException
com.google.protobuf.InvalidProtocolBufferException
public static QueryProviderOutbound parseFrom(InputStream input) throws IOException
IOException
public static QueryProviderOutbound parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static QueryProviderOutbound parseDelimitedFrom(InputStream input) throws IOException
IOException
public static QueryProviderOutbound parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public static QueryProviderOutbound parseFrom(com.google.protobuf.CodedInputStream input) throws IOException
IOException
public static QueryProviderOutbound parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws IOException
IOException
public QueryProviderOutbound.Builder newBuilderForType()
newBuilderForType
in interface com.google.protobuf.Message
newBuilderForType
in interface com.google.protobuf.MessageLite
public static QueryProviderOutbound.Builder newBuilder()
public static QueryProviderOutbound.Builder newBuilder(QueryProviderOutbound prototype)
public QueryProviderOutbound.Builder toBuilder()
toBuilder
in interface com.google.protobuf.Message
toBuilder
in interface com.google.protobuf.MessageLite
protected QueryProviderOutbound.Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent)
newBuilderForType
in class com.google.protobuf.GeneratedMessageV3
public static QueryProviderOutbound getDefaultInstance()
public static com.google.protobuf.Parser<QueryProviderOutbound> parser()
public com.google.protobuf.Parser<QueryProviderOutbound> getParserForType()
getParserForType
in interface com.google.protobuf.Message
getParserForType
in interface com.google.protobuf.MessageLite
getParserForType
in class com.google.protobuf.GeneratedMessageV3
public QueryProviderOutbound getDefaultInstanceForType()
getDefaultInstanceForType
in interface com.google.protobuf.MessageLiteOrBuilder
getDefaultInstanceForType
in interface com.google.protobuf.MessageOrBuilder
Copyright © 2010–2020. All rights reserved.