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

Class MessageClientImpl

java.lang.Object

com.aliyun.openservices.iot.api.http2.callback.AbstractHttp2StreamDataReceiver

com.aliyun.openservices.iot.api.message.impl.MessageClientImpl

All Implemented Interfaces:

Http2StreamListener, ConnectionListener, MessageClient

public class MessageClientImpl
extends AbstractHttp2StreamDataReceiver
implements ConnectionListener, MessageClient

message client implement

Author:

brhao

Date:

16/03/2018

Constructor Summary

Constructors

Constructor and Description
MessageClientImpl(Profile profile)

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
void	onSettingReceive(Connection connection, io.netty.handler.codec.http2.Http2Settings settings)
void	onStatusChange(ConnectionStatus status, Connection connection)
void	onStreamDataReceived(Connection connection, io.netty.handler.codec.http2.Http2Stream stream, StreamData streamData)
void	onStreamError(Connection connection, io.netty.handler.codec.http2.Http2Stream stream, IOException e)
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

Methods inherited from class com.aliyun.openservices.iot.api.http2.callback.AbstractHttp2StreamDataReceiver

getStreamData, onDataRead, onHeadersRead

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageClientImpl

public MessageClientImpl(Profile profile)

Method Detail

onStreamError

public void onStreamError(Connection connection,
                          io.netty.handler.codec.http2.Http2Stream stream,
                          IOException e)

Specified by:

onStreamError in interface Http2StreamListener

onStreamDataReceived

public void onStreamDataReceived(Connection connection,
                                 io.netty.handler.codec.http2.Http2Stream stream,
                                 StreamData streamData)

Specified by:

onStreamDataReceived in class AbstractHttp2StreamDataReceiver

onSettingReceive

public void onSettingReceive(Connection connection,
                             io.netty.handler.codec.http2.Http2Settings settings)

Specified by:

onSettingReceive in interface ConnectionListener

onStatusChange

public void onStatusChange(ConnectionStatus status,
                           Connection connection)

Specified by:

onStatusChange in interface ConnectionListener

connect

public void connect(MessageCallback messageCallback)

Description copied from interface: MessageClient

connect to iothub

Specified by:

connect in interface MessageClient

Parameters:

messageCallback - callback when message received

disconnect

public void disconnect()

Description copied from interface: MessageClient

disconnect

Specified by:

disconnect in interface MessageClient

setMessageListener

public void setMessageListener(MessageCallback messageCallback)

Description copied from interface: MessageClient

set listener for topic

Specified by:

setMessageListener in interface MessageClient

Parameters:

messageCallback - callback when message received

setMessageListener

public void setMessageListener(String topic,
                               MessageCallback messageCallback)

Description copied from interface: MessageClient

set listener for topic

Specified by:

setMessageListener in interface MessageClient

Parameters:

topic - topic

messageCallback - callback when message received and topic matched

subscribe

public CompletableFuture<Boolean> subscribe(String topic)

Description copied from interface: MessageClient

subscribe

Specified by:

subscribe in interface MessageClient

Parameters:

topic - topic

Returns:

completableFuture for subscribe result

subscribe

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

Description copied from interface: MessageClient

subscribe

Specified by:

subscribe in interface MessageClient

Parameters:

topic - topic

messageCallback - callback when message received on this topic

Returns:

completableFuture for subscribe result

unsubscribe

public CompletableFuture<Boolean> unsubscribe(String topic)

Description copied from interface: MessageClient

unsubscribe

Specified by:

unsubscribe in interface MessageClient

Parameters:

topic - topic

Returns:

completableFuture for unsubscribe result

publish

public MessageToken publish(String topic,
                            Message message)

Description copied from interface: MessageClient

publish message to topic

Specified by:

publish in interface MessageClient

Parameters:

topic - topic

message - message entity

Returns:

completableFuture for publish result

ack

public CompletableFuture<Boolean> ack(MessageToken messageToken)

Description copied from interface: MessageClient

ack message

Specified by:

ack in interface MessageClient

Parameters:

messageToken - token for message

Returns:

completableFuture for ack result

isConnected

public boolean isConnected()

Description copied from interface: MessageClient

is client connected

Specified by:

isConnected in interface MessageClient

Returns:

isConnected

setConnectionCallback

public void setConnectionCallback(ConnectionCallback connectionCallback)

Description copied from interface: MessageClient

set callback for connection

Specified by:

setConnectionCallback in interface MessageClient

Parameters:

connectionCallback - callback