aboutsummaryrefslogtreecommitdiffstats
path: root/python/examples/subscribe-example.py
diff options
context:
space:
mode:
Diffstat (limited to 'python/examples/subscribe-example.py')
-rwxr-xr-xpython/examples/subscribe-example.py70
1 files changed, 0 insertions, 70 deletions
diff --git a/python/examples/subscribe-example.py b/python/examples/subscribe-example.py
deleted file mode 100755
index 9c16bbe..0000000
--- a/python/examples/subscribe-example.py
+++ /dev/null
@@ -1,70 +0,0 @@
-import sys
-import threading
-import time
-import random
-import string
-from Pubnub import PubnubAsync as Pubnub
-
-## Initiate Class
-pubnub = Pubnub('demo', 'demo', None, False)
-
-print("My UUID is: " + pubnub.uuid)
-
-channel = ''.join(
- random.choice(string.ascii_letters + string.digits) for x in range(20))
-
-## Subscribe Example
-
-
-def receive(message):
- print(message)
- return False
-
-
-def pres_event(message):
- print(message)
- return False
-
-
-def subscribe():
- print("Listening for messages on '%s' channel..." % channel)
- pubnub.subscribe({
- 'channel': channel,
- 'callback': receive
- })
-
-
-def presence():
- print("Listening for presence events on '%s' channel..." % channel)
- pubnub.presence({
- 'channel': channel,
- 'callback': pres_event
- })
-
-
-def publish():
- print("Publishing a test message on '%s' channel..." % channel)
- pubnub.publish({
- 'channel': channel,
- 'message': {'text': 'foo bar'}
- })
-
-pres_thread = threading.Thread(target=presence)
-pres_thread.daemon = True
-pres_thread.start()
-
-sub_thread = threading.Thread(target=subscribe)
-sub_thread.daemon = True
-sub_thread.start()
-
-time.sleep(3)
-
-publish()
-
-
-print("waiting for subscribes and presence")
-pres_thread.join()
-
-print(pubnub.here_now({'channel': channel}))
-
-sub_thread.join()