Skip to content

Commit af88b25

Browse files
committed
Fix build
1 parent ea4ee80 commit af88b25

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/main/java/com/kapeta/spring/mongo/AbstractMongoDBConfig.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
package com.kapeta.spring.mongo;
22

33

4-
import com.blockware.spring.cluster.BlockwareClusterService;
54
import com.fasterxml.jackson.databind.ObjectMapper;
65
import com.fasterxml.jackson.databind.node.ObjectNode;
6+
import com.kapeta.spring.cluster.KapetaClusterService;
77
import com.mongodb.*;
88
import com.mongodb.client.MongoClient;
99
import com.mongodb.client.MongoClients;
@@ -37,7 +37,7 @@ abstract public class AbstractMongoDBConfig {
3737
private static final String PORT_TYPE = "mongodb";
3838

3939
@Autowired
40-
private BlockwareClusterService blockwareConfigSource;
40+
private KapetaClusterService blockwareConfigSource;
4141

4242
@Autowired
4343
private ObjectMapper objectMapper;
@@ -57,7 +57,7 @@ protected AbstractMongoDBConfig(String resourceName) {
5757

5858
@Bean
5959
public MongoClient createClient() {
60-
final BlockwareClusterService.ResourceInfo mongoInfo = blockwareConfigSource.getResourceInfo(RESOURCE_TYPE, PORT_TYPE, resourceName);
60+
final KapetaClusterService.ResourceInfo mongoInfo = blockwareConfigSource.getResourceInfo(RESOURCE_TYPE, PORT_TYPE, resourceName);
6161
Optional<String> dbUsername = Optional.ofNullable(mongoInfo.getCredentials().get("username"));
6262
Optional<String> dbPassword = Optional.ofNullable(mongoInfo.getCredentials().get("password"));
6363

0 commit comments

Comments
 (0)