lib/fluent/plugin/in_monitor_agent.rb in fluentd-0.14.13 vs lib/fluent/plugin/in_monitor_agent.rb in fluentd-0.14.14.pre.1

@@ -224,17 +224,22 @@
       super
 
       @first_warn = false
     end
 
+    def configure(conf)
+      super
+      @port += fluentd_worker_id
+    end
+
     def multi_workers_ready?
       true
     end
 
     def start
       super
 
-      log.debug "listening monitoring http server on http://#{@bind}:#{@port}/api/plugins"
+      log.debug "listening monitoring http server on http://#{@bind}:#{@port}/api/plugins for worker#{fluentd_worker_id}"
       @srv = WEBrick::HTTPServer.new({
           BindAddress: @bind,
           Port: @port,
           Logger: WEBrick::Log.new(STDERR, WEBrick::Log::FATAL),
           AccessLog: [],