lib/rising_dragon/sqs/emitter.rb in rising_dragon-0.2.1 vs lib/rising_dragon/sqs/emitter.rb in rising_dragon-0.3.0
- old
+ new
@@ -24,19 +24,25 @@
@handlers.delete(event_name)
end
def ignore(event_name)
- @handlers.delete(event_name)
+ unless event_name.is_a?(String)
+ raise "event_name must be String, but it's #{event_name.class}. event_name: #{event_name}"
+ end
+
+ @handlers[event_name] = ::RisingDragon::SQS::EmptyHandler
end
def list
@handlers.keys
end
def emit_event(event)
handler = @handlers[event.type]
- handler.new.handle(event) if handler
+ raise ::RisingDragon::UnRegisterEvent unless handler
+
+ handler.new.handle(event)
nil
end
def event_from_json(body)