Class: Karafka::Pro::Connection::Multiplexing::Listener

Inherits:

Object

• Object
• Karafka::Pro::Connection::Multiplexing::Listener

Defined in:

lib/karafka/pro/connection/multiplexing/listener.rb

Overview

Listener used to connect listeners manager to the lifecycle events that are significant to its operations

Instance Method Summary

• #initialize ⇒ Listener constructor

  A new instance of Listener.

• #on_statistics_emitted(event) ⇒ Object

  Triggers connection manage subscription groups details noticing.

Constructor Details

#initialize ⇒ Listener

Returns a new instance of Listener.

# File 'lib/karafka/pro/connection/multiplexing/listener.rb', line 23

def initialize
  @manager = App.config.internal.connection.manager
end

Instance Method Details

#on_statistics_emitted(event) ⇒ Object

Triggers connection manage subscription groups details noticing

Parameters:

• event (Karafka::Core::Monitoring::Event) —

  event with statistics

# File 'lib/karafka/pro/connection/multiplexing/listener.rb', line 30

def on_statistics_emitted(event)
  @manager.notice(
    event[:subscription_group_id],
    event[:statistics]
  )
end