blob: 14a43d9bd334cb226eae3190e1c68715ed5b2581 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
import sys
sys.path.append('../')
import threading
import time
import random
import string
from Pubnub import 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()
|
