github-forks
/
redisson
mirror of https://github.com/redisson/redisson.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Feature - quarkus.redisson.file setting added to define external Redisson config file. #3861

Browse Source
pull/3917/head
Nikita Koksharov 3 years ago
parent 06e370897e
commit 48017daa62
2 changed files with 22 additions and 8 deletions
Show Stats Download Patch File Download Diff File

15
redisson-quarkus/redisson-quarkus-16/deployment/src/main/java/io/quarkus/redisson/client/deployment/QuarkusRedissonClientProcessor.java
Unescape Escape View File

@ -35,6 +35,7 @@ import org.redisson.config.PropertiesConvertor;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.Optional;
/**
*
@ -87,10 +88,16 @@ class QuarkusRedissonClientProcessor {
@BuildStep
@Record(ExecutionTime.RUNTIME_INIT)
RedissonClientItemBuild build(RedissonClientRecorder recorder) throws IOException {
InputStream stream = Thread.currentThread().getContextClassLoader().getResourceAsStream("redisson.yaml");
if (stream != null) {
byte[] array = new byte[stream.available()];
stream.read(array);
InputStream configStream;
Optional<String> configFile = ConfigProvider.getConfig().getOptionalValue("quarkus.redisson.file", String.class);
if (configFile.isPresent()) {
configStream = getClass().getResourceAsStream(configFile.get());
} else {
configStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("redisson.yaml");
}
if (configStream != null) {
byte[] array = new byte[configStream.available()];
configStream.read(array);
recorder.configureRedisson(new String(array, StandardCharsets.UTF_8));
} else {
String yaml = PropertiesConvertor.toYaml("quarkus.redisson.", ConfigProvider.getConfig().getPropertyNames(), prop -> {

15
redisson-quarkus/redisson-quarkus-20/deployment/src/main/java/io/quarkus/redisson/client/deployment/QuarkusRedissonClientProcessor.java
Unescape Escape View File

@ -35,6 +35,7 @@ import org.redisson.config.PropertiesConvertor;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.Optional;
/**
*
@ -87,10 +88,16 @@ class QuarkusRedissonClientProcessor {
@BuildStep
@Record(ExecutionTime.RUNTIME_INIT)
RedissonClientItemBuild build(RedissonClientRecorder recorder) throws IOException {
InputStream stream = Thread.currentThread().getContextClassLoader().getResourceAsStream("redisson.yaml");
if (stream != null) {
byte[] array = new byte[stream.available()];
stream.read(array);
InputStream configStream;
Optional<String> configFile = ConfigProvider.getConfig().getOptionalValue("quarkus.redisson.file", String.class);
if (configFile.isPresent()) {
configStream = getClass().getResourceAsStream(configFile.get());
} else {
configStream = Thread.currentThread().getContextClassLoader().getResourceAsStream("redisson.yaml");
}
if (configStream != null) {
byte[] array = new byte[configStream.available()];
configStream.read(array);
recorder.configureRedisson(new String(array, StandardCharsets.UTF_8));
} else {
String yaml = PropertiesConvertor.toYaml("quarkus.redisson.", ConfigProvider.getConfig().getPropertyNames(), prop -> {

Write Preview
Loading…
Cancel
Save