Method: Que::Listener#initialize

Defined in:
lib/que/listener.rb

#initialize(connection:, channel: nil) ⇒ Listener

Returns a new instance of Listener.



9
10
11
12
13
14
15
16
17
18
 
# File 'lib/que/listener.rb', line 9

def initialize(connection:, channel: nil)
  @connection = connection
  @channel    = channel || "que_listener_#{connection.backend_pid}"

  Que.internal_log :listener_instantiate, self do
    {
      backend_pid: connection.backend_pid,
    }
  end
end