bbk-app

BBK::App

Classes for building services based on BBK stack.

События ActiveSupport::Notifications

Подписка на события BBK::Dispatcher:

ActiveSupport::Notifications.subscribe "dispatcher.run" do |event|
  event.name        # => "dispatcher.run"
  event.duration    # => 10 (in milliseconds)
  event.allocations # => 1826
  event.payload     # => {:extra=>information}

  Rails.logger.info "#{event} Received!"
end

BBK::Dispatcher

'dispatcher.run'

Момент запуска блокирующего чтения сообщений из всех BBK::Consumer

Ключ	Значение
:dispatcher	Объект BBK::Dispatcher

'dispatcher.close'

Момент остановки BBK::Dispatcher, перед остановкой всех BBK::Consumer#close

Ключ	Значение
:dispatcher	Объект BBK::Dispatcher

'dispatcher.process'

Исключение при обработки входящего сообщения

Ключ	Значение
:msg	Объект BBK::Message (его наследник)
:exception	Стандартный массив [Exception]

'dispatcher.exception'

! Устарело ! Вместо него надо использольвать dispatcher.process

Исключение при обработки входящего сообщения

Ключ	Значение
:msg	Объект BBK::Message (его наследник)
:exception	Объект Exception

'dispatcher.request.process'

Обработка входящего сообщения

Ключ	Значение
:msg	Объект BBK::Message (его наследник)
:match	Объект Hash, содержащий поля, по которым найден обработчик (Processor)
:processor	Объект Processor, выполняющий обработку
:unknown	Boolean - сообщение не попало ни под один обработчик (Processor)
:exception	Стандартный массив [Exception]

'dispatcher.request.exception'

! Устарело ! Вместо него надо использольвать ispatcher.request.process

Обработка входящего сообщения

Ключ	Значение
:msg	Объект BBK::Message (его наследник)
:match	Объект Hash, содержащий поля, по которым найден обработчик (Processor)
:processor	Объект Processor, выполняющий обработку
:exception	Объект Exception

'dispatcher.request.result_rejected'

Обработка входящего сообщения

Ключ	Значение
:msg	Объект BBK::Message (его наследник)
:message	String с текстом ошибки