io.micronaut.mqtt.intercept

Class AbstractMqttIntroductionAdvice<L,M>

java.lang.Object

io.micronaut.mqtt.intercept.AbstractMqttIntroductionAdvice<L,M>

Type Parameters:

L - The listener type

M - The message type

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

Direct Known Subclasses:

MqttIntroductionAdvice, MqttIntroductionAdvice

public abstract class AbstractMqttIntroductionAdvice<L,M>
extends java.lang.Object
implements io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>

Intercepts calls to MQTT clients to publish messages.

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
AbstractMqttIntroductionAdvice(MqttBinderRegistry binderRegistry)

Method Summary

Modifier and Type	Method and Description
abstract MqttBindingContext<M>	createBindingContext(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
abstract L	createListener(java.lang.Runnable onSuccess, java.util.function.Consumer<java.lang.Throwable> onError) Create a listener.
abstract java.lang.Class<? extends java.lang.annotation.Annotation>	getRequiredAnnotation()
java.lang.Object	intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)
abstract java.lang.Object	publish(java.lang.String topic, M message, L listener) Publishes the message.

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

AbstractMqttIntroductionAdvice

public AbstractMqttIntroductionAdvice(MqttBinderRegistry binderRegistry)

Method Detail

intercept

public java.lang.Object intercept(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)

Specified by:

intercept in interface io.micronaut.aop.MethodInterceptor<java.lang.Object,java.lang.Object>

createBindingContext

public abstract MqttBindingContext<M> createBindingContext(io.micronaut.aop.MethodInvocationContext<java.lang.Object,java.lang.Object> context)

Parameters:

context - The method context

Returns:

The binding context to bind data used in publishing

publish

public abstract java.lang.Object publish(java.lang.String topic,
                                         M message,
                                         L listener)

Publishes the message.

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

createListener

public abstract L createListener(java.lang.Runnable onSuccess,
                                 java.util.function.Consumer<java.lang.Throwable> onError)

Create a listener.

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 abstract java.lang.Class<? extends java.lang.annotation.Annotation> getRequiredAnnotation()

Returns:

The implement specific client annotation class