0006210: "Node failed to authenticate" in server logs after server

restarts or client session expires
JumpMind · Jan 25, 2024 · a4240c4 · a4240c4
1 parent fdbdb22
commit a4240c4
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/...ore/src/main/java/org/jumpmind/symmetric/service/impl/AbstractOfflineDetectorService.java b/...ore/src/main/java/org/jumpmind/symmetric/service/impl/AbstractOfflineDetectorService.java
@@ -104,7 +104,7 @@ protected void fireOffline(Exception exception, Node remoteNode, RemoteNodeStatu
             log.warn("Authorization denied from {} at {}", new Object[] { remoteNode, syncUrl });
             status.setStatus(Status.NOT_AUTHORIZED);
         } else if (isAuthenticationExpired(exception)) {
-            log.debug("Authentication is required again to renew session");
+            log.info("Session expired, so will re-authenticate");
             status.setStatus(Status.NOT_AUTHORIZED);
         } else if (isSyncDisabled(exception)) {
             log.warn("Sync was not enabled for {} at {}", new Object[] { remoteNode, syncUrl });

diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -680,7 +680,11 @@ protected void logOrRethrow(Throwable ex, String sourceNodeId) throws IOExceptio
             throw (HttpException) ex;
         } else if (ex instanceof InvalidRetryException) {
             throw (InvalidRetryException) ex;
-        } else if (ex instanceof ProtocolException || ex instanceof AuthenticationException || ex instanceof AuthenticationExpiredException) {
+        } else if (ex instanceof AuthenticationException) {
+            throw (AuthenticationException) ex;
+        } else if (ex instanceof AuthenticationExpiredException) {
+            throw (AuthenticationExpiredException) ex;
+        } else if (ex instanceof ProtocolException) {
             log.error("Failed to process incoming batch from node '{}': {}{}", sourceNodeId, ex.getClass().getSimpleName(),
                     StringUtils.isNotBlank(ex.getMessage()) ? ": " + ex.getMessage() : "");
         } else if (ex instanceof StagingLowFreeSpace) {