com.amazonaws.mobileconnectors.appsync.subscription.mqtt

Class MqttSubscriptionClient

java.lang.Object

com.amazonaws.mobileconnectors.appsync.subscription.mqtt.MqttSubscriptionClient

All Implemented Interfaces:

SubscriptionClient

public class MqttSubscriptionClient
extends java.lang.Object
implements SubscriptionClient

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Map<java.lang.String,java.util.Set<SubscriptionObject>>	subscriptionsMap key: topic

Constructor Summary

Constructors

Constructor and Description
MqttSubscriptionClient(android.content.Context applicationContext, java.lang.String wssURL, java.lang.String clientId)

Method Summary

Modifier and Type	Method and Description
void	close()
void	connect(SubscriptionClientCallback callback)
java.util.Set<java.lang.String>	getTopics()
void	setTransmitting(boolean isTransmitting)
void	subscribe(java.lang.String topic, int qos, SubscriptionCallback callback)
void	unsubscribe(java.lang.String topic)

Methods inherited from class java.lang.Object

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

Field Detail

subscriptionsMap

public final java.util.Map<java.lang.String,java.util.Set<SubscriptionObject>> subscriptionsMap

key: topic

Constructor Detail

MqttSubscriptionClient

public MqttSubscriptionClient(android.content.Context applicationContext,
                              java.lang.String wssURL,
                              java.lang.String clientId)

Method Detail

connect

public void connect(SubscriptionClientCallback callback)

Specified by:

connect in interface SubscriptionClient

subscribe

public void subscribe(java.lang.String topic,
                      int qos,
                      SubscriptionCallback callback)

Specified by:

subscribe in interface SubscriptionClient

unsubscribe

public void unsubscribe(java.lang.String topic)

Specified by:

unsubscribe in interface SubscriptionClient

setTransmitting

public void setTransmitting(boolean isTransmitting)

Specified by:

setTransmitting in interface SubscriptionClient

getTopics

public java.util.Set<java.lang.String> getTopics()

Specified by:

getTopics in interface SubscriptionClient

close

public void close()

Specified by:

close in interface SubscriptionClient