Package io.quarkus.smallrye.reactivemessaging.mqtt.runtime

Class MqttClientConfigCustomizer

java.lang.Object

io.quarkus.smallrye.reactivemessaging.mqtt.runtime.MqttClientConfigCustomizer

All Implemented Interfaces:

io.smallrye.reactive.messaging.ClientCustomizer<io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions>, jakarta.enterprise.inject.spi.Prioritized

@ApplicationScoped
public class MqttClientConfigCustomizer
extends Object
implements io.smallrye.reactive.messaging.ClientCustomizer<io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) io.quarkus.tls.TlsConfigurationRegistry	tlsRegistry

Fields inherited from interface io.smallrye.reactive.messaging.ClientCustomizer

CLIENT_CONFIG_CUSTOMIZER_DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor	Description
MqttClientConfigCustomizer()

Method Summary

Modifier and Type	Method	Description
io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions	customize(String channel, org.eclipse.microprofile.config.Config channelConfig, io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.smallrye.reactive.messaging.ClientCustomizer

getPriority

Field Details

tlsRegistry

@Inject
io.quarkus.tls.TlsConfigurationRegistry tlsRegistry

Constructor Details

MqttClientConfigCustomizer

public MqttClientConfigCustomizer()

Method Details

customize

public io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions customize(String channel,
 org.eclipse.microprofile.config.Config channelConfig,
 io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions options)

Specified by:

customize in interface io.smallrye.reactive.messaging.ClientCustomizer<io.smallrye.reactive.messaging.mqtt.session.MqttClientSessionOptions>