Package de.iip_ecosphere.platform.transport.spring.binder.mqttv5

Class MqttV5MessageBinderConfiguration

java.lang.Object
de.iip_ecosphere.platform.transport.spring.binder.mqttv5.MqttV5MessageBinderConfiguration
@Configuration @EnableConfigurationProperties(MqttConfiguration.class) public class MqttV5MessageBinderConfiguration extends Object
Represents the MQTT v5 message binder plugin.
Author:
Holger Eichelberger, SSE

  • Constructor Details

    • MqttV5MessageBinderConfiguration

      public MqttV5MessageBinderConfiguration()

  • Method Details

    • mqttv5BinderProvisioner

      @Bean @ConditionalOnMissingBean public MqttV5MessageBinderProvisioner mqttv5BinderProvisioner(MqttClient client)
      Returns the binder provisioner.
      Parameters:
      client - the client instance (autowired)
      Returns:
      the binder provisioner

    • mqttClient

      @Bean @ConditionalOnMissingBean public MqttClient mqttClient()
      Returns the client instance.
      Returns:
      the client instance

    • mqttv5Binder

      @Bean @ConditionalOnMissingBean public MqttV5MessageBinder mqttv5Binder(MqttV5MessageBinderProvisioner messageBinderProvisioner, MqttClient client)
      Returns the message binder.
      Parameters:
      messageBinderProvisioner - the provisioner with access to the destinations
      client - the client instance (autowired)
      Returns:
      the message binder

    • mqttTransportParameter

      @Bean @ConditionalOnMissingBean public de.iip_ecosphere.platform.transport.connectors.TransportParameter mqttTransportParameter(@Autowired org.springframework.context.ApplicationContext ctx, @Autowired MqttConfiguration config)
      Provides a transport parameter instance configured through the binder configuration.
      Parameters:
      ctx - the current application context (autowired)
      config - the actual MQTT configuration
      Returns:
      the transport parameter instance