Package org.axonframework.axonserver.connector.util

Class GrpcBufferingInterceptor

java.lang.Object

org.axonframework.axonserver.connector.util.GrpcBufferingInterceptor

All Implemented Interfaces:

io.grpc.ClientInterceptor

@Deprecated
public class GrpcBufferingInterceptor
extends Object
implements io.grpc.ClientInterceptor

Deprecated.

in through use of the AxonServer java connector

Interceptor that immediately requests a number of messages from the server, to increase the flow of messages.

As an additional message is requested by default each time a message is received, setting an initial request amount will allow that number of messages to be "in transit" before the server stops sending more.

Since:

4.2

Author:

Allard Buijze

Constructor Summary

Constructors

Constructor	Description
GrpcBufferingInterceptor(int additionalBuffer)	Deprecated. Initialize the interceptor to ask for additionalBuffer amount of messages from the server.

Method Summary

Modifier and Type	Method	Description
<ReqT, RespT> io.grpc.ClientCall<ReqT,RespT>	interceptCall(io.grpc.MethodDescriptor<ReqT,RespT> method, io.grpc.CallOptions callOptions, io.grpc.Channel next)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Details

GrpcBufferingInterceptor

public GrpcBufferingInterceptor(int additionalBuffer)

Deprecated.

Initialize the interceptor to ask for additionalBuffer amount of messages from the server.

Parameters:

additionalBuffer - The number of messages the server may send before waiting for permits to be renewed

Method Details

interceptCall

public <ReqT,
RespT> io.grpc.ClientCall<ReqT,RespT> interceptCall(io.grpc.MethodDescriptor<ReqT,RespT> method,
 io.grpc.CallOptions callOptions,
 io.grpc.Channel next)

Deprecated.

Specified by:

interceptCall in interface io.grpc.ClientInterceptor