org.axonframework.axonserver.connector.util

Class FlowControllingStreamObserver<T>

java.lang.Object

org.axonframework.axonserver.connector.util.FlowControllingStreamObserver<T>

All Implemented Interfaces:

io.grpc.stub.StreamObserver<T>

public class FlowControllingStreamObserver<T>
extends Object
implements io.grpc.stub.StreamObserver<T>

Wrapper around the standard StreamObserver that guarantees that the onNext calls are executed in a thread-safe manner. Also maintains flow control sending a new message with permits to AxonServer when it is ready to handle more messages

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver, AxonServerConfiguration configuration, Function<FlowControl,T> requestWrapper, Predicate<T> isConfirmationMessage)

Method Summary

Modifier and Type	Method and Description
void	markConsumed(Integer consumed) notifies the stream observer that [@code consumed} messages are processed by the client.
void	onCompleted()
void	onError(Throwable throwable)
void	onNext(T t)
FlowControllingStreamObserver<T>	sendInitialPermits()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowControllingStreamObserver

public FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver,
                                     AxonServerConfiguration configuration,
                                     Function<FlowControl,T> requestWrapper,
                                     Predicate<T> isConfirmationMessage)

Parameters:

wrappedStreamObserver - stream observer to send messages to AxonServer

configuration - AxonServer configuration for flow control

requestWrapper - Function to create a new permits request

isConfirmationMessage - predicate to test if the message sent to AxonServer is a confirmation message

Method Detail

sendInitialPermits

public FlowControllingStreamObserver<T> sendInitialPermits()

onNext

public void onNext(T t)

Specified by:

onNext in interface io.grpc.stub.StreamObserver<T>

onError

public void onError(Throwable throwable)

Specified by:

onError in interface io.grpc.stub.StreamObserver<T>

onCompleted

public void onCompleted()

Specified by:

onCompleted in interface io.grpc.stub.StreamObserver<T>

markConsumed

public void markConsumed(Integer consumed)

notifies the stream observer that [@code consumed} messages are processed by the client. Triggers a new permits request when remaining permits is 0

Parameters:

consumed - nr of messages consumed