Overridden Cluster connect method

teetangh · teetangh · commit d203c1b77fa9 · 2024-01-08T13:58:43.000+05:30
diff --git a/src/main/java/org/couchbase/quickstart/springdata/config/CouchbaseConfiguration.java b/src/main/java/org/couchbase/quickstart/springdata/config/CouchbaseConfiguration.java
@@ -9,6 +9,7 @@
 import com.couchbase.client.core.msg.kv.DurabilityLevel;
 import com.couchbase.client.java.Bucket;
 import com.couchbase.client.java.Cluster;
+import com.couchbase.client.java.env.ClusterEnvironment;
 import com.couchbase.client.java.manager.bucket.BucketSettings;
 import com.couchbase.client.java.manager.bucket.BucketType;
 
@@ -81,4 +82,10 @@ public Bucket getCouchbaseBucket(Cluster cluster){
     } 
     return cluster.bucket(getBucketName());
   }
+
+   @Override
+    @Bean(destroyMethod = "disconnect")
+    public Cluster couchbaseCluster(ClusterEnvironment couchbaseClusterEnvironment) {
+		  return Cluster.connect(getConnectionString(),getUserName(),getPassword());
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@`
`9`	`9`	`import com.couchbase.client.core.msg.kv.DurabilityLevel;`
`10`	`10`	`import com.couchbase.client.java.Bucket;`
`11`	`11`	`import com.couchbase.client.java.Cluster;`
	`12`	`+import com.couchbase.client.java.env.ClusterEnvironment;`
`12`	`13`	`import com.couchbase.client.java.manager.bucket.BucketSettings;`
`13`	`14`	`import com.couchbase.client.java.manager.bucket.BucketType;`
`14`	`15`
`@@ -81,4 +82,10 @@ public Bucket getCouchbaseBucket(Cluster cluster){`
`81`	`82`	`}`
`82`	`83`	`return cluster.bucket(getBucketName());`
`83`	`84`	`}`
	`85`	`+`
	`86`	`+ @Override`
	`87`	`+ @Bean(destroyMethod = "disconnect")`
	`88`	`+ public Cluster couchbaseCluster(ClusterEnvironment couchbaseClusterEnvironment) {`
	`89`	`+ return Cluster.connect(getConnectionString(),getUserName(),getPassword());`
	`90`	`+ }`
`84`	`91`	`}`