add debug logs

archfish · Dec 31, 2019 · 8555284 · 8555284
1 parent 44650af
commit 8555284
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 2 deletions.
diff --git a/lib/mqjob/version.rb b/lib/mqjob/version.rb
@@ -1,3 +1,3 @@
 module Mqjob
-  VERSION = "0.3.8"
+  VERSION = "0.3.9"
 end
diff --git a/lib/mqjob/worker.rb b/lib/mqjob/worker.rb
@@ -24,6 +24,7 @@ def do_work(cmd, msg)
     end
 
     def run
+      Mqjob.logger.debug("#{self.class.name}::#{__method__}"){'trigger'}
       @mq.listen(@topic, self, @topic_opts)
     end
 
@@ -38,8 +39,10 @@ def process_work(cmd, msg)
       result = nil
       begin
         result = if respond_to?(:perform_full_msg)
+          Mqjob.logger.info(__method__){"perform_full_msg: #{msg.inspect}"}
           perform_full_msg(cmd, msg)
         else
+          Mqjob.logger.info(__method__){"perform: #{msg.payload.inspect}"}
           perform(msg.payload)
         end
       rescue => exp

diff --git a/lib/plugin.rb b/lib/plugin.rb
@@ -13,6 +13,8 @@ def client(c, plugin: nil)
   def init_plugin(name)
     name ||= Mqjob.config.plugin
 
+    Mqjob.logger.debug("#{self.name}::#{__method__}"){"select plugin: #{name}"}
+
     require "plugin/#{name}"
 
     name.to_s.capitalize

diff --git a/lib/plugin/pulsar.rb b/lib/plugin/pulsar.rb
@@ -4,7 +4,7 @@ module Plugin
   class Pulsar < Base
     def listen(topic, worker, opts = {})
       create_consumer(topic, opts).listen do |cmd, msg|
-        Mqjob.logger.debug("#{self.class.name}::#{__method__}"){msg.payload}
+        Mqjob.logger.debug("#{self.class.name}::#{__method__}"){"receive msg: #{msg.payload}"}
         worker.do_work(cmd, msg)
       end
     end