@@ -77,23 +77,21 @@ def unsubscribe(client, userdata, topic, pid):
77
77
# This method is called when the client unsubscribes from a feed.
78
78
print ("Unsubscribed from {0} with PID {1}" .format (topic , pid ))
79
79
80
-
81
- def on_relay_msg (client , topic , message ):
82
- # Called when feeds/relay has a new value
83
- print ("Received relay value: " , message )
84
- if message == "ON" :
85
- power_pin .value = True
86
- elif message == "OFF" :
87
- power_pin .value = False
88
- else :
89
- print ("Unexpected message received on /feeds/relay." )
90
-
91
-
92
80
def on_message (client , topic , message ):
93
81
# Method callled when a client's subscribed feed has a new value.
94
82
print ("New message on topic {0}: {1}" .format (topic , message ))
95
83
96
84
85
+ def on_relay_msg (client , topic , value ):
86
+ # Called when relay feed obtains a new value
87
+ print ("Turning Relay %s" % value )
88
+ if value == "ON" :
89
+ power_pin .value = True
90
+ elif value == "OFF" :
91
+ power_pin .value = False
92
+ else :
93
+ print ("Unexpected value received on relay feed." )
94
+
97
95
# Connect to WiFi
98
96
print ("Connecting to WiFi..." )
99
97
wifi .connect ()
@@ -124,7 +122,6 @@ def on_message(client, topic, message):
124
122
# Subscribe to all updates on relay feed
125
123
client .subscribe (feed_relay )
126
124
127
-
128
125
while True :
129
126
try : # Poll for new messages on feed_relay
130
127
client .loop ()
0 commit comments