Class DefaultMqttBinder

java.lang.Object
io.micronaut.mqtt.bind.impl.DefaultMqttBinder
All Implemented Interfaces:
FallbackMqttBinder<MqttBindingContext<?>>, MqttBinder<MqttBindingContext<?>,Object>

@Singleton public class DefaultMqttBinder extends Object implements FallbackMqttBinder<MqttBindingContext<?>>
The FallbackMqttBinder to bind arguments that don't match any annotated or typed based binder. Matches arguments to properties in the message based on the argument name. If the name is not recognized, the argument is bound with the payload of the message.
Since:
1.0.0
Author:
James Kleeh
  • Constructor Details

  • Method Details

    • bindTo

      public void bindTo(MqttBindingContext<?> context, Object value, io.micronaut.core.type.Argument<Object> argument)
      Description copied from interface: MqttBinder
      Binds the given value to the given context. Publisher method arguments will be passed to this method.
      Specified by:
      bindTo in interface MqttBinder<MqttBindingContext<?>,Object>
      Parameters:
      context - The message context
      value - The argument value
      argument - The publisher argument
    • bindFrom

      public Optional<Object> bindFrom(MqttBindingContext<?> context, io.micronaut.core.convert.ArgumentConversionContext<Object> conversionContext)
      Description copied from interface: MqttBinder
      Binds the given context and returns an optional value. Subscriber method arguments will be passed to this method.
      Specified by:
      bindFrom in interface MqttBinder<MqttBindingContext<?>,Object>
      Parameters:
      context - The method context
      conversionContext - The argument conversion context
      Returns:
      An optional value