Nemcio/SCM-Manager
1
0
Fork 0
mirror of https://github.com/scm-manager/scm-manager.git synced 2025-11-02 19:45:51 +01:00
Code Issues Packages Projects Releases Activity

log name of eventbus, to make restarts more debuggable

Browse Source
This commit is contained in:
Sebastian Sdorra
2019-06-20 14:57:22 +02:00
parent c02ac21b6a
commit cbe983b9f1
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
scm-webapp/src/main/java/sonia/scm/event/LegmanScmEventBus.java
View File

@@ -63,6 +63,8 @@ public class LegmanScmEventBus extends ScmEventBus
//~--- constructors ---------------------------------------------------------
private String name;
/**
* Constructs ...
*
@@ -72,7 +74,7 @@ public class LegmanScmEventBus extends ScmEventBus
}
private EventBus create() {
String name = String.format(NAME, INSTANCE_COUNTER.incrementAndGet());
name = String.format(NAME, INSTANCE_COUNTER.incrementAndGet());
logger.info("create new event bus {}", name);
return new EventBus(name);
}
@@ -88,7 +90,7 @@ public class LegmanScmEventBus extends ScmEventBus
@Override
public void post(Object event)
{
logger.debug("post {} to event bus", event);
logger.debug("post {} to event bus {}", event, name);
eventBus.post(event);
}
@@ -102,7 +104,7 @@ public class LegmanScmEventBus extends ScmEventBus
@Override
public void register(Object object)
{
logger.trace("register {} to event bus", object);
logger.trace("register {} to event bus {}", object, name);
eventBus.register(object);
}
@@ -116,7 +118,7 @@ public class LegmanScmEventBus extends ScmEventBus
@Override
public void unregister(Object object)
{
logger.trace("unregister {} from event bus", object);
logger.trace("unregister {} from event bus {}", object, name);
try
{
@@ -130,7 +132,7 @@ public class LegmanScmEventBus extends ScmEventBus
@Subscribe(async = false)
public void recreateEventBus(RecreateEventBusEvent recreateEventBusEvent) {
logger.info("shutdown event bus executor");
logger.info("shutdown event bus executor for {}", name);
eventBus.shutdown();
eventBus = create();
}