org.springframework.data.couchbase.config

Class CouchbaseEnvironmentNoShutdownProxy

java.lang.Object

org.springframework.data.couchbase.config.CouchbaseEnvironmentNoShutdownProxy

All Implemented Interfaces:

com.couchbase.client.core.env.CoreEnvironment, com.couchbase.client.java.env.CouchbaseEnvironment

public class CouchbaseEnvironmentNoShutdownProxy
extends Object
implements com.couchbase.client.java.env.CouchbaseEnvironment

A proxy around a CouchbaseEnvironment that prevents its shutdown() method to be invoked. Useful when the delegate is not to be lifecycle-managed by Spring.

Author:

Simon Baslé, Jonathan Edwards

Constructor Summary

Constructors

Constructor and Description
CouchbaseEnvironmentNoShutdownProxy(com.couchbase.client.java.env.CouchbaseEnvironment delegate)

Method Summary

Modifier and Type	Method and Description
long	autoreleaseAfter()
int	bootstrapCarrierDirectPort()
boolean	bootstrapCarrierEnabled()
int	bootstrapCarrierSslPort()
int	bootstrapHttpDirectPort()
boolean	bootstrapHttpEnabled()
int	bootstrapHttpSslPort()
boolean	bufferPoolingEnabled()
boolean	callbacksOnIoPool()
String	clientBuild()
String	clientVersion()
int	computationPoolSize()
long	connectTimeout()
String	coreBuild()
String	coreVersion()
double	dcpConnectionBufferAckThreshold()
int	dcpConnectionBufferSize()
String	dcpConnectionName()
boolean	dcpEnabled()
long	disconnectTimeout()
boolean	dnsSrvEnabled()
com.couchbase.client.core.event.EventBus	eventBus()
com.couchbase.client.deps.io.netty.channel.EventLoopGroup	ioPool()
int	ioPoolSize()
long	keepAliveInterval()
int	kvEndpoints()
long	kvTimeout()
long	managementTimeout()
long	maxRequestLifetime()
boolean	mutationTokensEnabled()
com.couchbase.client.core.metrics.NetworkLatencyMetricsCollector	networkLatencyMetricsCollector()
com.couchbase.client.core.time.Delay	observeIntervalDelay()
String	packageNameAndVersion()
boolean	queryEnabled() Deprecated.
int	queryEndpoints()
int	queryPort() Deprecated.
long	queryTimeout()
com.couchbase.client.core.time.Delay	reconnectDelay()
int	requestBufferSize()
int	responseBufferSize()
com.couchbase.client.core.time.Delay	retryDelay()
com.couchbase.client.core.retry.RetryStrategy	retryStrategy()
com.couchbase.client.core.metrics.MetricsCollector	runtimeMetricsCollector()
rx.Scheduler	scheduler()
int	searchEndpoints()
long	searchTimeout()
rx.Observable<Boolean>	shutdown()
rx.Observable<Boolean>	shutdownAsync()
int	socketConnectTimeout()
boolean	sslEnabled()
String	sslKeystoreFile()
String	sslKeystorePassword()
boolean	tcpNodelayEnabled()
String	userAgent()
int	viewEndpoints()
long	viewTimeout()

Methods inherited from class java.lang.Object

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

Constructor Detail

CouchbaseEnvironmentNoShutdownProxy

public CouchbaseEnvironmentNoShutdownProxy(com.couchbase.client.java.env.CouchbaseEnvironment delegate)

Method Detail

shutdown

public rx.Observable<Boolean> shutdown()

Specified by:

shutdown in interface com.couchbase.client.core.env.CoreEnvironment

shutdownAsync

public rx.Observable<Boolean> shutdownAsync()

Specified by:

shutdownAsync in interface com.couchbase.client.core.env.CoreEnvironment

ioPool

public com.couchbase.client.deps.io.netty.channel.EventLoopGroup ioPool()

Specified by:

ioPool in interface com.couchbase.client.core.env.CoreEnvironment

scheduler

public rx.Scheduler scheduler()

Specified by:

