From cbe77e5fd490e81b936670d5ca17cb1e57c76835 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Simon=20Basl=C3=A9?= <simon.basle@gmail.com>
Date: Tue, 1 Dec 2015 11:19:41 +0100
Subject: [PATCH] DATACOUCH-177 - Upgrade SDK dependency to 2.2.2

---
 pom.xml                                       |  4 ++--
 .../CouchbaseEnvironmentNoShutdownProxy.java  | 20 +++++++++++++++++++
 2 files changed, 22 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 9e013040..5d3ba427 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,8 +21,8 @@
 
         <dist.key>DATACOUCH</dist.key>
 
-        <couchbase>2.2.0</couchbase>
-        <couchbase.osgi>2.2.0</couchbase.osgi>
+        <couchbase>2.2.2</couchbase>
+        <couchbase.osgi>2.2.2</couchbase.osgi>
         <jackson>2.6.0</jackson>
         <springdata.commons>1.11.0.BUILD-SNAPSHOT</springdata.commons>
         <validation>1.0.0.GA</validation>
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<Boolean> 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();