@@ -75,11 +75,12 @@ module AMQP log 'connected' # @on_disconnect = proc{ raise Error, 'Disconnected from server' } unless @closing - @on_disconnect = method(:reconnect) + @on_disconnect = method(:disconnected) @reconnecting = false end @connected = true + @connection_status.call(:connected) if @connection_status @buf = Buffer.new send_data HEADER @@ -188,8 +189,17 @@ module AMQP EM.connect opts[:host], opts[:port], self, opts end + def connection_status &blk + @connection_status = blk + end + private + def disconnected + @connection_status.call(:disconnected) if @connection_status + reconnect + end + def log *args return unless @settings[:logging] or AMQP.logging require 'pp' lib/amqp/client.rb bfe1fb60a2fd932373b1a8aa43d9a93b59335706 Aman Gupta aman@tmm1.net http://github.com/tmm1/amqp/commit/06c50d9c8f1fd129a06426f54d0b45e0703738ec 06c50d9c8f1fd129a06426f54d0b45e0703738ec 2009-05-16T19:21:06-07:00 2009-05-16T19:21:06-07:00 Add Client#connection_status 5df3b89d62757999aebbf83e91248a580e103bc1 Aman Gupta aman@tmm1.net