lib/tengine/event/sender.rb in tengine_event-1.1.0 vs lib/tengine/event/sender.rb in tengine_event-1.2.0

@@ -78,11 +78,11 @@
   # @option options [Hash] :keep_connection
   # @option options [Hash] :retry_interval
   # @option options [Hash] :retry_count
   # @return [Tengine::Event]
   def fire(event_or_event_type_name, options = {}, &block)
-#    @logger.info("fire(#{event_or_event_type_name.inspect}, #{options}) called")
+    @logger.debug("#{self.class.name}#fire(#{event_or_event_type_name.inspect}, #{options}) called")
     opts = (options || {}).dup
     cfg = {
       :keep_connection => (opts.delete(:keep_connection) || default_keep_connection),
       :retry_interval  => opts.delete(:retry_interval),
       :retry_count     => opts.delete(:retry_count),
@@ -93,13 +93,13 @@
       else
         Tengine::Event.new(opts.update(
           :event_type_name => event_or_event_type_name.to_s))
       end
     @mq_suite.fire self, event, cfg, block
-#    @logger.info("fire(#{event_or_event_type_name.inspect}, #{options}) complete")
+    @logger.debug("#{self.class.name}#fire(#{event_or_event_type_name.inspect}, #{options}) complete")
     event
   rescue Exception => e
-    @logger.warn("fire(#{event_or_event_type_name.inspect}, #{options}) raised [#{e.class.name}] #{e.message}")
+    @logger.warn("#{self.class.name}#fire(#{event_or_event_type_name.inspect}, #{options}) raised [#{e.class.name}] #{e.message}")
     raise e
   end
 
   def pending_events
     @mq_suite.pending_events_for self