scheduler in interface com.couchbase.client.core.env.CoreEnvironment

dcpEnabled

public boolean dcpEnabled()

Specified by:

dcpEnabled in interface com.couchbase.client.core.env.CoreEnvironment

sslEnabled

public boolean sslEnabled()

Specified by:

sslEnabled in interface com.couchbase.client.core.env.CoreEnvironment

sslKeystoreFile

public String sslKeystoreFile()

Specified by:

sslKeystoreFile in interface com.couchbase.client.core.env.CoreEnvironment

sslKeystorePassword

public String sslKeystorePassword()

Specified by:

sslKeystorePassword in interface com.couchbase.client.core.env.CoreEnvironment

queryEnabled

@Deprecated
public boolean queryEnabled()

Deprecated.

Specified by:

queryEnabled in interface com.couchbase.client.core.env.CoreEnvironment

queryPort

@Deprecated
public int queryPort()

Deprecated.

Specified by:

queryPort in interface com.couchbase.client.core.env.CoreEnvironment

bootstrapHttpEnabled

public boolean bootstrapHttpEnabled()

Specified by:

bootstrapHttpEnabled in interface com.couchbase.client.core.env.CoreEnvironment

bootstrapCarrierEnabled

public boolean bootstrapCarrierEnabled()

Specified by:

bootstrapCarrierEnabled in interface com.couchbase.client.core.env.CoreEnvironment

bootstrapHttpDirectPort

public int bootstrapHttpDirectPort()

Specified by:

bootstrapHttpDirectPort in interface com.couchbase.client.core.env.CoreEnvironment

bootstrapHttpSslPort

public int bootstrapHttpSslPort()

Specified by:

bootstrapHttpSslPort in interface com.couchbase.client.core.env.CoreEnvironment

bootstrapCarrierDirectPort

public int bootstrapCarrierDirectPort()

Specified by:

bootstrapCarrierDirectPort in interface com.couchbase.client.core.env.CoreEnvironment

bootstrapCarrierSslPort

public int bootstrapCarrierSslPort()

Specified by:

bootstrapCarrierSslPort in interface com.couchbase.client.core.env.CoreEnvironment

ioPoolSize

public int ioPoolSize()

Specified by:

ioPoolSize in interface com.couchbase.client.core.env.CoreEnvironment

computationPoolSize

public int computationPoolSize()

Specified by:

computationPoolSize in interface com.couchbase.client.core.env.CoreEnvironment

observeIntervalDelay

public com.couchbase.client.core.time.Delay observeIntervalDelay()

Specified by:

observeIntervalDelay in interface com.couchbase.client.core.env.CoreEnvironment

reconnectDelay

public com.couchbase.client.core.time.Delay reconnectDelay()

Specified by:

reconnectDelay in interface com.couchbase.client.core.env.CoreEnvironment

retryDelay

public com.couchbase.client.core.time.Delay retryDelay()

Specified by:

retryDelay in interface com.couchbase.client.core.env.CoreEnvironment

requestBufferSize

public int requestBufferSize()

Specified by:

requestBufferSize in interface com.couchbase.client.core.env.CoreEnvironment

responseBufferSize

public int responseBufferSize()

Specified by:

responseBufferSize in interface com.couchbase.client.core.env.CoreEnvironment

dcpConnectionBufferSize

public int dcpConnectionBufferSize()

Specified by:

dcpConnectionBufferSize in interface com.couchbase.client.core.env.CoreEnvironment

dcpConnectionBufferAckThreshold

public double dcpConnectionBufferAckThreshold()

Specified by:

dcpConnectionBufferAckThreshold in interface com.couchbase.client.core.env.CoreEnvironment

kvEndpoints

public int kvEndpoints()

Specified by:

kvEndpoints in interface com.couchbase.client.core.env.CoreEnvironment

viewEndpoints

public int viewEndpoints()

Specified by:

viewEndpoints in interface com.couchbase.client.core.env.CoreEnvironment

queryEndpoints

public int queryEndpoints()

Specified by:

queryEndpoints in interface com.couchbase.client.core.env.CoreEnvironment

