Class: Seamless::Dispatcher

Inherits:
Object
  • Object
show all
Includes:
Singleton
Defined in:
lib/seamless/dispatcher.rb

Instance Method Summary collapse

Instance Method Details

#incoming(session, request, response) ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
42
43
 
# File 'lib/seamless/dispatcher.rb', line 30

def incoming(session,request,response)
	body = request.env['RAW_POST_DATA']
	if body
	   node = REXML::Document.new(body)
	   node.root.each_element('//message') do |message|
		  requestid = message.attributes['requestid']
		  type = message.attributes['type']
		  text = message.text
		  msg = JSON.parse(text)
		  req = {'requestid'=>requestid, 'session'=>session}
		  MessageBroker.send(req,type,msg)
	   end
	end      
end

#outgoing(obj, type, message) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/seamless/dispatcher.rb', line 18

def outgoing(obj,type,message)
	queue = obj['session']['_seamless_mq']
	if !queue
	  queue = [];
	  obj['session']['_seamless_mq'] = queue
	end
	#TODO requestid
	queue << "<message requestid='' direction='OUTGOING' datatype='JSON' type='#{type}'><![CDATA["
	queue << message.to_json
	queue << ']]></message>'
end

#serialize(session, body) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
 
# File 'lib/seamless/dispatcher.rb', line 5

def serialize(session,body)
	queue = session['_seamless_mq']
	body << '<?xml version="1.0"?>'
	body << "<messages version='1.0' sessionid='#{session.session_id}'>"
	if queue
	  queue.each do |msg|
		body << msg
	  end
	  session['_seamless_mq']=[]
	end
	body << '</messages>'
end