com.aliyun.openservices.iot.api.message.api

Interface MessageClient

All Known Implementing Classes:

MessageClientImpl

public interface MessageClient

Author:

brhao

Date:

08/05/2018

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Boolean>	ack(MessageToken messageToken) ack message
void	connect(MessageCallback messageCallback) connect to iothub
void	disconnect() disconnect
boolean	isConnected() is client connected
MessageToken	publish(String topic, Message message) publish message to topic
void	setConnectionCallback(ConnectionCallback connectionCallback) set callback for connection
void	setMessageListener(MessageCallback messageCallback) set listener for topic
void	setMessageListener(String topic, MessageCallback messageCallback) set listener for topic
CompletableFuture<Boolean>	subscribe(String topic) subscribe
CompletableFuture<Boolean>	subscribe(String topic, MessageCallback messageCallback) subscribe
CompletableFuture<Boolean>	unsubscribe(String topic) unsubscribe

Method Detail

connect

void connect(MessageCallback messageCallback)

connect to iothub

Parameters:

messageCallback - callback when message received

disconnect

void disconnect()

disconnect

setMessageListener

void setMessageListener(MessageCallback messageCallback)

set listener for topic

Parameters:

messageCallback - callback when message received

setMessageListener

void setMessageListener(String topic,
                        MessageCallback messageCallback)

set listener for topic

Parameters:

topic - topic

messageCallback - callback when message received and topic matched

subscribe

CompletableFuture<Boolean> subscribe(String topic)

subscribe

Parameters:

topic - topic

Returns:

completableFuture for subscribe result

subscribe

CompletableFuture<Boolean> subscribe(String topic,
                                     MessageCallback messageCallback)

subscribe

Parameters:

topic - topic

messageCallback - callback when message received on this topic

Returns:

completableFuture for subscribe result

unsubscribe

CompletableFuture<Boolean> unsubscribe(String topic)

unsubscribe

Parameters:

topic - topic

Returns:

completableFuture for unsubscribe result

publish

MessageToken publish(String topic,
                     Message message)

publish message to topic

Parameters:

topic - topic

message - message entity

Returns:

completableFuture for publish result

ack

CompletableFuture<Boolean> ack(MessageToken messageToken)

ack message

Parameters:

messageToken - token for message

Returns:

completableFuture for ack result

isConnected

boolean isConnected()

is client connected

Returns:

isConnected

setConnectionCallback

void setConnectionCallback(ConnectionCallback connectionCallback)

set callback for connection

Parameters:

connectionCallback - callback