diff options
| author | Devendra | 2015-07-18 01:05:49 +0530 |
|---|---|---|
| committer | Devendra | 2015-07-18 01:05:49 +0530 |
| commit | 652252dbf30e9f4300eab81b083ce098a8d74cc4 (patch) | |
| tree | 6b8449143b0062084fe994465bf6c1236caba336 | |
| parent | 74dcfd277d104cc8db2dc52c5f3f75f15951c3e5 (diff) | |
| download | pubnub-python-652252dbf30e9f4300eab81b083ce098a8d74cc4.tar.bz2 | |
wildcard subscribe examples
| -rw-r--r-- | python/examples/wildcard_subscribe.py | 93 |
1 files changed, 93 insertions, 0 deletions
diff --git a/python/examples/wildcard_subscribe.py b/python/examples/wildcard_subscribe.py new file mode 100644 index 0000000..c78f83d --- /dev/null +++ b/python/examples/wildcard_subscribe.py @@ -0,0 +1,93 @@ + +from gevent import monkey; monkey.patch_all() + +from pubnub import Pubnub + +pubnub = Pubnub(publish_key="ds", subscribe_key="ds", + secret_key="ds", ssl_on=False) + +# Wildcard Subscribe without presence + +def a(): + channel_wc = "a.*" + channel = "a.b" + def callback(message1, channel1, real_channel=None): + print(channel1 + " : " + real_channel + " : " + str(message1)) + + + def error(message): + print("ERROR : " + str(message)) + + + def connect(channel1=None): + print("Connect on " + channel1) + print pubnub.publish(channel=channel, message="a") + + def disconnect(channel1=None): + print("Disconnect on " + channel1) + + def reconnect(channel1=None): + print("Reconnect on " + channel1) + + pubnub.subscribe(channels=channel_wc, callback=callback, error=callback, + connect=connect, disconnect=disconnect, reconnect=reconnect) + + +# Wildcard Subscribe with presence + +def b(): + channel_wc = "b.*" + channel = "b.c" + def callback(message1, channel1, real_channel=None): + print(channel1 + " : " + real_channel + " : " + str(message1)) + + + def error(message): + print("ERROR : " + str(message)) + + def presence(message1, channel1, real_channel=None): + print(channel1 + " : " + real_channel + " : " + str(message1)) + + def connect(channel1=None): + print("Connect on " + channel1) + print pubnub.publish(channel=channel, message="b") + + def disconnect(channel1=None): + print("Disconnect on " + channel1) + + def reconnect(channel1=None): + print("Reconnect on " + channel1) + + pubnub.subscribe(channels=channel_wc, callback=callback, error=callback, + connect=connect, disconnect=disconnect, reconnect=reconnect, presence=presence) + + +# Wildcard Subscribe and unsubscribe + +def c(): + channel_wc = "c.*" + channel = "c.d" + + def callback(message1, channel1, real_channel=None): + print(channel1 + " : " + real_channel + " : " + str(message1)) + + + def error(message): + print("ERROR : " + str(message)) + + def connect(channel1=None): + print("Connect on " + channel1) + print pubnub.publish(channel=channel, message="c") + + def disconnect(channel1=None): + print("Disconnect on " + channel1) + + def reconnect(channel1=None): + print("Reconnect on " + channel1) + + pubnub.subscribe(channels=channel_wc, callback=callback, error=callback, + connect=connect, disconnect=disconnect, reconnect=reconnect) + +a() +b() +c()
\ No newline at end of file |
