Parent

Class/Module Index [+]

Quicksearch

AMQ::Client::Async::CoolioClient::Socket

Cool.io socket delegates most of its operations to the parent adapter. Thus, 99.9% of the time you don't need to deal with this class.

@api private @private

Attributes

adapter[RW]

Public Class Methods

connect(adapter, host, port) click to toggle source

Connects to given host/port and sets parent adapter.

@param [CoolioClient] @param [String] @param [Fixnum]

# File lib/amq/client/async/adapters/coolio.rb, line 43
def self.connect(adapter, host, port)
  socket = super(host, port)
  socket.adapter = adapter
  socket
end

Public Instance Methods

on_close() click to toggle source

Triggers socket_disconnect callback

# File lib/amq/client/async/adapters/coolio.rb, line 63
def on_close
  adapter.socket_disconnected
end
on_connect() click to toggle source

Triggers socket_connect callback

# File lib/amq/client/async/adapters/coolio.rb, line 50
def on_connect
  #puts "On connect"
  adapter.socket_connected
end
on_connect_failed() click to toggle source

Triggers tcp_connection_failed callback

# File lib/amq/client/async/adapters/coolio.rb, line 68
def on_connect_failed
  adapter.tcp_connection_failed
end
on_read(data) click to toggle source

Triggers on_read callback

# File lib/amq/client/async/adapters/coolio.rb, line 56
def on_read(data)
  # puts "Received data"
  # puts_data(data)
  adapter.receive_data(data)
end
send_raw(data) click to toggle source

Sends raw data through the socket

param [String] Binary data

# File lib/amq/client/async/adapters/coolio.rb, line 75
def send_raw(data)
  # puts "Sending data"
  # puts_data(data)
  write(data)
end

Protected Instance Methods

puts_data(data) click to toggle source

Debugging routine

# File lib/amq/client/async/adapters/coolio.rb, line 83
def puts_data(data)
  puts "    As string:     #{data.inspect}"
  puts "    As byte array: #{data.bytes.to_a.inspect}"
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.