Change riak property name

This commit is contained in:
malkoas 2022-10-19 14:59:56 +03:00
parent 0832d069a6
commit 5437197c94
5 changed files with 7 additions and 7 deletions

View File

@ -10,10 +10,10 @@ import org.springframework.context.annotation.Configuration;
@Configuration
public class RiakConfig {
@Value("${riak.port}")
@Value("${riak-config.port}")
public int riakPort;
@Value("${riak.address}")
@Value("${riak-config.address}")
public String riakAddress;
@Bean

View File

@ -27,7 +27,7 @@ public class ListRepository implements CrudRepository<Row, String> {
private static final String TEXT_PLAIN = "text/plain";
private final RiakClient client;
@Value("${riak.bucket}")
@Value("${riak-config.bucket}")
private String bucket;
@Override

View File

@ -37,7 +37,7 @@ spring:
streams:
application-id: wb-list
client-id: wb-list-client
riak:
riak-config:
address: localhost
port: 8087
bucket: wblist

View File

@ -29,7 +29,7 @@ public class RiakTest {
private static final String VALUE = "value";
private static final String KEY = "key";
@Value("${riak.bucket}")
@Value("${riak-config.bucket}")
private String bucketName;
@Autowired

View File

@ -62,8 +62,8 @@ public class RiakTestcontainerExtension implements BeforeAllCallback, AfterAllCa
var container = THREAD_CONTAINER.get();
if (container != null) {
TestPropertyValues.of(
"riak.address=" + container.getContainerIpAddress(),
"riak.port=" + container.getMappedPort(8087))
"riak-config.address=" + container.getContainerIpAddress(),
"riak-config.port=" + container.getMappedPort(8087))
.applyTo(context);
}
};