Class RetainedBindingSpec.MySubscriber

java.lang.Object
io.micronaut.mqtt.test.bind.retained.RetainedBindingSpec.MySubscriber
Enclosing class:
RetainedBindingSpec

@Requires(property="retainedbindingspec", value="true") @MqttSubscriber public static class RetainedBindingSpec.MySubscriber extends Object
  • Field Details

    • payload

      public String payload
  • Constructor Details

    • MySubscriber

      public MySubscriber()
  • Method Details

    • get

      @Topic("test/retained") public void get(@Nullable @MessageBody String payload)