public class MessageClientImpl extends AbstractHttp2StreamDataReceiver implements ConnectionListener, MessageClient
| Constructor and Description |
|---|
MessageClientImpl(Profile profile) |
| 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
|
getStreamData, onDataRead, onHeadersReadpublic MessageClientImpl(Profile profile)
public void onStreamError(Connection connection, io.netty.handler.codec.http2.Http2Stream stream, IOException e)
onStreamError in interface Http2StreamListenerpublic void onStreamDataReceived(Connection connection, io.netty.handler.codec.http2.Http2Stream stream, StreamData streamData)
onStreamDataReceived in class AbstractHttp2StreamDataReceiverpublic void onSettingReceive(Connection connection, io.netty.handler.codec.http2.Http2Settings settings)
onSettingReceive in interface ConnectionListenerpublic void onStatusChange(ConnectionStatus status, Connection connection)
onStatusChange in interface ConnectionListenerpublic void connect(MessageCallback messageCallback)
MessageClientconnect in interface MessageClientmessageCallback - callback when message receivedpublic void disconnect()
MessageClientdisconnect in interface MessageClientpublic void setMessageListener(MessageCallback messageCallback)
MessageClientsetMessageListener in interface MessageClientmessageCallback - callback when message receivedpublic void setMessageListener(String topic, MessageCallback messageCallback)
MessageClientsetMessageListener in interface MessageClienttopic - topicmessageCallback - callback when message received and topic matchedpublic CompletableFuture<Boolean> subscribe(String topic)
MessageClientsubscribe in interface MessageClienttopic - topicpublic CompletableFuture<Boolean> subscribe(String topic, MessageCallback messageCallback)
MessageClientsubscribe in interface MessageClienttopic - topicmessageCallback - callback when message received on this topicpublic CompletableFuture<Boolean> unsubscribe(String topic)
MessageClientunsubscribe in interface MessageClienttopic - topicpublic MessageToken publish(String topic, Message message)
MessageClientpublish in interface MessageClienttopic - topicmessage - message entitypublic CompletableFuture<Boolean> ack(MessageToken messageToken)
MessageClientack in interface MessageClientmessageToken - token for messagepublic boolean isConnected()
MessageClientisConnected in interface MessageClientpublic void setConnectionCallback(ConnectionCallback connectionCallback)
MessageClientsetConnectionCallback in interface MessageClientconnectionCallback - callbackCopyright © 2019. All rights reserved.