Index (anteros-mqtt-core 1.0.7 API)

A B C D E F G H I K L M N O P Q R S T U V W
All Classes All Packages

A

AbstractMqttMessageDispatcher - Class in br.com.anteros.mqtt.core.server.dispatcher: 内部消息转发抽象
AbstractMqttMessageDispatcher() - Constructor for class br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher
active(String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 激活 session，标记 expire 的 session 为永久
active(String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
add(K, V) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
addAll(K, Set<? extends V>) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
addFilter(int, HttpFilter) - Static method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes: 注册路由
addFilter(HttpFilter) - Static method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes: 注册路由
addPaddingSubscribe(int, MqttPendingSubscription) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
addPaddingSubscribe(int, MqttPendingSubscription) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 添加订阅
addPaddingUnSubscribe(int, MqttPendingUnSubscription) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
addPaddingUnSubscribe(int, MqttPendingUnSubscription) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 添加取消订阅过程消息
addPendingPublish(int, MqttPendingPublish) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
addPendingPublish(int, MqttPendingPublish) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 添加过程消息
addPendingPublish(String, int, MqttPendingPublish) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 添加发布过程存储
addPendingPublish(String, int, MqttPendingPublish) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
addPendingQos2Publish(int, MqttPendingQos2Publish) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
addPendingQos2Publish(int, MqttPendingQos2Publish) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 添加 qos2 过程消息
addPendingQos2Publish(String, int, MqttPendingQos2Publish) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 添加发布过程存储
addPendingQos2Publish(String, int, MqttPendingQos2Publish) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
addRetainMessage(String, Message) - Method in interface br.com.anteros.mqtt.core.server.store.IMqttMessageStore: 存储 retain 消息
addRetainMessage(String, Message) - Method in class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
addSubscribe(String, String, int) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 添加订阅存储
addSubscribe(String, String, int) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
addSubscriptionList(List<MqttClientSubscription>) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
addSubscriptionList(List<MqttClientSubscription>) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 添加订阅
addWillMessage(String, Message) - Method in interface br.com.anteros.mqtt.core.server.store.IMqttMessageStore: 存储 clientId 的遗嘱消息
addWillMessage(String, Message) - Method in class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
apply(HttpRequest) - Method in interface br.com.anteros.mqtt.core.server.http.handler.HttpHandler: 处理请求
authenticate(ChannelContext, String, String, String, String) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerAuthHandler: 认证
authenticate(ChannelContext, String, String, String, String) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerAuthHandler
authHandler(IMqttServerAuthHandler) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
AUTHORIZATION_PREFIX - Static variable in class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter

B

base64 - br.com.anteros.mqtt.core.util.PayloadEncode
BaseForm - Class in br.com.anteros.mqtt.core.server.http.api.form: 基础模型
BaseForm() - Constructor for class br.com.anteros.mqtt.core.server.http.api.form.BaseForm
BASIC_AUTH_HEADER_NAME - Static variable in class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter
BASIC_REALM - Static variable in class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter
BasicAuthFilter - Class in br.com.anteros.mqtt.core.server.http.api.auth: Basic 认证
BasicAuthFilter(String, String) - Constructor for class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter
br.com.anteros.mqtt.core.client - package br.com.anteros.mqtt.core.client
br.com.anteros.mqtt.core.common - package br.com.anteros.mqtt.core.common
br.com.anteros.mqtt.core.server - package br.com.anteros.mqtt.core.server
br.com.anteros.mqtt.core.server.auth - package br.com.anteros.mqtt.core.server.auth
br.com.anteros.mqtt.core.server.bridge - package br.com.anteros.mqtt.core.server.bridge
br.com.anteros.mqtt.core.server.broker - package br.com.anteros.mqtt.core.server.broker
br.com.anteros.mqtt.core.server.cluster - package br.com.anteros.mqtt.core.server.cluster
br.com.anteros.mqtt.core.server.dispatcher - package br.com.anteros.mqtt.core.server.dispatcher
br.com.anteros.mqtt.core.server.event - package br.com.anteros.mqtt.core.server.event
br.com.anteros.mqtt.core.server.http.api - package br.com.anteros.mqtt.core.server.http.api
br.com.anteros.mqtt.core.server.http.api.auth - package br.com.anteros.mqtt.core.server.http.api.auth
br.com.anteros.mqtt.core.server.http.api.code - package br.com.anteros.mqtt.core.server.http.api.code
br.com.anteros.mqtt.core.server.http.api.form - package br.com.anteros.mqtt.core.server.http.api.form
br.com.anteros.mqtt.core.server.http.api.result - package br.com.anteros.mqtt.core.server.http.api.result
br.com.anteros.mqtt.core.server.http.core - package br.com.anteros.mqtt.core.server.http.core
br.com.anteros.mqtt.core.server.http.handler - package br.com.anteros.mqtt.core.server.http.handler
br.com.anteros.mqtt.core.server.http.websocket - package br.com.anteros.mqtt.core.server.http.websocket
br.com.anteros.mqtt.core.server.protocol - package br.com.anteros.mqtt.core.server.protocol
br.com.anteros.mqtt.core.server.session - package br.com.anteros.mqtt.core.server.session
br.com.anteros.mqtt.core.server.store - package br.com.anteros.mqtt.core.server.store
br.com.anteros.mqtt.core.server.support - package br.com.anteros.mqtt.core.server.support
br.com.anteros.mqtt.core.util - package br.com.anteros.mqtt.core.util
br.com.anteros.mqtt.core.util.collection - package br.com.anteros.mqtt.core.util.collection
bufferAllocator(ByteBufferAllocator) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
bufferAllocator(ByteBufferAllocator) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
build() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
build() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
builder() - Static method in class br.com.anteros.mqtt.core.client.MqttWillMessage
Builder() - Constructor for class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder

C

clean() - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
clean() - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 资源清理
clean() - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 清理
clean() - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
cleanSession(boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
clear() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
clear() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
clearRetainMessage(String) - Method in interface br.com.anteros.mqtt.core.server.store.IMqttMessageStore: 清理该 topic 的 retain 消息
clearRetainMessage(String) - Method in class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
clearStaticResCache() - Method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRequestHandler
clearWillMessage(String) - Method in interface br.com.anteros.mqtt.core.server.store.IMqttMessageStore: 清理该 clientId 的遗嘱消息
clearWillMessage(String) - Method in class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
clientId(String) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
clientSession(IMqttClientSession) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
close(String) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 服务端主动断开连接
close(ChannelContext, Packet) - Static method in class br.com.anteros.mqtt.core.server.http.core.MqttHttpHelper: 数据清理
CollUtil - Class in br.com.anteros.mqtt.core.util: 集合工具
CollUtil() - Constructor for class br.com.anteros.mqtt.core.util.CollUtil
config(MqttServer) - Method in class br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher
config(MqttServerCreator, ServerTioConfig) - Static method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer: 配置 web 服务
connect() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
connectListener(IMqttClientConnectListener) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
connectStatusListener(IMqttConnectStatusListener) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
containsKey(int) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
containsKey(int) - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap: Indicates whether or not this map contains a value for the specified key.
containsKey(Object) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
containsKey(Object) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
containsValue(Object) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
containsValue(Object) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
create() - Static method in class br.com.anteros.mqtt.core.client.MqttClient
create() - Static method in class br.com.anteros.mqtt.core.server.MqttServer

D

debug() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
decode(byte[]) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: decode Hex
decode(String) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: decode Hex
decode(String) - Method in enum br.com.anteros.mqtt.core.util.PayloadEncode: 解码
decode(String, String) - Static method in enum br.com.anteros.mqtt.core.util.PayloadEncode: 解码
decode(ByteBuffer, int, int, int, ChannelContext) - Method in class br.com.anteros.mqtt.core.client.MqttClientAioHandler
decode(ByteBuffer, int, int, int, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServerAioHandler
decode(ByteBuffer, int, int, int, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.MqttServerAioHandler: 根据ByteBuffer解码成业务需要的Packet对象.
decodeToString(byte[]) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: decodeToString Hex
decodeToString(String) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: decodeToString Hex
DEFAULT_CAPACITY - Static variable in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap: Default initial capacity.
DEFAULT_CHARSET - Static variable in class br.com.anteros.mqtt.core.util.HexUtil
DEFAULT_KEEP_ALIVE_SECS - Static variable in class br.com.anteros.mqtt.core.client.MqttClientCreator: 默认的心跳超时
DEFAULT_LOAD_FACTOR - Static variable in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap: Default load factor.
DefaultMqttBrokerDispatcher - Class in br.com.anteros.mqtt.core.server.broker: 默认的消息转发器
DefaultMqttBrokerDispatcher() - Constructor for class br.com.anteros.mqtt.core.server.broker.DefaultMqttBrokerDispatcher
DefaultMqttClientMessageIdGenerator - Class in br.com.anteros.mqtt.core.client: 默认的 mqtt 客户端的消息 id 生成器
DefaultMqttClientMessageIdGenerator() - Constructor for class br.com.anteros.mqtt.core.client.DefaultMqttClientMessageIdGenerator
DefaultMqttClientProcessor - Class in br.com.anteros.mqtt.core.client: 默认的 mqtt 消息处理器
DefaultMqttClientProcessor(MqttClientCreator) - Constructor for class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
DefaultMqttClientSession - Class in br.com.anteros.mqtt.core.client: 客户端 session 管理，包括 sub 和 pub
DefaultMqttClientSession() - Constructor for class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
DefaultMqttConnectStatusListener - Class in br.com.anteros.mqtt.core.server.support: 默认的链接状态监听
DefaultMqttConnectStatusListener() - Constructor for class br.com.anteros.mqtt.core.server.support.DefaultMqttConnectStatusListener
DefaultMqttServerAuthHandler - Class in br.com.anteros.mqtt.core.server.support: 默认的认证处理
DefaultMqttServerAuthHandler() - Constructor for class br.com.anteros.mqtt.core.server.support.DefaultMqttServerAuthHandler
DefaultMqttServerProcessor - Class in br.com.anteros.mqtt.core.server.support: mqtt broker 处理器
DefaultMqttServerProcessor(MqttServerCreator, ScheduledThreadPoolExecutor) - Constructor for class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
DefaultMqttServerUniqueIdServiceImpl - Class in br.com.anteros.mqtt.core.server.support: 默认的 mqtt 服务端唯一 id 绑定，使用 clientId
DefaultMqttServerUniqueIdServiceImpl() - Constructor for class br.com.anteros.mqtt.core.server.support.DefaultMqttServerUniqueIdServiceImpl
deleteClients(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 踢除指定客户端。
DIS_CONNECTED - Static variable in interface br.com.anteros.mqtt.core.server.MqttConst: 正常断开连接
disconnect() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 断开 mqtt 连接

E

E101 - br.com.anteros.mqtt.core.server.http.api.code.ResultCode: 关键请求参数缺失
E102 - br.com.anteros.mqtt.core.server.http.api.code.ResultCode: 请求参数错误
E103 - br.com.anteros.mqtt.core.server.http.api.code.ResultCode: 用户名或密码错误
E104 - br.com.anteros.mqtt.core.server.http.api.code.ResultCode: 请求方法错误
E105 - br.com.anteros.mqtt.core.server.http.api.code.ResultCode: 未知错误
encode(byte[]) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: encode Hex
encode(byte[]) - Method in enum br.com.anteros.mqtt.core.util.PayloadEncode: 编码
encode(byte[], boolean) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: encode Hex
encode(Packet, TioConfig, ChannelContext) - Method in class br.com.anteros.mqtt.core.client.MqttClientAioHandler
encode(Packet, TioConfig, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServerAioHandler
encode(Packet, TioConfig, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.MqttServerAioHandler: 编码
encodeSubProtocol(Packet, TioConfig, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler
encodeToString(byte[]) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: encode Hex
encodeToString(byte[], boolean) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: encode Hex
encodeToString(String) - Static method in class br.com.anteros.mqtt.core.util.HexUtil: encode Hex
entries() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
entries() - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap: Gets an iterable to traverse over the primitive entries contained in this map.
entrySet() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
entrySet() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
equals(Object) - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
equals(Object) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
equals(Object) - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
equals(Object) - Method in class br.com.anteros.mqtt.core.common.MqttPendingQos2Publish
equals(Object) - Method in class br.com.anteros.mqtt.core.server.http.handler.HandlerInfo
equals(Object) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
equals(Object) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
expire(String, int) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 标记 session 超时时间
expire(String, int) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager

F

fail(HttpResponse, ResultCode) - Static method in class br.com.anteros.mqtt.core.server.http.api.result.Result: 响应失败
filter(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter
filter(HttpRequest) - Method in interface br.com.anteros.mqtt.core.server.http.handler.HttpFilter: 处理请求
findNextPositivePowerOfTwo(int) - Static method in class br.com.anteros.mqtt.core.util.MathUtil: Fast method of finding the next power of 2 greater than or equal to the supplied value.

G

get(int) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
get(int) - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap: Gets the value in the map with the specified key.
get(Object) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
get(Object) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
getAndCleanSubscription() - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
getAndCleanSubscription() - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 获取并清除订阅
getAuthHandler() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getBufferAllocator() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getBufferAllocator() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getChannelContext(String) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 获取 ChannelContext
getClientCreator() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 获取配置
getClientId() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getClientId() - Method in class br.com.anteros.mqtt.core.server.http.api.form.BaseForm
getClientSession() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getClientTioConfig() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 获取 ClientTioConfig
getConnectListener() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getConnectStatusListener() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getContext() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 获取 ClientChannelContext
getEncode(String) - Static method in enum br.com.anteros.mqtt.core.util.PayloadEncode: 获取解码器
getEncoding() - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
getFilters() - Static method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes: 读取所以的过滤器
getGroupExecutor() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getGroupExecutor(int) - Static method in class br.com.anteros.mqtt.core.util.ThreadUtil: 获取 tio group 线程池
getHandler() - Method in class br.com.anteros.mqtt.core.server.http.handler.HandlerInfo
getHandler(String) - Static method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes: 读取路由
getHandler(RequestLine) - Static method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes: 读取路由
getHeartbeatTimeout() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getHttpBasicPassword() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getHttpBasicUsername() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getHttpConfig() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
getHttpConfig(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRequestHandler
getHttpRequestHandler() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
getId() - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientMessageIdGenerator
getId() - Method in interface br.com.anteros.mqtt.core.client.IMqttClientMessageIdGenerator: 获取 messageId
getIncomingPublish() - Method in class br.com.anteros.mqtt.core.common.MqttPendingQos2Publish
getIp() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getIp() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getIpStatListener() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getKeepaliveBackoff() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getKeepAliveSecs() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getListener() - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
getMatchedSubscription(String) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
getMatchedSubscription(String) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 获取匹配的订阅
getMaxBytesInMessage() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getMaxBytesInMessage() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getMaxClientIdLength() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getMaxClientIdLength() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getMessage() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
getMessage() - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
getMessageDispatcher() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getMessageId(String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 生成消息 Id
getMessageId(String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
getMessageIdGenerator() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getMessageListener() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getMessageStore() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getMethod() - Method in class br.com.anteros.mqtt.core.server.http.handler.HandlerInfo
getMqttQoS() - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
getMqttWebServerAioHandler() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
getName() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getName() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getNodeName() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getPaddingSubscribe(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
getPaddingSubscribe(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 获取过程订阅
getPaddingUnSubscribe(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
getPaddingUnSubscribe(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 获取取消订阅过程消息
getPassword() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getPayload() - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
getPayload() - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
getPendingPublish(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
getPendingPublish(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 获取过程消息
getPendingPublish(String, int) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 获取发布过程存储
getPendingPublish(String, int) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
getPendingQos2Publish(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
getPendingQos2Publish(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 获取 qos2 过程消息
getPendingQos2Publish(String, int) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 获取发布过程存储
getPendingQos2Publish(String, int) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
getPort() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getPort() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getPort() - Method in enum br.com.anteros.mqtt.core.server.protocol.MqttProtocol
getProperties() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getPublishPermission() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getQos() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
getQos() - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
getQos() - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
getQos() - Method in class br.com.anteros.mqtt.core.server.http.api.form.SubscribeForm
getReadBufferSize() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getReadBufferSize() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getReInterval() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getReSubscribeBatchSize() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getResultCode() - Method in enum br.com.anteros.mqtt.core.server.http.api.code.ResultCode
getRetainMessage(String) - Method in interface br.com.anteros.mqtt.core.server.store.IMqttMessageStore: 获取所有 retain 消息
getRetainMessage(String) - Method in class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
getRetryCount() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getScheduledExecutor() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getServerConfig() - Method in class br.com.anteros.mqtt.core.server.MqttServer: 获取 ServerTioConfig
getServerCreator() - Method in class br.com.anteros.mqtt.core.server.MqttServer: 获取 mqtt 配置
getServerTioConfig() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
getSessionExpiryIntervalSecs() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getSessionManager() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getSslConfig() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getSslConfig() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getStatusCode() - Method in enum br.com.anteros.mqtt.core.server.http.api.code.ResultCode
getSubscribeValidator() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getSupportedSubProtocols() - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler
getTimeout() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getTioClient() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 获取 TioClient
getTioExecutor() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getTioExecutor(int) - Static method in class br.com.anteros.mqtt.core.util.ThreadUtil: 获取 getTioExecutor 线程池
getTioServer() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
getTioServer() - Method in class br.com.anteros.mqtt.core.server.MqttServer: 获取 TioServer
getTopic() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
getTopic() - Method in class br.com.anteros.mqtt.core.server.http.api.form.BaseForm
getTopicFilter() - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
getTopicFilter(String) - Static method in class br.com.anteros.mqtt.core.util.TopicUtil: 获取处理完成之后的 topic
getTopicFilterPattern(String) - Static method in class br.com.anteros.mqtt.core.util.TopicUtil: mqtt topicFilter 转正则
getTopicPattern(String) - Static method in class br.com.anteros.mqtt.core.util.TopicUtil: mqtt topicFilter 转正则
getType(String) - Static method in enum br.com.anteros.mqtt.core.common.TopicFilterType: 获取 topicFilter 类型
getUniqueId(ChannelContext, String, String, String) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerUniqueIdService: 获取 mqtt 唯一id，用来绑定 mqtt 内的 session 等功能
getUniqueId(ChannelContext, String, String, String) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerUniqueIdServiceImpl
getUniqueIdService() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getUsername() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getVersion() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getWebPort() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
getWebServer() - Method in class br.com.anteros.mqtt.core.server.MqttServer: 获取 http、websocket 服务
getWillMessage() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
getWillMessage(String) - Method in interface br.com.anteros.mqtt.core.server.store.IMqttMessageStore: 获取 will 消息
getWillMessage(String) - Method in class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
getWillProperties() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
groupExecutor(ThreadPoolExecutor) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator

H

handler(Packet, ChannelContext) - Method in class br.com.anteros.mqtt.core.client.MqttClientAioHandler
handler(Packet, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServerAioHandler
handler(Packet, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.MqttServerAioHandler: 处理消息包
handler(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRequestHandler
HandlerInfo - Class in br.com.anteros.mqtt.core.server.http.handler: Handler info
HandlerInfo(Method, HttpHandler) - Constructor for class br.com.anteros.mqtt.core.server.http.handler.HandlerInfo
handshake(HttpRequest, HttpResponse, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler
hashCode() - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
hashCode() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
hashCode() - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
hashCode() - Method in class br.com.anteros.mqtt.core.common.MqttPendingQos2Publish
hashCode() - Method in class br.com.anteros.mqtt.core.server.http.handler.HandlerInfo
hashCode() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
hashCode() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
hasPermission(ChannelContext, String, String, MqttQoS, boolean) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerPublishPermission: 否有发布权限
hasSession(String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 判断是否存在 session
hasSession(String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
heartbeatPacket(ChannelContext) - Method in class br.com.anteros.mqtt.core.client.MqttClientAioHandler
heartbeatTimeout(Long) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
hex - br.com.anteros.mqtt.core.util.PayloadEncode
HexUtil - Class in br.com.anteros.mqtt.core.util: hex 工具，编解码全用 byte
HexUtil() - Constructor for class br.com.anteros.mqtt.core.util.HexUtil
httpBasicAuth(String, String) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
httpEnable(boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
HttpFilter - Interface in br.com.anteros.mqtt.core.server.http.handler: http 过滤器
HttpHandler - Interface in br.com.anteros.mqtt.core.server.http.handler: http 处理器

I

IMqttClientConnectListener - Interface in br.com.anteros.mqtt.core.client: mqtt 客户端连接监听
IMqttClientMessageIdGenerator - Interface in br.com.anteros.mqtt.core.client: mqtt client messageId 生成器
IMqttClientMessageListener - Interface in br.com.anteros.mqtt.core.client: mqtt 消息处理
IMqttClientProcessor - Interface in br.com.anteros.mqtt.core.client: mqtt 客户端消息处理器
IMqttClientSession - Interface in br.com.anteros.mqtt.core.client: 客户端 session
IMqttConnectStatusListener - Interface in br.com.anteros.mqtt.core.server.event: mqtt 链接状态事件
IMqttMessageDispatcher - Interface in br.com.anteros.mqtt.core.server.dispatcher: mqtt 消息调度器
IMqttMessageListener - Interface in br.com.anteros.mqtt.core.server.event: mqtt 消息处理
IMqttMessageStore - Interface in br.com.anteros.mqtt.core.server.store: message store
IMqttServerAuthHandler - Interface in br.com.anteros.mqtt.core.server.auth: mqtt 服务端，认证处理器
IMqttServerPublishPermission - Interface in br.com.anteros.mqtt.core.server.auth: mqtt 服务端校验客户端是否有发布权限
IMqttServerSubscribeValidator - Interface in br.com.anteros.mqtt.core.server.auth: mqtt 服务端，认证处理器
IMqttServerUniqueIdService - Interface in br.com.anteros.mqtt.core.server.auth: mqtt 服务端唯一 id 绑定
IMqttSessionManager - Interface in br.com.anteros.mqtt.core.server.session: session 管理，不封装 MqttSession 实体，方便 redis 等集群处理
InMemoryMqttMessageStore - Class in br.com.anteros.mqtt.core.server.store: message store
InMemoryMqttMessageStore() - Constructor for class br.com.anteros.mqtt.core.server.store.InMemoryMqttMessageStore
InMemoryMqttSessionManager - Class in br.com.anteros.mqtt.core.server.session: 内存 session 管理
InMemoryMqttSessionManager() - Constructor for class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
IntObjectHashMap<V> - Class in br.com.anteros.mqtt.core.util.collection: A hash map implementation of IntObjectMap that uses open addressing for keys.
IntObjectHashMap() - Constructor for class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
IntObjectHashMap(int) - Constructor for class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
IntObjectHashMap(int, float) - Constructor for class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
IntObjectMap<V> - Interface in br.com.anteros.mqtt.core.util.collection: Interface for a primitive map that uses ints as keys.
IntObjectMap.PrimitiveEntry<V> - Interface in br.com.anteros.mqtt.core.util.collection: A primitive entry in the map, provided by the iterator from IntObjectMap.entries()
ip(String) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
ip(String) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
ipStatListener(IpStatListener) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
IS_HTTP - Static variable in interface br.com.anteros.mqtt.core.server.MqttConst: 是 http 协议
isCleanSession() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
isConnected() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 判断客户端跟服务端是否连接
isDebug() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
isDisconnected() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 判断客户端跟服务端是否断开连接
isEmpty() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
isEmpty() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
isHttpEnable() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
isReconnect() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
isRetain() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
isRetain() - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
isStatEnable() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
isStatEnable() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
isSubscribed(MqttClientSubscription) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
isSubscribed(MqttClientSubscription) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 判断是否已经订阅过
isUseQueueDecode() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
isUseQueueSend() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
isValid(ChannelContext, String, String, MqttQoS) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerSubscribeValidator: 是否可以订阅
isWebsocketEnable() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator

K

keepaliveBackoff(float) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
keepAliveSecs(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
key() - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap.PrimitiveEntry: Gets the key for this entry.
keySet() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
keySet() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
keyToString(int) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap: Helper method called by IntObjectHashMap.toString() in order to convert a single map key into a string.

L

logger - Static variable in interface br.com.anteros.mqtt.core.server.auth.IMqttServerAuthHandler
logger - Static variable in interface br.com.anteros.mqtt.core.server.auth.IMqttServerPublishPermission
logger - Static variable in interface br.com.anteros.mqtt.core.server.auth.IMqttServerSubscribeValidator

M

match(String, String) - Method in enum br.com.anteros.mqtt.core.common.TopicFilterType: 判断 topicFilter 和 topicName 匹配情况
match(String, String) - Static method in class br.com.anteros.mqtt.core.util.TopicUtil: 判断 topicFilter topicName 是否匹配
matches(String) - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
MathUtil - Class in br.com.anteros.mqtt.core.util: Math utility methods.
maxBytesInMessage(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
maxBytesInMessage(int) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
maxClientIdLength(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
maxClientIdLength(int) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
message(byte[]) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
messageDispatcher(IMqttMessageDispatcher) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
messageIdGenerator(IMqttClientMessageIdGenerator) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
messageListener(IMqttMessageListener) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
messageStore(IMqttMessageStore) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
messageText(String) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
MQTT - br.com.anteros.mqtt.core.server.protocol.MqttProtocol
MQTT_SSL - br.com.anteros.mqtt.core.server.protocol.MqttProtocol
MQTT_WS - br.com.anteros.mqtt.core.server.protocol.MqttProtocol
MQTT_WS_SSL - br.com.anteros.mqtt.core.server.protocol.MqttProtocol
MqttClient - Class in br.com.anteros.mqtt.core.client: mqtt 客户端
MqttClientAioHandler - Class in br.com.anteros.mqtt.core.client: mqtt 客户端处理
MqttClientAioHandler(MqttClientCreator, IMqttClientProcessor) - Constructor for class br.com.anteros.mqtt.core.client.MqttClientAioHandler
MqttClientAioListener - Class in br.com.anteros.mqtt.core.client: mqtt 客户端监听器
MqttClientAioListener(MqttClientCreator) - Constructor for class br.com.anteros.mqtt.core.client.MqttClientAioListener
MqttClientCreator - Class in br.com.anteros.mqtt.core.client: mqtt 客户端构造器
MqttClientCreator() - Constructor for class br.com.anteros.mqtt.core.client.MqttClientCreator
MqttClientSubscription - Class in br.com.anteros.mqtt.core.client: 发送订阅，未 ack 前的数据承载
MqttClientSubscription(MqttQoS, String, IMqttClientMessageListener) - Constructor for class br.com.anteros.mqtt.core.client.MqttClientSubscription
MqttConst - Interface in br.com.anteros.mqtt.core.server: 常量
MqttHttpApi - Class in br.com.anteros.mqtt.core.server.http.api: mqtt http api
MqttHttpApi(IMqttMessageDispatcher) - Constructor for class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi
MqttHttpHelper - Class in br.com.anteros.mqtt.core.server.http.core: http 工具
MqttHttpHelper() - Constructor for class br.com.anteros.mqtt.core.server.http.core.MqttHttpHelper
MqttHttpRequestHandler - Class in br.com.anteros.mqtt.core.server.http.handler: mqtt http 消息处理
MqttHttpRequestHandler() - Constructor for class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRequestHandler
MqttHttpRoutes - Class in br.com.anteros.mqtt.core.server.http.handler: mqtt http api 路由
MqttHttpRoutes() - Constructor for class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes
MqttPendingPublish - Class in br.com.anteros.mqtt.core.common: MqttPendingPublish，参考于 netty-mqtt-client
MqttPendingPublish(ByteBuffer, MqttPublishMessage, MqttQoS) - Constructor for class br.com.anteros.mqtt.core.common.MqttPendingPublish
MqttPendingQos2Publish - Class in br.com.anteros.mqtt.core.common: MqttPendingPublish，参考于 netty-mqtt-client
MqttPendingQos2Publish(MqttPublishMessage, MqttMessage) - Constructor for class br.com.anteros.mqtt.core.common.MqttPendingQos2Publish
MqttProtocol - Enum in br.com.anteros.mqtt.core.server.protocol: mqtt 协议
mqttServer - Variable in class br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher
MqttServer - Class in br.com.anteros.mqtt.core.server: mqtt 服务端
MqttServerAioHandler - Class in br.com.anteros.mqtt.core.server
MqttServerAioHandler(MqttServerCreator, MqttServerProcessor) - Constructor for class br.com.anteros.mqtt.core.server.MqttServerAioHandler
MqttServerAioListener - Class in br.com.anteros.mqtt.core.server: mqtt 服务监听
MqttServerAioListener(MqttServerCreator, ScheduledThreadPoolExecutor) - Constructor for class br.com.anteros.mqtt.core.server.MqttServerAioListener
MqttServerCreator - Class in br.com.anteros.mqtt.core.server: mqtt 服务端参数构造
MqttServerCreator() - Constructor for class br.com.anteros.mqtt.core.server.MqttServerCreator
MqttServerProcessor - Interface in br.com.anteros.mqtt.core.server: mqtt broker 处理器
MqttWebServer - Class in br.com.anteros.mqtt.core.server.http.core: mqtt web Server，集成 http 和 websocket
MqttWebServer(MqttServerCreator, ServerAioListener, HttpRequestHandler, IWsMsgHandler, SynThreadPoolExecutor, ThreadPoolExecutor) - Constructor for class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
MqttWebServer(MqttServerCreator, ServerAioListener, IWsMsgHandler) - Constructor for class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
MqttWebServerAioHandler - Class in br.com.anteros.mqtt.core.server.http.core: websocket 和 http 共存
MqttWebServerAioHandler(HttpConfig, HttpRequestHandler, IWsMsgHandler) - Constructor for class br.com.anteros.mqtt.core.server.http.core.MqttWebServerAioHandler
MqttWillMessage - Class in br.com.anteros.mqtt.core.client: 遗嘱消息
MqttWillMessage.Builder - Class in br.com.anteros.mqtt.core.client
MqttWsMsgHandler - Class in br.com.anteros.mqtt.core.server.http.websocket: mqtt websocket 消息处理
MqttWsMsgHandler(MqttServerCreator, String[], AioHandler) - Constructor for class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler
MqttWsMsgHandler(MqttServerCreator, AioHandler) - Constructor for class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler
MultiValueMap<K,V> - Class in br.com.anteros.mqtt.core.util.collection: 多值得 map
MultiValueMap() - Constructor for class br.com.anteros.mqtt.core.util.collection.MultiValueMap
MultiValueMap(Map<K, Set<V>>) - Constructor for class br.com.anteros.mqtt.core.util.collection.MultiValueMap

N

name(String) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
name(String) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
nodeName(String) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
NONE - br.com.anteros.mqtt.core.common.TopicFilterType: 默认 TopicFilter

O

offline(ChannelContext, String, String) - Method in interface br.com.anteros.mqtt.core.server.event.IMqttConnectStatusListener: 设备离线
offline(ChannelContext, String, String) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttConnectStatusListener
ok(HttpResponse) - Static method in class br.com.anteros.mqtt.core.server.http.api.result.Result: 响应成功
ok(HttpResponse, Object) - Static method in class br.com.anteros.mqtt.core.server.http.api.result.Result: 响应成功
onAfterConnected(ChannelContext, boolean, boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClientAioListener
onAfterHandshaked(HttpRequest, HttpResponse, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler: 握手后处理
onAfterSent(ChannelContext, Packet, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerAioListener
onBeforeClose(ChannelContext, Throwable, String, boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClientAioListener
onBeforeClose(ChannelContext, Throwable, String, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerAioListener
onBytes(WsRequest, byte[], ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler: 字节消息（binaryType = arraybuffer）过来后会走这个方法
onClose(WsRequest, byte[], ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler: 当客户端发 close flag 时，会走这个方法
onConnected(ChannelContext, boolean) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientConnectListener: 监听到消息
onDisconnect(ChannelContext, Throwable, String, boolean) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientConnectListener: 连接关闭前触发本方法
onHeartbeatTimeout(ChannelContext, Long, int) - Method in class br.com.anteros.mqtt.core.server.MqttServerAioListener
online(ChannelContext, String, String) - Method in interface br.com.anteros.mqtt.core.server.event.IMqttConnectStatusListener: 设备上线（连接成功）
online(ChannelContext, String, String) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttConnectStatusListener
onMessage(String, ByteBuffer) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientMessageListener: 监听到消息
onMessage(ChannelContext, String, Message) - Method in interface br.com.anteros.mqtt.core.server.event.IMqttMessageListener: 监听到消息
onPubAckReceived() - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
onPubCompReceived() - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
onPubRelReceived() - Method in class br.com.anteros.mqtt.core.common.MqttPendingQos2Publish
onSubscribed(String, MqttQoS) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientMessageListener: 订阅成功之后的事件
onText(WsRequest, String, ChannelContext) - Method in class br.com.anteros.mqtt.core.server.http.websocket.MqttWsMsgHandler: 字符消息（binaryType = blob）过来后会走这个方法

P

partition(List<T>, int) - Static method in class br.com.anteros.mqtt.core.util.CollUtil: list 分片
password(String) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
PayloadEncode - Enum in br.com.anteros.mqtt.core.util: 消息正文编码
plain - br.com.anteros.mqtt.core.util.PayloadEncode: 纯文本、hex、base64
port(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
port(int) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
processConAck(ChannelContext, MqttConnAckMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processConAck(ChannelContext, MqttConnAckMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端链接 ack
processConnect(ChannelContext, MqttConnectMessage) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: 处理链接
processConnect(ChannelContext, MqttConnectMessage) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processDecodeFailure(ChannelContext, MqttMessage, Throwable) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processDecodeFailure(ChannelContext, MqttMessage, Throwable) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理编解码失败
processDisConnect(ChannelContext) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: 断开连接
processDisConnect(ChannelContext) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processPingReq(ChannelContext) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: ping 消息处理
processPingReq(ChannelContext) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processPubAck(MqttPubAckMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processPubAck(MqttPubAckMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端 publish 的 ack
processPubAck(ChannelContext, MqttMessageIdVariableHeader) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: PubAck
processPubAck(ChannelContext, MqttMessageIdVariableHeader) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processPubComp(MqttMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processPubComp(MqttMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端 publish comp
processPubComp(ChannelContext, MqttMessageIdVariableHeader) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: PubComp
processPubComp(ChannelContext, MqttMessageIdVariableHeader) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processPublish(ChannelContext, MqttPublishMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processPublish(ChannelContext, MqttPublishMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端 publish 的消息
processPublish(ChannelContext, MqttPublishMessage) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: Publish
processPublish(ChannelContext, MqttPublishMessage) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processPubRec(ChannelContext, MqttMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processPubRec(ChannelContext, MqttMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端 publish rec
processPubRec(ChannelContext, MqttMessageIdVariableHeader) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: PubRec
processPubRec(ChannelContext, MqttMessageIdVariableHeader) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processPubRel(ChannelContext, MqttMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processPubRel(ChannelContext, MqttMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端 publish rel
processPubRel(ChannelContext, MqttMessageIdVariableHeader) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: PubRel
processPubRel(ChannelContext, MqttMessageIdVariableHeader) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processSubAck(MqttSubAckMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processSubAck(MqttSubAckMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端订阅的 ack
processSubscribe(ChannelContext, MqttSubscribeMessage) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: 监听
processSubscribe(ChannelContext, MqttSubscribeMessage) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
processUnSubAck(MqttUnsubAckMessage) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientProcessor
processUnSubAck(MqttUnsubAckMessage) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientProcessor: 处理服务端解除订阅的 ack
processUnSubscribe(ChannelContext, MqttUnsubscribeMessage) - Method in interface br.com.anteros.mqtt.core.server.MqttServerProcessor: 取消监听
processUnSubscribe(ChannelContext, MqttUnsubscribeMessage) - Method in class br.com.anteros.mqtt.core.server.support.DefaultMqttServerProcessor
properties(MqttProperties) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
publish(String, byte[]) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, byte[], boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, byte[], MqttQoS) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, byte[], MqttQoS, boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, String, ByteBuffer) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息
publish(String, String, ByteBuffer, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息
publish(String, String, ByteBuffer, MqttQoS) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息
publish(String, String, ByteBuffer, MqttQoS, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息
publish(String, ByteBuffer) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, ByteBuffer, boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, ByteBuffer, MqttQoS) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, ByteBuffer, MqttQoS, boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, ByteBuffer, MqttQoS, boolean, MqttProperties) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(String, ByteBuffer, MqttQoS, Consumer<MqttMessageBuilders.PublishBuilder>) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 发布消息
publish(ChannelContext, String, String, ByteBuffer, MqttQoS, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息
publish(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 消息发布
publishAll(String, ByteBuffer) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息给所以的在线设备
publishAll(String, ByteBuffer, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息给所以的在线设备
publishAll(String, ByteBuffer, MqttQoS) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息
publishAll(String, ByteBuffer, MqttQoS, boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServer: 发布消息给所以的在线设备
publishBatch(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 消息批量发布
PublishForm - Class in br.com.anteros.mqtt.core.server.http.api.form: 发布的模型
PublishForm() - Constructor for class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
publishPermission(IMqttServerPublishPermission) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
put(int, V) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
put(int, V) - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap: Puts the given entry into the map.
put(Integer, V) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
put(K, Set<V>) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
putAll(Map<? extends Integer, ? extends V>) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
putAll(Map<? extends K, ? extends Set<V>>) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap

Q

qos(MqttQoS) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
QUEUE - br.com.anteros.mqtt.core.common.TopicFilterType: $queue/ 为前缀的共享订阅是不带群组的共享订阅

R

readBufferSize(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
readBufferSize(int) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
reconnect() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 重连
reconnect(boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
register() - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 注册路由
register(Method, String, HttpHandler) - Static method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRoutes: 注册路由
reInterval(long) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
remove(int) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
remove(int) - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap: Removes the entry with the specified key.
remove(Object) - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
remove(Object) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
remove(String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 清除 session
remove(String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
removePaddingSubscribe(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
removePaddingSubscribe(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 删除过程订阅
removePaddingUnSubscribe(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
removePaddingUnSubscribe(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 删除取消订阅过程消息
removePendingPublish(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
removePendingPublish(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 删除过程消息
removePendingPublish(String, int) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 删除发布过程中的存储
removePendingPublish(String, int) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
removePendingQos2Publish(int) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
removePendingQos2Publish(int) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 删除 qos2 过程消息
removePendingQos2Publish(String, int) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 删除发布过程中的存储
removePendingQos2Publish(String, int) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
removeSubscribe(String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
removeSubscribe(String, String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 删除订阅
removeSubscribe(String, String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
removeSubscriptions(List<String>) - Method in class br.com.anteros.mqtt.core.client.DefaultMqttClientSession
removeSubscriptions(List<String>) - Method in interface br.com.anteros.mqtt.core.client.IMqttClientSession: 删除订阅过程消息
resp404(HttpRequest, RequestLine) - Method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRequestHandler
resp500(HttpRequest, RequestLine, Throwable) - Method in class br.com.anteros.mqtt.core.server.http.handler.MqttHttpRequestHandler
response(HttpRequest, HttpResponse) - Method in class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter
response(HttpRequest, HttpResponse) - Method in interface br.com.anteros.mqtt.core.server.http.handler.HttpFilter: 响应
reSubscribeBatchSize(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
Result - Class in br.com.anteros.mqtt.core.server.http.api.result: api Result
Result() - Constructor for class br.com.anteros.mqtt.core.server.http.api.result.Result
ResultCode - Enum in br.com.anteros.mqtt.core.server.http.api.code: 响应 code 码
retain(boolean) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
retryCount(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
RetryProcessor<T extends br.com.anteros.mqtt.codec.MqttMessage> - Class in br.com.anteros.mqtt.core.common: 重试处理器，参考于 netty-mqtt-client
RetryProcessor() - Constructor for class br.com.anteros.mqtt.core.common.RetryProcessor

S

safeFindNextPositivePowerOfTwo(int) - Static method in class br.com.anteros.mqtt.core.util.MathUtil: Fast method of finding the next power of 2 greater than or equal to the supplied value.
scheduledExecutor(ScheduledThreadPoolExecutor) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
searchSubscribe(String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 查找订阅信息
searchSubscribe(String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
searchSubscribe(String, String) - Method in interface br.com.anteros.mqtt.core.server.session.IMqttSessionManager: 查找订阅 qos 信息
searchSubscribe(String, String) - Method in class br.com.anteros.mqtt.core.server.session.InMemoryMqttSessionManager
send(Message) - Method in class br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher
send(Message) - Method in interface br.com.anteros.mqtt.core.server.dispatcher.IMqttMessageDispatcher: 发送消息
send(String, Message) - Method in interface br.com.anteros.mqtt.core.server.dispatcher.IMqttMessageDispatcher: 发送消息
sendAll(Message) - Method in class br.com.anteros.mqtt.core.server.broker.DefaultMqttBrokerDispatcher
sendAll(Message) - Method in class br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher: 转发所有消息
SESSION_EXPIRES - Static variable in interface br.com.anteros.mqtt.core.server.MqttConst: session 有效期，小于等于 0，关闭时清理，大于 0 采用缓存处理
sessionExpiryIntervalSecs(Integer) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
sessionManager - Variable in class br.com.anteros.mqtt.core.server.dispatcher.AbstractMqttMessageDispatcher
sessionManager(IMqttSessionManager) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
set(K, V) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
setAll(Map<K, V>) - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
setClientId(String) - Method in class br.com.anteros.mqtt.core.server.http.api.form.BaseForm
setEncoding(String) - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
setHandle(BiConsumer<MqttFixedHeader, T>) - Method in class br.com.anteros.mqtt.core.common.RetryProcessor
setOriginalMessage(T) - Method in class br.com.anteros.mqtt.core.common.RetryProcessor
setPayload(String) - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
setPubRelMessage(MqttMessage) - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
setQos(int) - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
setQos(int) - Method in class br.com.anteros.mqtt.core.server.http.api.form.SubscribeForm
setRetain(boolean) - Method in class br.com.anteros.mqtt.core.server.http.api.form.PublishForm
setTopic(String) - Method in class br.com.anteros.mqtt.core.server.http.api.form.BaseForm
setValue(V) - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap.PrimitiveEntry: Sets the value for this entry.
SHARE - br.com.anteros.mqtt.core.common.TopicFilterType: $share/{group-name}/ 为前缀的共享订阅是带群组的共享订阅
SHARE_GROUP_PREFIX - Static variable in enum br.com.anteros.mqtt.core.common.TopicFilterType
SHARE_QUEUE_PREFIX - Static variable in enum br.com.anteros.mqtt.core.common.TopicFilterType: 共享订阅的 topic
size() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
size() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
sleep(long) - Static method in class br.com.anteros.mqtt.core.util.ThreadUtil: 挂起当前线程
sslConfig(SslConfig) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
start() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
start() - Method in class br.com.anteros.mqtt.core.server.MqttServer: 启动服务
start() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
start(ScheduledThreadPoolExecutor) - Method in class br.com.anteros.mqtt.core.common.RetryProcessor
startPublishRetransmissionTimer(ScheduledThreadPoolExecutor, Consumer<MqttMessage>) - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
startPubRecRetransmitTimer(ScheduledThreadPoolExecutor, Consumer<MqttMessage>) - Method in class br.com.anteros.mqtt.core.common.MqttPendingQos2Publish
startPubRelRetransmissionTimer(ScheduledThreadPoolExecutor, Consumer<MqttMessage>) - Method in class br.com.anteros.mqtt.core.common.MqttPendingPublish
statEnable() - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
statEnable() - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
statEnable(boolean) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
statEnable(boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
stop() - Method in class br.com.anteros.mqtt.core.client.MqttClient: 停止客户端
stop() - Method in class br.com.anteros.mqtt.core.common.RetryProcessor
stop() - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServer
stop() - Method in class br.com.anteros.mqtt.core.server.MqttServer: 停止服务
subQos0(String, IMqttClientMessageListener) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subQos1(String, IMqttClientMessageListener) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subQos2(String, IMqttClientMessageListener) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subscribe(MqttQoS, String, IMqttClientMessageListener) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subscribe(String[], MqttQoS, IMqttClientMessageListener) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subscribe(String[], MqttQoS, IMqttClientMessageListener, MqttProperties) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subscribe(String, MqttQoS, IMqttClientMessageListener) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subscribe(String, MqttQoS, IMqttClientMessageListener, MqttProperties) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 订阅
subscribe(List<MqttClientSubscription>) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 批量订阅
subscribe(List<MqttClientSubscription>, MqttProperties) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 批量订阅
subscribe(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 主题订阅
subscribeBatch(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 主题批量订阅
SubscribeForm - Class in br.com.anteros.mqtt.core.server.http.api.form: 订阅表单
SubscribeForm() - Constructor for class br.com.anteros.mqtt.core.server.http.api.form.SubscribeForm
subscribeValidator(IMqttServerSubscribeValidator) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
SUCCESS - br.com.anteros.mqtt.core.server.http.api.code.ResultCode: 成功

T

ThreadUtil - Class in br.com.anteros.mqtt.core.util: mqtt 线程工具类
ThreadUtil() - Constructor for class br.com.anteros.mqtt.core.util.ThreadUtil
timeout(int) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
tioConfigCustomize(Consumer<TioConfig>) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
tioConfigCustomize(Consumer<TioConfig>) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
tioExecutor(SynThreadPoolExecutor) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
topic(String) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
TopicFilterType - Enum in br.com.anteros.mqtt.core.common: TopicFilter 类型
TopicUtil - Class in br.com.anteros.mqtt.core.util: Mqtt Topic 工具
TopicUtil() - Constructor for class br.com.anteros.mqtt.core.util.TopicUtil
toString() - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription
toString() - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage
toString() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
toTopicSubscription() - Method in class br.com.anteros.mqtt.core.client.MqttClientSubscription

U

uniqueIdService(IMqttServerUniqueIdService) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
unsubscribe(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 取消订阅
unSubscribe(String...) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 取消订阅
unSubscribe(List<String>) - Method in class br.com.anteros.mqtt.core.client.MqttClient: 取消订阅
unsubscribeBatch(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.api.MqttHttpApi: 批量取消订阅
updateWebSocketProtocol(HttpRequest) - Method in class br.com.anteros.mqtt.core.server.http.core.MqttWebServerAioHandler: 本方法改编自baseio: https://gitee.com/generallycloud/baseio
感谢开源作者的付出
useQueueDecode(boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
useQueueSend(boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
USER_NAME_KEY - Static variable in interface br.com.anteros.mqtt.core.server.MqttConst: 用户名 key
username(String) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
useSsl(InputStream, InputStream, String) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
useSsl(String, String, String) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator

V

value() - Method in interface br.com.anteros.mqtt.core.util.collection.IntObjectMap.PrimitiveEntry: Gets the value for this entry.
valueOf(String) - Static method in enum br.com.anteros.mqtt.core.common.TopicFilterType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum br.com.anteros.mqtt.core.server.http.api.code.ResultCode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum br.com.anteros.mqtt.core.server.protocol.MqttProtocol: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum br.com.anteros.mqtt.core.util.PayloadEncode: Returns the enum constant of this type with the specified name.
values() - Static method in enum br.com.anteros.mqtt.core.common.TopicFilterType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum br.com.anteros.mqtt.core.server.http.api.code.ResultCode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum br.com.anteros.mqtt.core.server.protocol.MqttProtocol: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class br.com.anteros.mqtt.core.util.collection.IntObjectHashMap
values() - Method in class br.com.anteros.mqtt.core.util.collection.MultiValueMap
values() - Static method in enum br.com.anteros.mqtt.core.util.PayloadEncode: Returns an array containing the constants of this enum type, in the order they are declared.
verifyAuthenticate(ChannelContext, String, String, String, String) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerAuthHandler: 认证
verifyPermission(ChannelContext, String, String, MqttQoS, boolean) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerPublishPermission: 否有发布权限
verifyTopicFilter(ChannelContext, String, String, MqttQoS) - Method in interface br.com.anteros.mqtt.core.server.auth.IMqttServerSubscribeValidator: 校验订阅的 topicFilter
version(MqttVersion) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator

W

webPort(int) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
websocketEnable(boolean) - Method in class br.com.anteros.mqtt.core.server.MqttServerCreator
willMessage(MqttWillMessage) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
willMessage(Consumer<MqttWillMessage.Builder>) - Method in class br.com.anteros.mqtt.core.client.MqttClientCreator
willProperties(MqttProperties) - Method in class br.com.anteros.mqtt.core.client.MqttWillMessage.Builder
WWW_AUTHENTICATE - Static variable in class br.com.anteros.mqtt.core.server.http.api.auth.BasicAuthFilter

A B C D E F G H I K L M N O P Q R S T U V W
All Classes All Packages