Package com.amazonaws.services.iot.client.mqtt

Class AwsIotMqttConnection

java.lang.Object

com.amazonaws.services.iot.client.core.AwsIotConnection

com.amazonaws.services.iot.client.mqtt.AwsIotMqttConnection

All Implemented Interfaces:

AwsIotConnectionCallback

Direct Known Subclasses:

AwsIotTlsConnection, AwsIotWebsocketConnection

public class AwsIotMqttConnection
extends AwsIotConnection

This class extends AwsIotConnection to provide the basic MQTT pub/sub functionalities using the Paho MQTT library.

Field Summary

Fields inherited from class com.amazonaws.services.iot.client.core.AwsIotConnection

client, connectionStatus

Constructor Summary

Constructors

Constructor	Description
AwsIotMqttConnection(AbstractAwsIotClient client, SocketFactory socketFactory, String serverUri)

Method Summary

Modifier and Type	Method	Description
void	closeConnection(AwsIotMessageCallback callback)	Abstract method which is called to terminate an underneath connection.
AwsIotMqttClientListener	getClientListener()
AwsIotMqttMessageListener	getMessageListener()
org.eclipse.paho.client.mqttv3.MqttAsyncClient	getMqttClient()
Set<String>	getServerUris()
SocketFactory	getSocketFactory()
void	openConnection(AwsIotMessageCallback callback)	Abstract method which is called to establish an underneath connection.
void	publishMessage(AWSIotMessage message)	Abstract method which is called to publish a message.
void	setClientListener(AwsIotMqttClientListener clientListener)
void	setMessageListener(AwsIotMqttMessageListener messageListener)
void	setMqttClient(org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttClient)
void	subscribeTopic(AWSIotMessage message)	Abstract method which is called to subscribe to a topic.
void	unsubscribeTopic(AWSIotMessage message)	Abstract method which is called to unsubscribe to a topic.

Methods inherited from class com.amazonaws.services.iot.client.core.AwsIotConnection

connect, disconnect, getClient, getConnectCallback, getConnectionStatus, getPublishQueue, getRetryTask, getRetryTimes, getSubscribeQueue, getUnsubscribeQueue, isUserDisconnect, onConnectionClosed, onConnectionFailure, onConnectionSuccess, publish, setConnectionStatus, subscribe, unsubscribe, updateCredentials

Methods inherited from class java.lang.Object

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

Constructor Details

AwsIotMqttConnection

public AwsIotMqttConnection(AbstractAwsIotClient client,
 SocketFactory socketFactory,
 String serverUri)
                     throws AWSIotException

Throws:

AWSIotException

Method Details

openConnection

public void openConnection(AwsIotMessageCallback callback)
                    throws AWSIotException

Description copied from class: AwsIotConnection

Abstract method which is called to establish an underneath connection.

Specified by:

openConnection in class AwsIotConnection

Parameters:

callback - connection callback functions

Throws:

AWSIotException - this exception is thrown when the request is failed to be sent

closeConnection

public void closeConnection(AwsIotMessageCallback callback)
                     throws AWSIotException

Description copied from class: AwsIotConnection

Abstract method which is called to terminate an underneath connection.

Specified by:

closeConnection in class AwsIotConnection

Parameters:

callback - connection callback functions

Throws:

AWSIotException - this exception is thrown when the request is failed to be sent

publishMessage

public void publishMessage(AWSIotMessage message)
                    throws AWSIotException,
AwsIotRetryableException

Description copied from class: AwsIotConnection

Abstract method which is called to publish a message.

Specified by:

publishMessage in class AwsIotConnection

Parameters:

message - the message to be published

Throws:

AWSIotException - this exception is thrown when there's an unrecoverable error happened while processing the request

AwsIotRetryableException - this exception is thrown when the request is failed to be sent, which will be queued and retried

subscribeTopic

public void subscribeTopic(AWSIotMessage message)
                    throws AWSIotException,
AwsIotRetryableException

Description copied from class: AwsIotConnection

Abstract method which is called to subscribe to a topic.

Specified by:

subscribeTopic in class AwsIotConnection

Parameters:

message - the topic to be subscribed to

Throws:

AWSIotException - this exception is thrown when there's an unrecoverable error happened while processing the request

AwsIotRetryableException - this exception is thrown when the request is failed to be sent, which will be queued and retried

unsubscribeTopic

public void unsubscribeTopic(AWSIotMessage message)
                      throws AWSIotException,
AwsIotRetryableException

Description copied from class: AwsIotConnection

Abstract method which is called to unsubscribe to a topic.

Specified by:

unsubscribeTopic in class AwsIotConnection

Parameters:

message - the topic to be unsubscribed to

Throws:

AWSIotException - this exception is thrown when there's an unrecoverable error happened while processing the request

AwsIotRetryableException - this exception is thrown when the request is failed to be sent, which will be queued and retried

getServerUris

public Set<String> getServerUris()

getSocketFactory

public SocketFactory getSocketFactory()

getMqttClient

public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttClient()

getMessageListener

public AwsIotMqttMessageListener getMessageListener()

getClientListener

public AwsIotMqttClientListener getClientListener()

setMqttClient

public void setMqttClient(org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttClient)

setMessageListener

public void setMessageListener(AwsIotMqttMessageListener messageListener)

setClientListener

public void setClientListener(AwsIotMqttClientListener clientListener)