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 | 
