Uses of Class
io.axoniq.axonserver.grpc.query.QueryProviderOutbound

Packages that use QueryProviderOutbound

Package	Description
io.axoniq.axonserver.grpc.query
org.axonframework.axonserver.connector
org.axonframework.axonserver.connector.query
org.axonframework.axonserver.connector.query.subscription

Uses of QueryProviderOutbound in io.axoniq.axonserver.grpc.query

Methods in io.axoniq.axonserver.grpc.query that return QueryProviderOutbound

Modifier and Type	Method and Description
QueryProviderOutbound	QueryProviderOutbound.Builder.build()
QueryProviderOutbound	QueryProviderOutbound.Builder.buildPartial()
static QueryProviderOutbound	QueryProviderOutbound.getDefaultInstance()
QueryProviderOutbound	QueryProviderOutbound.getDefaultInstanceForType()
QueryProviderOutbound	QueryProviderOutbound.Builder.getDefaultInstanceForType()
static QueryProviderOutbound	QueryProviderOutbound.parseDelimitedFrom(InputStream input)
static QueryProviderOutbound	QueryProviderOutbound.parseDelimitedFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(byte[] data)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(byte[] data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(ByteBuffer data)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(ByteBuffer data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(com.google.protobuf.ByteString data)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(com.google.protobuf.ByteString data, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(com.google.protobuf.CodedInputStream input)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(com.google.protobuf.CodedInputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(InputStream input)
static QueryProviderOutbound	QueryProviderOutbound.parseFrom(InputStream input, com.google.protobuf.ExtensionRegistryLite extensionRegistry)

Methods in io.axoniq.axonserver.grpc.query that return types with arguments of type QueryProviderOutbound

Modifier and Type	Method and Description
static io.grpc.MethodDescriptor<QueryProviderOutbound,QueryProviderInbound>	QueryServiceGrpc.getOpenStreamMethod()
com.google.protobuf.Parser<QueryProviderOutbound>	QueryProviderOutbound.getParserForType()
io.grpc.stub.StreamObserver<QueryProviderOutbound>	QueryServiceGrpc.QueryServiceImplBase.openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver) Opens a Query- and Instruction stream to AxonServer.
io.grpc.stub.StreamObserver<QueryProviderOutbound>	QueryServiceGrpc.QueryServiceStub.openStream(io.grpc.stub.StreamObserver<QueryProviderInbound> responseObserver) Opens a Query- and Instruction stream to AxonServer.
static com.google.protobuf.Parser<QueryProviderOutbound>	QueryProviderOutbound.parser()

Methods in io.axoniq.axonserver.grpc.query with parameters of type QueryProviderOutbound

Modifier and Type	Method and Description
QueryProviderOutbound.Builder	QueryProviderOutbound.Builder.mergeFrom(QueryProviderOutbound other)
static QueryProviderOutbound.Builder	QueryProviderOutbound.newBuilder(QueryProviderOutbound prototype)

Uses of QueryProviderOutbound in org.axonframework.axonserver.connector

Methods in org.axonframework.axonserver.connector that return types with arguments of type QueryProviderOutbound

Modifier and Type	Method and Description
io.grpc.stub.StreamObserver<QueryProviderOutbound>	AxonServerConnectionManager.getQueryStream(String context, io.grpc.stub.StreamObserver<QueryProviderInbound> inboundQueryStream) Opens a Stream for incoming queries from AxonServer in the given context.

Uses of QueryProviderOutbound in org.axonframework.axonserver.connector.query

Method parameters in org.axonframework.axonserver.connector.query with type arguments of type QueryProviderOutbound

Modifier and Type	Method and Description
AxonServerQueryBus.Builder	AxonServerQueryBus.Builder.instructionAckSource(InstructionAckSource<QueryProviderOutbound> instructionAckSource) Sets the instruction ack source used to send instruction acknowledgements.
AxonServerQueryBus.Builder	AxonServerQueryBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<QueryProviderInbound>,io.grpc.stub.StreamObserver<QueryProviderOutbound>> requestStreamFactory) Sets the request stream factory that creates a request stream based on upstream.

Uses of QueryProviderOutbound in org.axonframework.axonserver.connector.query.subscription

Constructor parameters in org.axonframework.axonserver.connector.query.subscription with type arguments of type QueryProviderOutbound

Constructor and Description
SubscriptionQueryRequestTarget(QueryBus localSegment, Publisher<QueryProviderOutbound> publisher, SubscriptionMessageSerializer serializer) Instantiate a SubscriptionQueryRequestTarget used to receive Subscription Query requests and response.