io.micronaut.mqtt.v5.intercept

Class MqttIntroductionAdvice

java.lang.Object

io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice<org.eclipse.paho.mqttv5.client.MqttActionListener,org.eclipse.paho.mqttv5.common.MqttMessage>

io.micronaut.mqtt.v5.intercept.MqttIntroductionAdvice

All Implemented Interfaces:

io.micronaut.aop.Interceptor<java.lang.Object,java.lang.Object>, io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>, io.micronaut.core.order.Ordered

@Singleton
public class MqttIntroductionAdvice
extends AbstractMqttIntroductionAdvice<org.eclipse.paho.mqttv5.client.MqttActionListener,org.eclipse.paho.mqttv5.common.MqttMessage>

The MQTT v5 implementation of AbstractMqttIntroductionAdvice.

Since:

1.0.0

Author:

James Kleeh

Field Summary

Fields inherited from interface io.micronaut.aop.Interceptor

HOTSWAP, LAZY, PROXY_TARGET

Fields inherited from interface io.micronaut.core.order.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
MqttIntroductionAdvice(org.eclipse.paho.mqttv5.client.MqttAsyncClient mqttAsyncClient, MqttBinderRegistry binderRegistry)

Method Summary

Modifier and Type	Method and Description
MqttBindingContext<org.eclipse.paho.mqttv5.common.MqttMessage>	createBindingContext(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
org.eclipse.paho.mqttv5.client.MqttActionListener	createListener(java.lang.Runnable onSuccess, java.util.function.Consumer<java.lang.Throwable> onError) Create a listener.
java.lang.Class<? extends java.lang.annotation.Annotation>	getRequiredAnnotation()
java.lang.Object	publish(java.lang.String topic, org.eclipse.paho.mqttv5.common.MqttMessage message, org.eclipse.paho.mqttv5.client.MqttActionListener listener) Publishes the message.

Methods inherited from class io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice

intercept

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.aop.MethodInterceptor

intercept

Methods inherited from interface io.micronaut.core.order.Ordered

getOrder

Constructor Detail

MqttIntroductionAdvice

public MqttIntroductionAdvice(org.eclipse.paho.mqttv5.client.MqttAsyncClient mqttAsyncClient,
                              MqttBinderRegistry binderRegistry)

Method Detail

publish

public java.lang.Object publish(java.lang.String topic,
                                org.eclipse.paho.mqttv5.common.MqttMessage message,
                                org.eclipse.paho.mqttv5.client.MqttActionListener listener)

Description copied from class: AbstractMqttIntroductionAdvice

Publishes the message.

Specified by:

publish in class AbstractMqttIntroductionAdvice<org.eclipse.paho.mqttv5.client.MqttActionListener,org.eclipse.paho.mqttv5.common.MqttMessage>

Parameters:

topic - The topic to publish the message to

message - The message to publish

listener - The publish action listener

Returns:

The result of the publish method

createBindingContext

public MqttBindingContext<org.eclipse.paho.mqttv5.common.MqttMessage> createBindingContext(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)

Specified by:

createBindingContext in class AbstractMqttIntroductionAdvice<org.eclipse.paho.mqttv5.client.MqttActionListener,org.eclipse.paho.mqttv5.common.MqttMessage>

Parameters:

context - The method context

Returns:

The binding context to bind data used in publishing

createListener

public org.eclipse.paho.mqttv5.client.MqttActionListener createListener(java.lang.Runnable onSuccess,
                                                                        java.util.function.Consumer<java.lang.Throwable> onError)

Description copied from class: AbstractMqttIntroductionAdvice

Create a listener.

Specified by:

createListener in class AbstractMqttIntroductionAdvice<org.eclipse.paho.mqttv5.client.MqttActionListener,org.eclipse.paho.mqttv5.common.MqttMessage>

Parameters:

onSuccess - The code to call when a message is sent successfully

onError - The consumer to call in the case of an exception

Returns:

A publish action listener

getRequiredAnnotation

public java.lang.Class<? extends java.lang.annotation.Annotation> getRequiredAnnotation()

Specified by:

getRequiredAnnotation in class AbstractMqttIntroductionAdvice<org.eclipse.paho.mqttv5.client.MqttActionListener,org.eclipse.paho.mqttv5.common.MqttMessage>

Returns:

The implement specific client annotation class