libre.sh/keycloak-scim
4
0
Fork 0
Code Issues 15 Pull requests Releases 1 Activity Actions

KEYCLOAK-5910 Retry sending notification when remote cache is unavailable

Browse source
This commit is contained in:
Hynek Mlnarik 2017-11-30 11:01:55 +01:00 committed by Hynek Mlnařík
parent b8e5fd2b99
commit b466f4d0b6
1 changed files with 17 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
model/infinispan/src/main/java/org/keycloak/cluster/infinispan/InfinispanNotificationsManager.java
View file

@ -50,8 +50,10 @@ import org.keycloak.cluster.ClusterEvent;
import org.keycloak.cluster.ClusterListener; import org.keycloak.cluster.ClusterListener;
import org.keycloak.cluster.ClusterProvider; import org.keycloak.cluster.ClusterProvider;
import org.keycloak.common.util.ConcurrentMultivaluedHashMap; import org.keycloak.common.util.ConcurrentMultivaluedHashMap;
import org.keycloak.common.util.Retry;
import org.keycloak.executors.ExecutorsProvider; import org.keycloak.executors.ExecutorsProvider;
import org.keycloak.models.KeycloakSession; import org.keycloak.models.KeycloakSession;
import org.infinispan.client.hotrod.exceptions.HotRodClientException;
/** /**
* Impl for sending infinispan messages across cluster and listening to them * Impl for sending infinispan messages across cluster and listening to them
@ -153,7 +155,21 @@ public class InfinispanNotificationsManager {
.put(eventKey, wrappedEvent, 120, TimeUnit.SECONDS); .put(eventKey, wrappedEvent, 120, TimeUnit.SECONDS);
} else { } else {
// Add directly to remoteCache. Will notify remote listeners on all nodes in all DCs // Add directly to remoteCache. Will notify remote listeners on all nodes in all DCs
workRemoteCache.put(eventKey, wrappedEvent, 120, TimeUnit.SECONDS); Retry.executeWithBackoff((int iteration) -> {
try {
workRemoteCache.put(eventKey, wrappedEvent, 120, TimeUnit.SECONDS);
} catch (HotRodClientException re) {
if (logger.isDebugEnabled()) {
logger.debugf(re, "Failed sending notification to remote cache '%s'. Key: '%s', iteration '%s'. Will try to retry the task",
workRemoteCache.getName(), eventKey, iteration);
}
// Rethrow the exception. Retry will take care of handle the exception and eventually retry the operation.
throw re;
}
}, 10, 10);
} }
} }