userAgent

public String userAgent()

Specified by:

userAgent in interface com.couchbase.client.core.env.CoreEnvironment

packageNameAndVersion

public String packageNameAndVersion()

Specified by:

packageNameAndVersion in interface com.couchbase.client.core.env.CoreEnvironment

retryStrategy

public com.couchbase.client.core.retry.RetryStrategy retryStrategy()

Specified by:

retryStrategy in interface com.couchbase.client.core.env.CoreEnvironment

maxRequestLifetime

public long maxRequestLifetime()

Specified by:

maxRequestLifetime in interface com.couchbase.client.core.env.CoreEnvironment

autoreleaseAfter

public long autoreleaseAfter()

Specified by:

autoreleaseAfter in interface com.couchbase.client.core.env.CoreEnvironment

keepAliveInterval

public long keepAliveInterval()

Specified by:

keepAliveInterval in interface com.couchbase.client.core.env.CoreEnvironment

eventBus

public com.couchbase.client.core.event.EventBus eventBus()

Specified by:

eventBus in interface com.couchbase.client.core.env.CoreEnvironment

bufferPoolingEnabled

public boolean bufferPoolingEnabled()

Specified by:

bufferPoolingEnabled in interface com.couchbase.client.core.env.CoreEnvironment

managementTimeout

public long managementTimeout()

Specified by:

managementTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment

queryTimeout

public long queryTimeout()

Specified by:

queryTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment

viewTimeout

public long viewTimeout()

Specified by:

viewTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment

kvTimeout

public long kvTimeout()

Specified by:

kvTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment

connectTimeout

public long connectTimeout()

Specified by:

connectTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment

disconnectTimeout

public long disconnectTimeout()

Specified by:

disconnectTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment

dnsSrvEnabled

public boolean dnsSrvEnabled()

Specified by:

dnsSrvEnabled in interface com.couchbase.client.java.env.CouchbaseEnvironment

networkLatencyMetricsCollector

public com.couchbase.client.core.metrics.NetworkLatencyMetricsCollector networkLatencyMetricsCollector()

Specified by:

networkLatencyMetricsCollector in interface com.couchbase.client.core.env.CoreEnvironment

socketConnectTimeout

public int socketConnectTimeout()

Specified by:

socketConnectTimeout in interface com.couchbase.client.core.env.CoreEnvironment

runtimeMetricsCollector

public com.couchbase.client.core.metrics.MetricsCollector runtimeMetricsCollector()

Specified by:

runtimeMetricsCollector in interface com.couchbase.client.core.env.CoreEnvironment

mutationTokensEnabled

public boolean mutationTokensEnabled()

Specified by:

mutationTokensEnabled in interface com.couchbase.client.core.env.CoreEnvironment

tcpNodelayEnabled

public boolean tcpNodelayEnabled()

Specified by:

tcpNodelayEnabled in interface com.couchbase.client.core.env.CoreEnvironment

callbacksOnIoPool

public boolean callbacksOnIoPool()

Specified by:

callbacksOnIoPool in interface com.couchbase.client.core.env.CoreEnvironment

coreBuild

public String coreBuild()

Specified by:

coreBuild in interface com.couchbase.client.core.env.CoreEnvironment

coreVersion

public String coreVersion()

Specified by:

coreVersion in interface com.couchbase.client.core.env.CoreEnvironment

dcpConnectionName

public String dcpConnectionName()

Specified by:

dcpConnectionName in interface com.couchbase.client.core.env.CoreEnvironment

searchEndpoints

public int searchEndpoints()

Specified by:

searchEndpoints in interface com.couchbase.client.core.env.CoreEnvironment

clientBuild

public String clientBuild()

Specified by:

clientBuild in interface com.couchbase.client.java.env.CouchbaseEnvironment

clientVersion

public String clientVersion()

Specified by:

clientVersion in interface com.couchbase.client.java.env.CouchbaseEnvironment

searchTimeout

public long searchTimeout()

Specified by:

searchTimeout in interface com.couchbase.client.java.env.CouchbaseEnvironment