fix: #141 ?

eclipse-thingweb · Nov 11, 2019 · bafc561 · bafc561
1 parent 2ff2bd1
commit bafc561
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/packages/binding-mqtt/src/mqtt-broker-server.ts b/packages/binding-mqtt/src/mqtt-broker-server.ts
@@ -106,7 +106,7 @@ export default class MqttBrokerServer implements ProtocolServer {
         let topic = "/" + encodeURIComponent(name) + "/properties/" + encodeURIComponent(propertyName);
         let property = thing.properties[propertyName];
 
-        thing.subscribeEvent(propertyName,
+        thing.observeProperty(propertyName,
         // let subscription = property.subscribe(
           (data) => {
             let content;
@@ -115,7 +115,7 @@ export default class MqttBrokerServer implements ProtocolServer {
             } catch(err) {
               console.warn(`MqttServer cannot process data for Property '${propertyName}': ${err.message}`);
               // subscription.unsubscribe();
-              thing.unsubscribeEvent(propertyName);
+              thing.unobserveProperty(propertyName);
               return;
             }
             console.log(`MqttBrokerServer at ${this.brokerURI} publishing to Property topic '${propertyName}' `);