Module: OMQ::QoS::ScatterExt

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

Overview

Same pattern as PushExt — SCATTER uses RoundRobin too.

Instance Method Summary collapse

Instance Method Details

#connection_added(conn) ⇒ Object 



338
339
340
341
 
# File 'lib/omq/qos/routing_ext.rb', line 338

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