org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner クラス

org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner の継承関係図

org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner 連携図

公開メンバ関数
	ClusterAwareScheduledTaskRunner (KeycloakSessionFactory sessionFactory, ScheduledTask task, long intervalMillis)
void	run ()

限定公開メンバ関数
void	runTask (final KeycloakSession session)

限定公開変数類
final KeycloakSessionFactory	sessionFactory
final ScheduledTask	task

非公開変数類
final int	intervalSecs

静的非公開変数類
static final Logger	logger = Logger.getLogger(ClusterAwareScheduledTaskRunner.class)

詳解

Ensures that there are not concurrent executions of same task (either on this host or any other cluster host)

著者

Marek Posolda

構築子と解体子

ClusterAwareScheduledTaskRunner()

org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner.ClusterAwareScheduledTaskRunner ( KeycloakSessionFactory  sessionFactory, ScheduledTask  task, long  intervalMillis  )

inline

                                                                                                                           {
        super(sessionFactory, task);
        this.intervalSecs = (int) (intervalMillis / 1000);
    }

関数詳解

run()

void org.keycloak.services.scheduled.ScheduledTaskRunner.run ( )

inlineinherited

                      {
        KeycloakSession session = sessionFactory.create();
        try {
            runTask(session);
        } catch (Throwable t) {
            ServicesLogger.LOGGER.failedToRunScheduledTask(t, task.getClass().getSimpleName());

            session.getTransactionManager().rollback();
        } finally {
            try {
                session.close();
            } catch (Throwable t) {
                ServicesLogger.LOGGER.failedToCloseProviderSession(t);
            }
        }
    }

runTask()

void org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner.runTask ( final KeycloakSession  session )

inlineprotected

                                                          {
        session.getTransactionManager().begin();

        ClusterProvider clusterProvider = session.getProvider(ClusterProvider.class);
        String taskKey = task.getClass().getSimpleName();

        ExecutionResult<Void> result = clusterProvider.executeIfNotExecuted(taskKey, intervalSecs, new Callable<Void>() {

            @Override
            public Void call() throws Exception {
                task.run(session);
                return null;
            }

        });

        session.getTransactionManager().commit();

        if (result.isExecuted()) {
            logger.debugf("Executed scheduled task %s", taskKey);
        } else {
            logger.debugf("Skipped execution of task %s as other cluster node is executing it", taskKey);
        }
    }

メンバ詳解

intervalSecs

final int org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner.intervalSecs

private

logger

final Logger org.keycloak.services.scheduled.ClusterAwareScheduledTaskRunner.logger = Logger.getLogger(ClusterAwareScheduledTaskRunner.class)

staticprivate

sessionFactory

final KeycloakSessionFactory org.keycloak.services.scheduled.ScheduledTaskRunner.sessionFactory

protectedinherited

task

final ScheduledTask org.keycloak.services.scheduled.ScheduledTaskRunner.task

protectedinherited

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/rest-service/src/services/src/main/java/org/keycloak/services/scheduled/ClusterAwareScheduledTaskRunner.java