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)