From 652252dbf30e9f4300eab81b083ce098a8d74cc4 Mon Sep 17 00:00:00 2001 From: Devendra Date: Sat, 18 Jul 2015 01:05:49 +0530 Subject: wildcard subscribe examples --- python/examples/wildcard_subscribe.py | 93 +++++++++++++++++++++++++++++++++++ 1 file changed, 93 insertions(+) create mode 100644 python/examples/wildcard_subscribe.py (limited to 'python/examples') 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 -- cgit v1.2.3