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

Inherits:
Handler
  • Object
show all
Includes:
SchemaCreatable
Defined in:
lib/droonga/plugins/watch.rb

Instance Attribute Summary

Attributes inherited from Handler

#label, #loop, #messenger

Instance Method Summary collapse

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.



159
160
161
162
# 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



164
165
166
167
168
# File 'lib/droonga/plugins/watch.rb', line 164

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