Class: ZmqWrapper

Inherits:
Object
  • Object
show all
Defined in:
lib/realtime/zmq_wrapper.rb

Class Method Summary collapse

Class Method Details

.publish(the_message) ⇒ Object 



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

def self.publish(the_message)
	EM.run {
		zmq = EM::ZeroMQ::Context.new(1)
		pusher = zmq.socket(ZMQ::PUSH)
		pusher.connect($zmq_server)
		message = "realtime_msg:" + the_message.to_json	
		puts "Pushing realtime message: " + message
		pusher.send_msg(message)
		EM.stop
	}
end

.store_session(user_id, session_id, session_data, expiration) ⇒ Object 



18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/realtime/zmq_wrapper.rb', line 18

def self.store_session(user_id, session_id, session_data, expiration)
	EM.run {
		zmq = EM::ZeroMQ::Context.new(1)
		pusher = zmq.socket(ZMQ::PUSH)
		pusher.connect($zmq_server)
		the_message = {user_id: user_id, 
			session_id: session_id,
			session_data: session_data,
			expiration: expiration}
			message = "rtSession:" + the_message.to_json	
			puts "Pushing session message: " + message
			pusher.send_msg(message)
			EM.stop
		}
end