Class QosBindingSpec.MySubscriber

java.lang.Object

io.micronaut.mqtt.test.bind.qos.QosBindingSpec.MySubscriber

Enclosing class:

QosBindingSpec

@Requires(property="qosbindingspec",
          value="true")
@MqttSubscriber
public static class QosBindingSpec.MySubscriber
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
Integer	qos

Constructor Summary

Constructors

Constructor	Description
MySubscriber()

Method Summary

Modifier and Type	Method	Description
void	get(Integer qos)

Methods inherited from class Object

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

Field Details

qos

public Integer qos

Constructor Details

MySubscriber

public MySubscriber()

Method Details

get

@Topic(value="test/qos",
       qos=2)
public void get(@Qos
 Integer qos)