package com.fastbee.mqtt.annotation;
|
|
import io.netty.handler.codec.mqtt.MqttMessageType;
|
import org.springframework.stereotype.Component;
|
|
import java.lang.annotation.ElementType;
|
import java.lang.annotation.Retention;
|
import java.lang.annotation.RetentionPolicy;
|
import java.lang.annotation.Target;
|
|
|
@Target(ElementType.TYPE)
|
@Retention(RetentionPolicy.RUNTIME)
|
/*自动注入bean*/
|
@Component
|
public @interface Process {
|
|
|
/*消息类型*/
|
MqttMessageType type() default MqttMessageType.PUBLISH;
|
}
|
