Package | Description |
---|---|
org.axonframework.axonserver.connector | |
org.axonframework.axonserver.connector.util |
Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getCommandFlowControl() |
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getDefaultFlowControlConfiguration() |
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getEventFlowControl() |
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getQueryFlowControl() |
Modifier and Type | Method and Description |
---|---|
void |
AxonServerConfiguration.setCommandFlowControl(AxonServerConfiguration.FlowControlConfiguration commandFlowControl) |
void |
AxonServerConfiguration.setEventFlowControl(AxonServerConfiguration.FlowControlConfiguration eventFlowControl) |
void |
AxonServerConfiguration.setQueryFlowControl(AxonServerConfiguration.FlowControlConfiguration queryFlowControl) |
Constructor and Description |
---|
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver,
String clientId,
AxonServerConfiguration.FlowControlConfiguration flowControlConfiguration,
Function<io.axoniq.axonserver.grpc.FlowControl,T> requestWrapper,
Predicate<T> isConfirmationMessage)
Deprecated.
Constructs a
FlowControllingStreamObserver . |
Copyright © 2010–2020. All rights reserved.