Class: Droonga::Plugins::Watch::SweepHandler

Inherits:

Handler

• Object
• Handler
• Droonga::Plugins::Watch::SweepHandler

Includes:

SchemaCreatable

Defined in:

lib/droonga/plugins/watch.rb

Instance Attribute Summary

Attributes inherited from Handler

#loop, #messenger

Instance Method Summary

• #handle(message) ⇒ Object
• #initialize(*args) ⇒ SweepHandler constructor

  A new instance of SweepHandler.

Methods inherited from Handler

action, message

Methods included from Droonga::Pluggable

#find_sub_classes, #options

Constructor Details

#initialize(*args) ⇒ SweepHandler

Returns a new instance of SweepHandler.

# File 'lib/droonga/plugins/watch.rb', line 159

def initialize(*args)
  super
  ensure_schema_created # TODO: REMOVE ME
end

Instance Method Details

#handle(message) ⇒ Object

# File 'lib/droonga/plugins/watch.rb', line 164

def handle(message)
  sweeper = Sweeper.new(@context)
  sweeper.sweep_expired_subscribers
  nil
end