class Faye::Engine::Proxy
Attributes
interval[R]
timeout[R]
Public Class Methods
new(options)
click to toggle source
Calls superclass method
# File lib/faye/engines/proxy.rb, line 39 def initialize(options) super() @options = options @connections = {} @interval = @options[:interval] || INTERVAL @timeout = @options[:timeout] || TIMEOUT engine_class = @options[:type] || Memory @engine = engine_class.create(self, @options) bind :close do |client_id| EventMachine.next_tick { flush_connection(client_id) } end debug('Created new engine: ?', @options) end
Public Instance Methods
close()
click to toggle source
# File lib/faye/engines/proxy.rb, line 110 def close @connections.keys.each { |client_id| flush_connection(client_id) } @engine.disconnect end
close_connection(client_id)
click to toggle source
# File lib/faye/engines/proxy.rb, line 77 def close_connection(client_id) debug('Closing connection for ?', client_id) return unless conn = @connections[client_id] conn.socket.close if conn.socket trigger('connection:close', client_id) @connections.delete(client_id) end
connect(client_id, options = {}, &callback)
click to toggle source
# File lib/faye/engines/proxy.rb, line 57 def connect(client_id, options = {}, &callback) debug('Accepting connection from ?', client_id) @engine.ping(client_id) conn = connection(client_id, true) conn.connect(options, &callback) @engine.empty_queue(client_id) end
connection(client_id, create)
click to toggle source
# File lib/faye/engines/proxy.rb, line 69 def connection(client_id, create) conn = @connections[client_id] return conn if conn or not create @connections[client_id] = Connection.new(self, client_id) trigger('connection:open', client_id) @connections[client_id] end
deliver(client_id, messages)
click to toggle source
# File lib/faye/engines/proxy.rb, line 90 def deliver(client_id, messages) return if !messages || messages.empty? return false unless conn = connection(client_id, false) messages.each(&conn.method(:deliver)) true end
disconnect()
click to toggle source
# File lib/faye/engines/proxy.rb, line 115 def disconnect @engine.disconnect if @engine.respond_to?(:disconnect) end
flush_connection(client_id, close = true)
click to toggle source
# File lib/faye/engines/proxy.rb, line 101 def flush_connection(client_id, close = true) return unless client_id debug('Flushing connection for ?', client_id) return unless conn = connection(client_id, false) conn.socket = nil unless close conn.flush close_connection(client_id) end
generate_id()
click to toggle source
# File lib/faye/engines/proxy.rb, line 97 def generate_id Engine.random end
has_connection?(client_id)
click to toggle source
# File lib/faye/engines/proxy.rb, line 65 def has_connection?(client_id) @connections.has_key?(client_id) end
open_socket(client_id, socket)
click to toggle source
# File lib/faye/engines/proxy.rb, line 85 def open_socket(client_id, socket) conn = connection(client_id, true) conn.socket = socket end
publish(message)
click to toggle source
# File lib/faye/engines/proxy.rb, line 119 def publish(message) channels = Channel.expand(message['channel']) @engine.publish(message, channels) end