diff --git a/bom/pom.xml b/bom/pom.xml
index 919647b523..d422a7869d 100644
--- a/bom/pom.xml
+++ b/bom/pom.xml
@@ -430,11 +430,21 @@ quarkus.vertx.max-event-loop-execute-time=${max.event-loop.execute-time:20000}
hono-service-command-router${project.version}
+
+ org.eclipse.hono
+ client-device-connection
+ ${project.version}
+ org.eclipse.honoclient-device-connection-infinispan${project.version}
+
+ org.eclipse.hono
+ client-device-connection-redis
+ ${project.version}
+ org.eclipse.honohono-client-application
diff --git a/client-device-connection-infinispan/pom.xml b/client-device-connection-infinispan/pom.xml
index b24f28db0b..c951d639ef 100644
--- a/client-device-connection-infinispan/pom.xml
+++ b/client-device-connection-infinispan/pom.xml
@@ -34,6 +34,7 @@
org.slf4jslf4j-api
+
org.infinispaninfinispan-core-jakarta
@@ -59,18 +60,35 @@
+
+
+ org.eclipse.hono
+ hono-core
+
+
+ org.eclipse.hono
+ client-device-connection
+ org.eclipse.honohono-client-common
+
io.vertx
- vertx-web
+ vertx-core
+
com.google.guavaguava
+
+
+ io.smallrye.config
+ smallrye-config-core
+
+
io.quarkusquarkus-core
diff --git a/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/BasicCache.java b/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/BasicCache.java
index 9373aae86f..3fdaa5ce77 100644
--- a/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/BasicCache.java
+++ b/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/BasicCache.java
@@ -24,6 +24,7 @@
import java.util.function.Function;
import org.eclipse.hono.client.ServerErrorException;
+import org.eclipse.hono.deviceconnection.common.Cache;
import org.eclipse.hono.util.Futures;
import org.eclipse.hono.util.Lifecycle;
import org.infinispan.commons.api.BasicCacheContainer;
diff --git a/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/HotrodCache.java b/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/HotrodCache.java
index 4e3b3ea9b1..693a5e7904 100644
--- a/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/HotrodCache.java
+++ b/client-device-connection-infinispan/src/main/java/org/eclipse/hono/deviceconnection/infinispan/client/HotrodCache.java
@@ -18,6 +18,7 @@
import java.util.Objects;
import java.util.concurrent.atomic.AtomicBoolean;
+import org.eclipse.hono.deviceconnection.common.CommonCacheConfig;
import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheContainer;
import org.infinispan.client.hotrod.RemoteCacheManager;
@@ -174,7 +175,6 @@ protected void postCacheAccess(final AsyncResult cacheOperationResult) {
*/
@Override
public Future checkForCacheAvailability() {
-
if (isStarted()) {
final ConnectionCheckResult lastResult = lastConnectionCheckResult;
if (lastResult != null && !lastResult.isOlderThan(CACHED_CONNECTION_CHECK_RESULT_MAX_AGE)) {
diff --git a/client-device-connection-infinispan/src/test/java/org/eclipse/hono/deviceconnection/infinispan/client/QuarkusPropertyBindingTest.java b/client-device-connection-infinispan/src/test/java/org/eclipse/hono/deviceconnection/infinispan/client/RemoteCacheQuarkusPropertyBindingTest.java
similarity index 85%
rename from client-device-connection-infinispan/src/test/java/org/eclipse/hono/deviceconnection/infinispan/client/QuarkusPropertyBindingTest.java
rename to client-device-connection-infinispan/src/test/java/org/eclipse/hono/deviceconnection/infinispan/client/RemoteCacheQuarkusPropertyBindingTest.java
index 53fe74cf6a..fe52d57ff5 100644
--- a/client-device-connection-infinispan/src/test/java/org/eclipse/hono/deviceconnection/infinispan/client/QuarkusPropertyBindingTest.java
+++ b/client-device-connection-infinispan/src/test/java/org/eclipse/hono/deviceconnection/infinispan/client/RemoteCacheQuarkusPropertyBindingTest.java
@@ -25,24 +25,10 @@
import org.junit.jupiter.api.Test;
/**
- * Tests verifying binding of configuration properties to {@link CommonCacheConfig} and
- * {@link InfinispanRemoteConfigurationProperties}.
+ * Tests verifying binding of configuration properties to {@link InfinispanRemoteConfigurationProperties}.
*
*/
-public class QuarkusPropertyBindingTest {
-
- @Test
- void testCommonCacheConfigurationPropertiesArePickedUp() {
-
- final var commonCacheConfig = new CommonCacheConfig(
- ConfigMappingSupport.getConfigMapping(
- CommonCacheOptions.class,
- this.getClass().getResource("/common-cache-options.yaml")));
-
- assertThat(commonCacheConfig.getCacheName()).isEqualTo("the-cache");
- assertThat(commonCacheConfig.getCheckKey()).isEqualTo("the-key");
- assertThat(commonCacheConfig.getCheckValue()).isEqualTo("the-value");
- }
+public class RemoteCacheQuarkusPropertyBindingTest {
@SuppressWarnings("deprecation")
@Test
diff --git a/client-device-connection-redis/pom.xml b/client-device-connection-redis/pom.xml
new file mode 100644
index 0000000000..25a09d01ad
--- /dev/null
+++ b/client-device-connection-redis/pom.xml
@@ -0,0 +1,125 @@
+
+
+
+ 4.0.0
+
+ org.eclipse.hono
+ hono-bom
+ 2.6.0-SNAPSHOT
+ ../bom
+
+ client-device-connection-redis
+
+ Redis Device Connection client
+ A Redis based client for accessing device connection information in a Redis cluster.
+
+
+
+ org.eclipse.hono
+ client-device-connection
+
+
+
+ io.quarkus
+ quarkus-vertx
+
+
+
+ org.eclipse.hono
+ hono-legal
+
+
+ org.eclipse.hono
+ hono-core
+
+
+
+ org.slf4j
+ slf4j-api
+
+
+
+ io.smallrye.config
+ smallrye-config
+
+
+
+ io.vertx
+ vertx-core
+
+
+ io.vertx
+ vertx-redis-client
+
+
+
+
+ org.junit.jupiter
+ junit-jupiter-engine
+ test
+
+
+ org.junit.jupiter
+ junit-jupiter-params
+ test
+
+
+ com.google.truth
+ truth
+ test
+
+
+ ch.qos.logback
+ logback-classic
+ test
+
+
+ org.mockito
+ mockito-core
+ test
+
+
+ io.vertx
+ vertx-junit5
+ test
+
+
+ org.eclipse.hono
+ core-test-utils
+ test
+
+
+
+
+
+
+ org.apache.maven.plugins
+ maven-dependency-plugin
+
+
+ org.apache.maven.plugins
+ maven-checkstyle-plugin
+
+
+ org.jboss.jandex
+ jandex-maven-plugin
+
+
+ org.jacoco
+ jacoco-maven-plugin
+
+
+
+
diff --git a/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/RedisCacheVertx.java b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/RedisCacheVertx.java
new file mode 100644
index 0000000000..9777fdb181
--- /dev/null
+++ b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/RedisCacheVertx.java
@@ -0,0 +1,206 @@
+/**
+ * Copyright (c) 2023 Contributors to the Eclipse Foundation
+ *
+ * See the NOTICE file(s) distributed with this work for additional
+ * information regarding copyright ownership.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0
+ *
+ * SPDX-License-Identifier: EPL-2.0
+ */
+
+package org.eclipse.hono.deviceconnection.redis.client;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+import org.eclipse.hono.deviceconnection.common.Cache;
+import org.eclipse.hono.util.Lifecycle;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import io.vertx.core.Future;
+import io.vertx.core.json.JsonObject;
+import io.vertx.redis.client.RedisAPI;
+import io.vertx.redis.client.Response;
+
+/**
+ * TODO.
+ */
+public class RedisCacheVertx implements Cache, Lifecycle {
+
+ private static final Logger LOG = LoggerFactory.getLogger(RedisCacheVertx.class);
+
+ private final RedisAPI api;
+
+ /**
+ * TODO.
+ *
+ * @param api TODO.
+ */
+ private RedisCacheVertx(final RedisAPI api) {
+ Objects.requireNonNull(api);
+ this.api = api;
+ }
+
+ /**
+ * TODO.
+ *
+ * @param api TODO.
+ * @return TODO.
+ */
+ public static RedisCacheVertx from(final RedisAPI api) {
+ Objects.requireNonNull(api);
+ return new RedisCacheVertx(api);
+ }
+
+ @Override
+ public Future start() {
+ LOG.info("VREDIS: start()");
+ return checkForCacheAvailability().mapEmpty();
+ }
+
+ @Override
+ public Future stop() {
+ LOG.info("VREDIS: stop()");
+ api.close();
+ return Future.succeededFuture();
+ }
+
+ @Override
+ public Future checkForCacheAvailability() {
+ LOG.info("VREDIS: checkForCacheAvailability()");
+ Objects.requireNonNull(api);
+
+ return api.ping(List.of())
+ .map(new JsonObject());
+ }
+
+ @Override
+ public Future put(final String key, final String value) {
+ LOG.info("VREDIS: put {}={}", key, value);
+ Objects.requireNonNull(api);
+
+ return api.set(List.of(String.valueOf(key), String.valueOf(value)))
+ .mapEmpty();
+ }
+
+ @Override
+ public Future put(final String key, final String value, final long lifespan, final TimeUnit lifespanUnit) {
+ LOG.info("VREDIS: put {}={} ({} {})", key, value, lifespan, lifespanUnit);
+ Objects.requireNonNull(api);
+
+ final List params = new ArrayList<>(List.of(key, value));
+ final long millis = lifespanUnit.toMillis(lifespan);
+ if (millis > 0) {
+ params.addAll(List.of("PX", String.valueOf(millis)));
+ }
+ return api.set(params)
+ .mapEmpty();
+ }
+
+ @Override
+ public Future putAll(final Map data) {
+ LOG.info("VREDIS: putAll ({})", data.size());
+ Objects.requireNonNull(api);
+
+ final List keyValues = new ArrayList<>(data.size() * 2);
+ data.forEach((k, v) -> {
+ keyValues.add(k);
+ keyValues.add(v);
+ });
+ return api.mset(keyValues)
+ .mapEmpty();
+ }
+
+ @Override
+ public Future putAll(final Map data, final long lifespan,
+ final TimeUnit lifespanUnit) {
+ LOG.info("VREDIS: putAll ({}) ({} {})", data.size(), lifespan, lifespanUnit);
+ Objects.requireNonNull(api);
+
+ final long millis = lifespanUnit.toMillis(lifespan);
+ return api.multi()
+ .compose(ignored -> {
+ final List> futures = new ArrayList<>(data.size());
+ data.forEach((k, v) -> {
+ final List params = new ArrayList<>(List.of(String.valueOf(k), String.valueOf(v)));
+ if (millis > 0) {
+ params.addAll(List.of("PX", String.valueOf(millis)));
+ }
+ futures.add(api.set(params));
+ });
+ return Future.all(Collections.unmodifiableList(futures));
+ })
+ .compose(ignored -> api.exec())
+ // null reply means transaction aborted
+ .map(Objects::nonNull)
+ .mapEmpty();
+ }
+
+ @Override
+ public Future get(final String key) {
+ LOG.info("VREDIS: get {}", key);
+ Objects.requireNonNull(api);
+
+ return api.get(String.valueOf(key))
+ .compose(value -> Future.succeededFuture(String.valueOf(value)));
+ }
+
+ @Override
+ public Future remove(final String key, final String value) {
+ LOG.info("VREDIS: remove {}={}", key, value);
+ Objects.requireNonNull(api);
+
+ return api.watch(List.of(String.valueOf(key)))
+ .compose(ignored -> api.get(String.valueOf(key)))
+ .compose(response -> {
+ if (response == null) {
+ // key does not exist
+ return Future.succeededFuture(false);
+ }
+ if (String.valueOf(response).equals(value)) {
+ return api.multi()
+ .compose(ignored -> api.del(List.of(String.valueOf(key))))
+ .compose(ignored -> api.exec())
+ // null reply means transaction aborted
+ .map(Objects::nonNull);
+ } else {
+ return Future.succeededFuture(false);
+ }
+ });
+ }
+
+ @Override
+ public Future> getAll(final Set keys) {
+ LOG.info("VREDIS: getAll ({})", keys.size());
+ Objects.requireNonNull(api);
+
+ final LinkedList keyList = new LinkedList<>(keys.stream().map(String::valueOf).toList());
+ final Map result = new HashMap<>(keyList.size());
+ return api.mget(keyList)
+ .compose(values -> {
+ values.forEach(i -> {
+ try {
+ if (i != null) { // TODO: this is kinda strange but some results are null and the BasicCache does not include those in the returned result. Ask about/investigate.
+ result.put(keyList.removeFirst(), i.toString());
+ } else {
+ keyList.removeFirst();
+ }
+ } catch (Exception e) {
+ LOG.info(" - got exception {}", e.getMessage());
+ }
+ });
+ return Future.succeededFuture(result);
+ });
+ }
+}
diff --git a/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/NetConfig.java b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/NetConfig.java
new file mode 100644
index 0000000000..9c5d89402f
--- /dev/null
+++ b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/NetConfig.java
@@ -0,0 +1,135 @@
+/**
+ * TODO.
+ */
+package org.eclipse.hono.deviceconnection.redis.client.config;
+
+import java.time.Duration;
+import java.util.List;
+import java.util.Optional;
+import java.util.OptionalInt;
+import java.util.Set;
+
+
+/**
+ * TODO.
+ */
+@SuppressWarnings("checkstyle:JavadocMethod")
+public interface NetConfig {
+
+ /**
+ * Set the ALPN usage.
+ */
+ Optional alpn();
+
+ /**
+ * Sets the list of application-layer protocols to provide to the server during the
+ * {@code Application-Layer Protocol Negotiation}.
+ */
+ Optional> applicationLayerProtocols();
+
+ /**
+ * Sets the list of enabled SSL/TLS protocols.
+ */
+ Optional> secureTransportProtocols();
+
+ /**
+ * Set the idle timeout.
+ */
+ Optional idleTimeout();
+
+ /**
+ * Set the connect timeout.
+ */
+ Optional connectionTimeout();
+
+ /**
+ * Set a list of remote hosts that are not proxied when the client is configured to use a proxy.
+ */
+ Optional> nonProxyHosts();
+
+ /**
+ * Set proxy options for connections via CONNECT proxy.
+ */
+ ProxyConfig proxyOptions();
+
+ /**
+ * Set the read idle timeout.
+ */
+ Optional readIdleTimeout();
+
+ /**
+ * Set the TCP receive buffer size.
+ */
+ OptionalInt receiveBufferSize();
+
+ /**
+ * Set the value of reconnect attempts.
+ */
+ OptionalInt reconnectAttempts();
+
+ /**
+ * Set the reconnect interval.
+ */
+ Optional reconnectInterval();
+
+ /**
+ * Whether to reuse the address.
+ */
+ Optional reuseAddress();
+
+ /**
+ * Whether to reuse the port.
+ */
+ Optional reusePort();
+
+ /**
+ * Set the TCP send buffer size.
+ */
+ OptionalInt sendBufferSize();
+
+ /**
+ * Set the {@code SO_linger} keep alive duration.
+ */
+ Optional soLinger();
+
+ /**
+ * Enable the {@code TCP_CORK} option - only with linux native transport.
+ */
+ Optional cork();
+
+ /**
+ * Enable the {@code TCP_FASTOPEN} option - only with linux native transport.
+ */
+ Optional fastOpen();
+
+ /**
+ * Set whether keep alive is enabled.
+ */
+ Optional keepAlive();
+
+ /**
+ * Set whether no delay is enabled.
+ */
+ Optional noDelay();
+
+ /**
+ * Enable the {@code TCP_QUICKACK} option - only with linux native transport.
+ */
+ Optional quickAck();
+
+ /**
+ * Set the value of traffic class.
+ */
+ OptionalInt trafficClass();
+
+ /**
+ * Set the write idle timeout.
+ */
+ Optional writeIdleTimeout();
+
+ /**
+ * Set the local interface to bind for network connections.
+ * When the local address is null, it will pick any local address, the default local address is null.
+ */
+ Optional localAddress();
+}
diff --git a/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/ProxyConfig.java b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/ProxyConfig.java
new file mode 100644
index 0000000000..970d4ba628
--- /dev/null
+++ b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/ProxyConfig.java
@@ -0,0 +1,47 @@
+/**
+ * TODO.
+ */
+package org.eclipse.hono.deviceconnection.redis.client.config;
+
+import java.util.Optional;
+
+import io.quarkus.runtime.annotations.ConfigGroup;
+import io.smallrye.config.WithDefault;
+import io.vertx.core.net.ProxyType;
+
+/**
+ * TODO.
+ */
+@SuppressWarnings("checkstyle:JavadocMethod")
+@ConfigGroup
+public interface ProxyConfig {
+
+ /**
+ * Set proxy username.
+ */
+ Optional username();
+
+ /**
+ * Set proxy password.
+ */
+ Optional password();
+
+ /**
+ * Set proxy port. Defaults to 3128.
+ */
+ @WithDefault("3128")
+ int port();
+
+ /**
+ * Set proxy host.
+ */
+ Optional host();
+
+ /**
+ * Set proxy type.
+ * Accepted values are: {@code HTTP} (default), {@code SOCKS4} and {@code SOCKS5}.
+ */
+ @WithDefault("http")
+ ProxyType type();
+
+}
diff --git a/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/RedisConfig.java b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/RedisConfig.java
new file mode 100644
index 0000000000..1af2377a34
--- /dev/null
+++ b/client-device-connection-redis/src/main/java/org/eclipse/hono/deviceconnection/redis/client/config/RedisConfig.java
@@ -0,0 +1,197 @@
+/**
+ * TODO.
+ */
+package org.eclipse.hono.deviceconnection.redis.client.config;
+
+import java.net.URI;
+import java.time.Duration;
+import java.util.Optional;
+import java.util.Set;
+
+import io.smallrye.config.ConfigMapping;
+import io.smallrye.config.WithDefault;
+import io.vertx.redis.client.RedisClientType;
+import io.vertx.redis.client.RedisReplicas;
+import io.vertx.redis.client.RedisRole;
+
+/**
+ * TODO.
+ */
+@SuppressWarnings("checkstyle:JavadocMethod")
+@ConfigMapping(prefix = "hono.cache.redis") //, namingStrategy = ConfigMapping.NamingStrategy.VERBATIM)
+public interface RedisConfig {
+
+ /**
+ * The redis hosts to use while connecting to the redis server. Only the cluster and sentinel modes will consider more than
+ * 1 element.
+ *
+ * The URI provided uses the following schema `redis://[username:password@][host][:port][/database]`
+ * Use `quarkus.redis.hosts-provider-name` to provide the hosts programmatically.
+ *
+ * It is the {@code @Named} value of the hosts provider bean. It is used to discriminate if multiple
+ * `io.quarkus.redis.client.RedisHostsProvider` beans are available.
+ *
+ *
+ * Used when `quarkus.redis.hosts` is not set.
+ */
+ Optional hostsProviderName();
+
+ /**
+ * The maximum delay to wait before a blocking command to redis server times out.
+ */
+ @WithDefault("10s")
+ Duration timeout();
+
+ /**
+ * The redis client type.
+ * Accepted values are: {@code STANDALONE} (default), {@code CLUSTER}, {@code REPLICATION}, {@code SENTINEL}.
+ */
+ @WithDefault("standalone")
+ RedisClientType clientType();
+
+ /**
+ * The master name (only considered in HA mode).
+ */
+ Optional masterName();
+
+ /**
+ * The role name (only considered in Sentinel / HA mode).
+ * Accepted values are: {@code MASTER}, {@code REPLICA}, {@code SENTINEL}.
+ */
+ Optional role();
+
+ /**
+ * Whether to use replicas nodes (only considered in Cluster mode).
+ * Accepted values are: {@code ALWAYS}, {@code NEVER}, {@code SHARE}.
+ */
+ Optional replicas();
+
+ /**
+ * The default password for cluster/sentinel connections.
+ *
+ * If not set it will try to extract the value from the current default {@code #hosts}.
+ */
+ Optional password();
+
+ /**
+ * The maximum size of the connection pool. When working with cluster or sentinel.
+ *
+ * This value should be at least the total number of cluster member (or number of sentinels + 1)
+ */
+ @WithDefault("6")
+ int maxPoolSize();
+
+ /**
+ * The maximum waiting requests for a connection from the pool.
+ */
+ @WithDefault("24")
+ int maxPoolWaiting();
+
+ /**
+ * The duration indicating how often should the connection pool cleaner executes.
+ */
+ Optional poolCleanerInterval();
+
+ /**
+ * The timeout for a connection recycling.
+ */
+ @WithDefault("15")
+ Duration poolRecycleTimeout();
+
+ /**
+ * Sets how many handlers is the client willing to queue.
+ *
+ * The client will always work on pipeline mode, this means that messages can start queueing.
+ * Using this configuration option, you can control how much backlog you're willing to accept.
+ */
+ @WithDefault("2048")
+ int maxWaitingHandlers();
+
+ /**
+ * Tune how much nested arrays are allowed on a redis response. This affects the parser performance.
+ */
+ @WithDefault("32")
+ int maxNestedArrays();
+
+ /**
+ * The number of reconnection attempts when a pooled connection cannot be established on first try.
+ */
+ @WithDefault("0")
+ int reconnectAttempts();
+
+ /**
+ * The interval between reconnection attempts when a pooled connection cannot be established on first try.
+ */
+ @WithDefault("1")
+ Duration reconnectInterval();
+
+ /**
+ * Should the client perform {@code RESP} protocol negotiation during the connection handshake.
+ */
+ @WithDefault("true")
+ boolean protocolNegotiation();
+
+ /*
+ * The preferred protocol version to be used during protocol negotiation. When not set,
+ * defaults to RESP 3. When protocol negotiation is disabled, this setting has no effect.
+ */
+ //Optional preferredProtocolVersion();
+
+ /**
+ * The TTL of the hash slot cache. A hash slot cache is used by the clustered Redis client
+ * to prevent constantly sending {@code CLUSTER SLOTS} commands to the first statically
+ * configured cluster node.
+ *
+ * When enabled, {@code key-certificate-jks} and {@code #key-certificate-pfx} must be disabled.
+ */
+ PemKeyCert keyCertificatePem();
+
+ /**
+ * Key/cert configuration in the JKS format.
+ *
+ * When enabled, {@code #key-certificate-pem} and {@code #key-certificate-pfx} must be disabled.
+ */
+ Jks keyCertificateJks();
+
+ /**
+ * Key/cert configuration in the PFX format.
+ *
+ * When enabled, {@code key-certificate-jks} and {@code #key-certificate-pem} must be disabled.
+ */
+ Pfx keyCertificatePfx();
+
+ /**
+ * The hostname verification algorithm to use in case the server's identity should be checked.
+ * Should be {@code HTTPS}, {@code LDAPS} or an {@code NONE} (default).
+ *
+ * If set to {@code NONE}, it does not verify the hostname.
+ *