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

Class MqttV3MessageBinderConfiguration

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

  • Constructor Details

    • MqttV3MessageBinderConfiguration

      public MqttV3MessageBinderConfiguration()

  • Method Details

    • mqttv3BinderProvisioner

      @Bean @ConditionalOnMissingBean public MqttV3MessageBinderProvisioner mqttv3BinderProvisioner(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

    • mqttv3Binder

      @Bean @ConditionalOnMissingBean public MqttV3MessageBinder mqttv3Binder(MqttV3MessageBinderProvisioner 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