Skip to content

Commit 807f7c8

Browse files
authored
Merge pull request #14 from runnerway/bucket-from-template
Take bucket name from CouchbaseTemplate
2 parents 5d8c0c0 + 779b729 commit 807f7c8

File tree

2 files changed

+3
-5
lines changed

2 files changed

+3
-5
lines changed

src/main/java/com/github/mkopylec/sessioncouchbase/configuration/PersistentConfiguration.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,6 @@
2525
@ConditionalOnProperty(name = "session-couchbase.in-memory.enabled", havingValue = "false", matchIfMissing = true)
2626
public class PersistentConfiguration {
2727

28-
@Autowired
29-
protected CouchbaseProperties couchbase;
3028
@Autowired
3129
protected SessionCouchbaseProperties sessionCouchbase;
3230

@@ -51,6 +49,6 @@ public RetryTemplate sessionCouchbaseRetryTemplate(RetryLoggingListener listener
5149
@Bean
5250
@ConditionalOnMissingBean
5351
public SessionDao sessionDao(CouchbaseTemplate couchbaseTemplate, @Qualifier("sessionCouchbaseRetryTemplate") RetryTemplate retryTemplate) {
54-
return new PersistentDao(couchbase, sessionCouchbase, couchbaseTemplate, retryTemplate);
52+
return new PersistentDao(sessionCouchbase, couchbaseTemplate, retryTemplate);
5553
}
5654
}

src/main/java/com/github/mkopylec/sessioncouchbase/data/PersistentDao.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ public class PersistentDao implements SessionDao {
3333
protected final CouchbaseTemplate couchbaseTemplate;
3434
protected final RetryTemplate retryTemplate;
3535

36-
public PersistentDao(CouchbaseProperties couchbase, SessionCouchbaseProperties sessionCouchbase, CouchbaseTemplate couchbaseTemplate, RetryTemplate retryTemplate) {
37-
bucket = couchbase.getBucket().getName();
36+
public PersistentDao(SessionCouchbaseProperties sessionCouchbase, CouchbaseTemplate couchbaseTemplate, RetryTemplate retryTemplate) {
37+
bucket = couchbaseTemplate.getCouchbaseBucket().name();
3838
queryConsistency = sessionCouchbase.getPersistent().getQueryConsistency();
3939
this.couchbaseTemplate = couchbaseTemplate;
4040
this.retryTemplate = retryTemplate;

0 commit comments

Comments
 (0)