class ZmqWrapper

Public Class Methods

publish(the_message) click to toggle source
# 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) click to toggle source
# 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