Package br.com.anteros.mqtt.core.server.http.api

Class MqttHttpApi

java.lang.Object

br.com.anteros.mqtt.core.server.http.api.MqttHttpApi

public class MqttHttpApi
extends Object

mqtt http api

Author:

L.cm

Constructor Summary

Constructors

Constructor	Description
MqttHttpApi(IMqttMessageDispatcher messageDispatcher)

Method Summary

Modifier and Type	Method	Description
org.tio.http.common.HttpResponse	deleteClients(org.tio.http.common.HttpRequest request)	踢除指定客户端。
org.tio.http.common.HttpResponse	publish(org.tio.http.common.HttpRequest request)	消息发布
org.tio.http.common.HttpResponse	publishBatch(org.tio.http.common.HttpRequest request)	消息批量发布
void	register()	注册路由
org.tio.http.common.HttpResponse	subscribe(org.tio.http.common.HttpRequest request)	主题订阅
org.tio.http.common.HttpResponse	subscribeBatch(org.tio.http.common.HttpRequest request)	主题批量订阅
org.tio.http.common.HttpResponse	unsubscribe(org.tio.http.common.HttpRequest request)	取消订阅
org.tio.http.common.HttpResponse	unsubscribeBatch(org.tio.http.common.HttpRequest request)	批量取消订阅

Methods inherited from class java.lang.Object

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

Constructor Detail

MqttHttpApi

public MqttHttpApi(IMqttMessageDispatcher messageDispatcher)

Method Detail

publish

public org.tio.http.common.HttpResponse publish(org.tio.http.common.HttpRequest request)
                                         throws Exception

消息发布

POST /api/v1/mqtt/publish

Parameters:

request - HttpRequest

Returns:

HttpResponse

Throws:

Exception - Exception

publishBatch

public org.tio.http.common.HttpResponse publishBatch(org.tio.http.common.HttpRequest request)

消息批量发布

POST /api/v1/mqtt/publish/batch

Parameters:

request - HttpRequest

Returns:

HttpResponse

subscribe

public org.tio.http.common.HttpResponse subscribe(org.tio.http.common.HttpRequest request)
                                           throws Exception

主题订阅

POST /api/v1/mqtt/subscribe

Parameters:

request - HttpRequest

Returns:

HttpResponse

Throws:

Exception - Exception

subscribeBatch

public org.tio.http.common.HttpResponse subscribeBatch(org.tio.http.common.HttpRequest request)

主题批量订阅

POST /api/v1/mqtt/subscribe/batch

Parameters:

request - HttpRequest

Returns:

HttpResponse

unsubscribe

public org.tio.http.common.HttpResponse unsubscribe(org.tio.http.common.HttpRequest request)

取消订阅

POST /api/v1/mqtt/unsubscribe

Parameters:

request - HttpRequest

Returns:

HttpResponse

unsubscribeBatch

public org.tio.http.common.HttpResponse unsubscribeBatch(org.tio.http.common.HttpRequest request)

批量取消订阅

POST /api/v1/mqtt/unsubscribe/batch

Parameters:

request - HttpRequest

Returns:

HttpResponse

deleteClients

public org.tio.http.common.HttpResponse deleteClients(org.tio.http.common.HttpRequest request)

踢除指定客户端。注意踢除客户端操作会将连接与会话一并终结。

POST /api/v1/clients/delete

Parameters:

request - HttpRequest

Returns:

HttpResponse

register

public void register()

注册路由