DcpChannel is not using the configured dcpChannelsReconnectMaxAttempts

In the line 213, method dispatchReconnect() of the class DcpChannel, the following code makes the Client reconnect:

connect()

.retryWhen(any().max(Integer.MAX_VALUE).delay(Delay.exponential(TimeUnit.MILLISECONDS, 4096, 32))

.doOnRetry(new Action4<Integer, Throwable, Long, TimeUnit>() {

@Override

public void call(Integer integer, Throwable throwable, Long aLong, TimeUnit timeUnit) {

LOGGER.debug("Rescheduling Node reconnect for DCP channel {}", inetAddress);

}

}).build())

Maybe the original idea was to use the value configured when the
[com|eclipse-javadoc:%E2%98%82=dcp-client/src%5C/main%5C/java%3Ccom].[couchbase|eclipse-javadoc:%E2%98%82=dcp-client/src%5C/main%5C/java%3Ccom.couchbase].[client|eclipse-javadoc:%E2%98%82=dcp-client/src%5C/main%5C/java%3Ccom.couchbase.client].[dcp|eclipse-javadoc:%E2%98%82=dcp-client/src%5C/main%5C/java%3Ccom.couchbase.client.dcp].Client  is instantiated, in the following way:
 

connect()

.retryWhen(any().max(env.dcpChannelsReconnectMaxAttempts()).delay(Delay.exponential(TimeUnit.MILLISECONDS, 4096, 32))