diff --git a/pom.xml b/pom.xml
index 9e013040..5d3ba427 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,8 +21,8 @@
DATACOUCH
- 2.2.0
- 2.2.0
+ 2.2.2
+ 2.2.2
2.6.0
1.11.0.BUILD-SNAPSHOT
1.0.0.GA
diff --git a/src/main/java/org/springframework/data/couchbase/config/CouchbaseEnvironmentNoShutdownProxy.java b/src/main/java/org/springframework/data/couchbase/config/CouchbaseEnvironmentNoShutdownProxy.java
index 93821210..05e250e9 100644
--- a/src/main/java/org/springframework/data/couchbase/config/CouchbaseEnvironmentNoShutdownProxy.java
+++ b/src/main/java/org/springframework/data/couchbase/config/CouchbaseEnvironmentNoShutdownProxy.java
@@ -47,6 +47,11 @@ public class CouchbaseEnvironmentNoShutdownProxy implements CouchbaseEnvironment
//===== DELEGATION METHODS =====
+ @Override
+ public Observable shutdownAsync() {
+ return delegate.shutdownAsync();
+ }
+
@Override
public EventLoopGroup ioPool() {
return delegate.ioPool();
@@ -154,6 +159,16 @@ public class CouchbaseEnvironmentNoShutdownProxy implements CouchbaseEnvironment
return delegate.responseBufferSize();
}
+ @Override
+ public int dcpConnectionBufferSize() {
+ return delegate.dcpConnectionBufferSize();
+ }
+
+ @Override
+ public double dcpConnectionBufferAckThreshold() {
+ return delegate.dcpConnectionBufferAckThreshold();
+ }
+
@Override
public int kvEndpoints() {
return delegate.kvEndpoints();
@@ -249,6 +264,11 @@ public class CouchbaseEnvironmentNoShutdownProxy implements CouchbaseEnvironment
return delegate.networkLatencyMetricsCollector();
}
+ @Override
+ public int socketConnectTimeout() {
+ return delegate.socketConnectTimeout();
+ }
+
@Override
public MetricsCollector runtimeMetricsCollector() {
return delegate.runtimeMetricsCollector();