Class AwsIotSubscriptionManager
- java.lang.Object
-
- com.scaleoutsoftware.digitaltwin.datasource.aws.AwsIotSubscriptionManager
-
public class AwsIotSubscriptionManager extends java.lang.Object
Manages subscriptions to AWS IoT hub.
-
-
Constructor Summary
Constructors Constructor Description AwsIotSubscriptionManager(com.scaleout.client.GridConnection connection)
-
Method Summary
Modifier and Type Method Description void
addSubscription(java.lang.String model, java.lang.String id, java.lang.String responseTopic)
AwsIotSubscriptionMetadata
getSubscription(java.lang.String model, java.lang.String id)
java.util.List<AwsIotSubscriptionMetadata>
rebalance()
void
removeSubscription(java.lang.String model, java.lang.String id)
-
-
-
Method Detail
-
rebalance
public java.util.List<AwsIotSubscriptionMetadata> rebalance()
-
addSubscription
public void addSubscription(java.lang.String model, java.lang.String id, java.lang.String responseTopic) throws java.lang.InterruptedException
- Throws:
java.lang.InterruptedException
-
getSubscription
public AwsIotSubscriptionMetadata getSubscription(java.lang.String model, java.lang.String id) throws java.util.concurrent.ExecutionException
- Throws:
java.util.concurrent.ExecutionException
-
removeSubscription
public void removeSubscription(java.lang.String model, java.lang.String id)
-
-