class IRuby::SessionAdapter::CztopAdapter
Public Class Methods
Source
# File lib/iruby/session_adapter/cztop_adapter.rb, line 4 def self.load_requirements require 'cztop' end
Public Instance Methods
Source
# File lib/iruby/session_adapter/cztop_adapter.rb, line 16 def heartbeat_loop(sock) loop do message = sock.receive sock << message end end
Source
# File lib/iruby/session_adapter/cztop_adapter.rb, line 12 def recv(sock) sock.receive end
Source
# File lib/iruby/session_adapter/cztop_adapter.rb, line 8 def send(sock, data) sock << data end
Private Instance Methods
Source
# File lib/iruby/session_adapter/cztop_adapter.rb, line 38 def make_socket(type_symbol, protocol, host, port) uri = "#{protocol}://#{host}:#{port}" socket_class = socket_type_class(type_symbol) socket_class.new(uri) end
Source
# File lib/iruby/session_adapter/cztop_adapter.rb, line 25 def socket_type_class(type_symbol) case type_symbol when :ROUTER, :PUB, :REP CZTop::Socket.const_get(type_symbol) else if CZTop::Socket.const_defined?(type_symbol) raise ArgumentError, "Unsupported ZMQ socket type: #{type_symbol}" else raise ArgumentError, "Invalid ZMQ socket type: #{type_symbol}" end end end