Skip to content

Commit 5967ab6

Browse files
committed
Update CassandraConfigurations
Signed-off-by: Otavio Santana <[email protected]>
1 parent cd896c1 commit 5967ab6

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

jnosql-cassandra-driver/src/main/java/org/eclipse/jnosql/communication/cassandra/column/CassandraConfiguration.java

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,8 +20,10 @@
2020
import jakarta.nosql.column.ColumnConfiguration;
2121

2222
import java.util.HashMap;
23+
import java.util.List;
2324
import java.util.Map;
2425
import java.util.concurrent.ExecutorService;
26+
import java.util.stream.Collectors;
2527

2628
import static java.util.Objects.requireNonNull;
2729

@@ -47,7 +49,12 @@ public CassandraColumnManagerFactory apply(Settings settings) throws NullPointer
4749
requireNonNull(settings, "settings is required");
4850
Map<String, String> configurations = new HashMap<>();
4951

50-
for (String key : settings.keySet()) {
52+
List<String> keys = settings.keySet()
53+
.stream()
54+
.filter(k -> k.startsWith("jnosql."))
55+
.collect(Collectors.toUnmodifiableList());
56+
57+
for (String key : keys) {
5158
settings.get(key, String.class).ifPresent(v -> configurations.put(key, v));
5259
}
5360
return getManagerFactory(configurations);

0 commit comments

Comments
 (0)