| 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<FlowControl,T> requestWrapper,
Predicate<T> isConfirmationMessage) |
Copyright © 2010–2020. All rights reserved.