aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorDevendra2015-07-18 01:05:49 +0530
committerDevendra2015-07-18 01:05:49 +0530
commit652252dbf30e9f4300eab81b083ce098a8d74cc4 (patch)
tree6b8449143b0062084fe994465bf6c1236caba336
parent74dcfd277d104cc8db2dc52c5f3f75f15951c3e5 (diff)
downloadpubnub-python-652252dbf30e9f4300eab81b083ce098a8d74cc4.tar.bz2
wildcard subscribe examples
-rw-r--r--python/examples/wildcard_subscribe.py93
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