Skeleton code for libmosquitto-py

mosquitto_skeleton.py

import mosquitto

def on_connect(rc):
    if rc == 0:
	print "Connected"

def on_message(msg):
    # Do something
    print msg.topic
    print msg.payload

mq = mosquitto.Mosquitto("client")

mq.on_message = on_message
mq.on_connect = on_connect

mq.connect("red.act.ted")
mq.subscribe("cam/image")

while mq.loop() == 0:
    pass