RPi Realtime Audio Broadcast

rpi-rt-audio-bdcast

def _callback(message,channel):
	
	if message["type"]=="request" :      
		print" Received message = ", message["play"]
		status=subprocess.call(["espeak","-s 120 -v en ",message["play"]], stdout=FNULL, stderr=subprocess.STDOUT)
	
		if status==0 :
			pubnub.publish(pubnub_responsechannel, postive_response)
		elif status!=0 :
			pubnub.publish(pubnub_responsechannel,negative_response)

	if message["type"]=="completed" :
		pubnub.publish(pubnub_responsechannel, done)
		sys.exit()

rpi-rt-audio-rq1

def process_request():
	sentence = importData().split(".")

	for data in sentence :
		print "sending message: ",data
		request={"type" : "request" , "play" : data}
		pubnub.publish(pubnub_requestchannel, request)
		lock.acquire()

	pubnub.publish(pubnub_requestchannel,complete_sentence)

rpi-rt-audio-rq2

def _callback(message,channel):
	
	
	if message["status"]== "positive":
		lock.release()

	elif message["status"]== "negative":
		print "error in response"

	elif message["status"]== "done":
		sys.exit()