Interface IncrementalSyncSubscriptionManager

All Known Implementing Classes:
CachingIncrementalSyncSubscriptionManager, DefaultIncrementalSyncSubscriptionManager

@Transactional public interface IncrementalSyncSubscriptionManager
An interface to work with IncrementalSyncSubscriptionEntity
Since:
9.3.0
  • Method Details

    • store

      Add or update an IncrementalSyncSubscription. It will determine whether IncrementalSyncSubscription is exits using Id or (context key + subscription key). If not exits then new IncrementalSyncSubscription will be inserted
      Parameters:
      subscription -
      Returns:
    • getSubscription

      @Transactional(readOnly=true) Optional<IncrementalSyncSubscription> getSubscription(long id)
      Parameters:
      id -
      Returns:
    • getSubscriptionsByContext

      @Transactional(readOnly=true) Collection<IncrementalSyncSubscription> getSubscriptionsByContext(String context)
      Get all subscription within a context
      Parameters:
      context -
      Returns:
    • getSubscriptionsByContext

      @Transactional(readOnly=true) Collection<IncrementalSyncSubscription> getSubscriptionsByContext(String context, IncrementalSyncState state)
      Get all subscription within a context and state
      Parameters:
      context -
      state -
      Returns:
    • removeSubscription

      boolean removeSubscription(long id)
      Remove a subscription using context key and subscription key
      Parameters:
      id - the subscription's ID
      Returns:
      true if the subscription is removed successfully, false otherwise.
    • removeAllSubscriptions

      int removeAllSubscriptions(String contextKey)
      Remove all subscription belong to a context key
      Parameters:
      contextKey - the context key
      Returns:
    • removeExpiredSubscriptions

      int removeExpiredSubscriptions(String contextKey, Instant ttl)
      Remove expired subscription belong to a context key
      Parameters:
      contextKey -
      ttl - the time-to-live attribute
      Returns:
    • removeDeletedSubscriptions

      int removeDeletedSubscriptions(String contextKey)
      Remove deleted subscription belong to a context key
      Parameters:
      contextKey - the context key
      Returns: