@ SuppressWarnings ( "unused" ) @ Scheduled ( fixedDelay = DateUtils . MILLIS_PER_MINUTE ) public void syncSubscriptions ( ) { if ( ! mySyncSubscriptionsSemaphore . tryAcquire ( ) ) { return ; } try { doSyncSubscriptionsWithRetry ( ) ; } finally { mySyncSubscriptionsSemaphore . release ( ) ; } }
Read the existing subscriptions from the database