Package | Description |
---|---|
org.axonframework.axonserver.connector | |
org.axonframework.axonserver.connector.util |
Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getCommandFlowControl()
Specific
flow control settings for the command message stream. |
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getDefaultFlowControlConfiguration()
The default
flow control settings used when no specific
command , event , or
query flow control settings are provided. |
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getEventFlowControl()
Specific flow control settings for the event message stream.
|
AxonServerConfiguration.FlowControlConfiguration |
AxonServerConfiguration.getQueryFlowControl()
Specific
flow control settings for the query message stream. |
Modifier and Type | Method and Description |
---|---|
void |
AxonServerConfiguration.setCommandFlowControl(AxonServerConfiguration.FlowControlConfiguration commandFlowControl)
Sets specific
flow control settings for the command message stream. |
void |
AxonServerConfiguration.setEventFlowControl(AxonServerConfiguration.FlowControlConfiguration eventFlowControl)
Sets specific
flow control settings for the event message stream. |
void |
AxonServerConfiguration.setQueryFlowControl(AxonServerConfiguration.FlowControlConfiguration queryFlowControl)
Sets specific
flow control settings for the query message stream. |
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–2024. All rights reserved.