in docker_images/java/wrapper/src/main/java/glue/ModuleGlue.java [283:313]
public void enableTwin(String connectionId, final Handler<AsyncResult<Void>> handler)
{
final ModuleClient client = getClient(connectionId);
if (client == null)
{
handler.handle(Future.failedFuture(new MainApiException(500, "invalid connection id")));
}
else
{
try
{
System.out.println("calling subscribeToDesiredProperties to start twin");
client.subscribeToDesiredProperties(
(twin, context) ->
{
TwinCollection desiredProperties = twin.getDesiredProperties();
for (String key : desiredProperties.keySet())
{
onPropertyChanged(new Property(key, desiredProperties.get(key)), null);
}
},
null);
handler.handle(Future.succeededFuture());
}
catch (Exception e)
{
handler.handle(Future.failedFuture((e)));
}
}
}