Module: OMQ::QoS::PushExt

Defined in:
lib/omq/qos/routing_ext.rb

Overview

Prepended onto Routing::Push. Installs the per-level command handler on every new connection. The existing reaper fiber keeps blocking on Connection#receive_message, which dispatches incoming command frames through ConnectionExt to our handler.

Instance Method Summary collapse

Instance Method Details

#connection_added(conn) ⇒ Object 



328
329
330
331
 
# File 'lib/omq/qos/routing_ext.rb', line 328

def connection_added(conn)
  super
  QoS.on_send_connection_added(self, conn)
end