From f747be4331bb3f0060bf9f9b49df233928dd5748 Mon Sep 17 00:00:00 2001 From: Sebastian Sdorra Date: Wed, 19 Jun 2019 11:53:13 +0200 Subject: [PATCH] create instance counter for EventBus, to improve visibility during restarts --- .../main/java/sonia/scm/event/LegmanScmEventBus.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/scm-webapp/src/main/java/sonia/scm/event/LegmanScmEventBus.java b/scm-webapp/src/main/java/sonia/scm/event/LegmanScmEventBus.java index fb8fe6d2de..40795a27a6 100644 --- a/scm-webapp/src/main/java/sonia/scm/event/LegmanScmEventBus.java +++ b/scm-webapp/src/main/java/sonia/scm/event/LegmanScmEventBus.java @@ -40,6 +40,8 @@ import com.github.legman.Subscribe; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import java.util.concurrent.atomic.AtomicLong; + /** * * @author Sebastian Sdorra @@ -47,8 +49,11 @@ import org.slf4j.LoggerFactory; public class LegmanScmEventBus extends ScmEventBus { + private static final AtomicLong INSTANCE_COUNTER = new AtomicLong(); + + /** Field description */ - private static final String NAME = "ScmEventBus"; + private static final String NAME = "ScmEventBus-%s"; /** * the logger for LegmanScmEventBus @@ -67,8 +72,9 @@ public class LegmanScmEventBus extends ScmEventBus } private EventBus create() { - logger.info("create new event bus {}", NAME); - return new EventBus(NAME); + String name = String.format(NAME, INSTANCE_COUNTER.incrementAndGet()); + logger.info("create new event bus {}", name); + return new EventBus(name); } //~--- methods --------------------------------------------------------------