In [1]:

    

import paho.mqtt.client as mqtt


    

In [2]:

    

# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))

    # Subscribing in on_connect() means that if we lose the connection and
    # reconnect then subscriptions will be renewed.
    client.subscribe("/test")

# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("172.17.0.212", 1883, 60)

# Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a
# manual interface.
client.loop_forever()


    

    




Connected with result code 0
/test TX00, 8525
/test TX00, 8526
/test TX00, 8527
/test TX00, 8524






    




---------------------------------------------------------------------------
KeyboardInterrupt                         Traceback (most recent call last)
<ipython-input-2-edb537bd1509> in <module>()
     21 # Other loop*() functions are available that give a threaded interface and a
     22 # manual interface.
---> 23 client.loop_forever()

/usr/local/lib/python2.7/dist-packages/paho/mqtt/client.pyc in loop_forever(self, timeout, max_packets, retry_first_connection)
   1279             else:
   1280                 self._state_mutex.release()
-> 1281                 time.sleep(1)
   1282 
   1283                 self._state_mutex.acquire()

KeyboardInterrupt: