pypubsub/clients/python/client.py

#!/usr/bin/env python3
import asfpy.pubsub


def process(payload):
    keys = list(payload.keys())
    if keys == ['stillalive']:
        print("Got a ping-back from pubsub")
    else:
        print("Got a payload!")
        print(payload)


pps = asfpy.pubsub.Listener('http://localhost:2069/')
pps.attach(process, raw=True)