diff options
Diffstat (limited to 'python/examples/wildcard_subscribe.py')
| -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 | 
