diff --git a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java index 68aa57f70..ac07cdf5d 100644 --- a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java +++ b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutExecutor.java @@ -155,7 +155,7 @@ public class JpaRolloutExecutor implements RolloutExecutor { @Override public void execute(final Rollout rollout) { - log.debug("handle rollout {}", rollout.getId()); + log.debug("Processing rollout {}", rollout.getId()); switch (rollout.getStatus()) { case CREATING: @@ -201,6 +201,8 @@ public class JpaRolloutExecutor implements RolloutExecutor { log.error("Rollout in status {} not supposed to be handled!", rollout.getStatus()); break; } + + log.debug("Rollout {} processed", rollout.getId()); } private void handleCreateRollout(final JpaRollout rollout) { diff --git a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java index a7932f5e4..05b2b93ef 100644 --- a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java +++ b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/JpaRolloutHandler.java @@ -68,8 +68,7 @@ public class JpaRolloutHandler implements RolloutHandler { return; } - final String tenant = tenantAware.getCurrentTenant(); - final String handlerId = createRolloutLockKey(tenant); + final String handlerId = createRolloutLockKey(tenantAware.getCurrentTenant()); final Lock lock = lockRegistry.obtain(handlerId); if (!lock.tryLock()) { if (log.isTraceEnabled()) { @@ -79,16 +78,14 @@ public class JpaRolloutHandler implements RolloutHandler { } try { - log.debug("[{}] Trigger handling {} rollouts.", tenant, rollouts.size()); + log.debug("Trigger handling {} rollouts.", rollouts.size()); rollouts.forEach(rolloutId -> { try { - log.debug("[{}] Handling rollout {}", tenant, rolloutId); handleRolloutInNewTransaction(rolloutId, handlerId); - log.debug("[{}] Rollout {} processed", tenant, rolloutId); } catch (final Throwable throwable) { - log.error("[{}] Failed to process rollout with id {}", tenant, rolloutId , throwable); + log.error("Failed to process rollout with id {}", rolloutId , throwable); }}); - log.debug("[{}] Finished handling of the rollouts.", tenant); + log.debug("Finished handling of the rollouts."); } finally { if (log.isTraceEnabled()) { log.trace("Unlock lock {}", lock); diff --git a/hawkbit-security-core/src/main/java/org/eclipse/hawkbit/security/MDCHandler.java b/hawkbit-security-core/src/main/java/org/eclipse/hawkbit/security/MDCHandler.java index 07a063f14..6e975636e 100644 --- a/hawkbit-security-core/src/main/java/org/eclipse/hawkbit/security/MDCHandler.java +++ b/hawkbit-security-core/src/main/java/org/eclipse/hawkbit/security/MDCHandler.java @@ -90,7 +90,7 @@ public class MDCHandler { } /** - * With logging throwing Runtime Exception (wihtLoggingRE). Calls the {@link #withLogging(Callable)} method and + * With logging throwing Runtime Exception (withLoggingRE). Calls the {@link #withLogging(Callable)} method and * wraps any catchable exception into a {@link RuntimeException}. * * @param the return type @@ -111,7 +111,6 @@ public class MDCHandler { final String user = springSecurityAuditorAware .getCurrentAuditor() .filter(username -> !username.equals("system")) // null and system are the same - system user - .map(username -> (securityContext != null && securityContext.isCurrentThreadSystemCode() ? "as " : "") + username) .orElse(null); final String currentUser = MDC.get(MDC_KEY_USER);