Package org.jumpmind.symmetric.service

Interface ITriggerRouterService

All Known Implementing Classes:
TriggerRouterService
public interface ITriggerRouterService
Provides an API to configure TriggerRouters, Triggers and Routers.

  • Method Details

    • refreshFromDatabase

      boolean refreshFromDatabase()

    • getActiveTriggerHistoriesFromCache

      List<TriggerHistory> getActiveTriggerHistoriesFromCache()

    • getActiveTriggerHistories

      List<TriggerHistory> getActiveTriggerHistories()

    • getActiveTriggerHistories

      List<TriggerHistory> getActiveTriggerHistories(Trigger trigger)

    • getActiveTriggerHistories

      List<TriggerHistory> getActiveTriggerHistories(String tableName)

    • getLastErrorTriggerHistories

      Map<String,TriggerHistory> getLastErrorTriggerHistories()

    • getTriggerRouters

      List<TriggerRouter> getTriggerRouters(boolean refreshCache)

    • getTriggerRoutersFromDatabase

      List<TriggerRouter> getTriggerRoutersFromDatabase()

    • buildTriggerRoutersForSymmetricTables

      List<TriggerRouter> buildTriggerRoutersForSymmetricTables(String version, NodeGroupLink nodeGroupLink, String... tablesToExclude)
      Return a list of triggers used when extraction configuration data during the registration process.
      Parameters:
      sourceGroupId - group id of the node being registered with
      targetGroupId - group id of the node that is registering

    • buildSymmetricTableRouterId

      String buildSymmetricTableRouterId(String triggerId, String sourceNodeGroupId, String targetNodeGroupId)

    • getTriggerForCurrentNodeById

      Trigger getTriggerForCurrentNodeById(String triggerId)

    • getTriggerRouterForCurrentNode

      TriggerRouter getTriggerRouterForCurrentNode(String triggerId, String routerId, boolean refreshCache)

    • getTriggerRoutersForTargetNode

      List<TriggerRouter> getTriggerRoutersForTargetNode(String targetNodeGroupId)

    • getTriggerRoutersForSourceAndTargetNodes

      List<TriggerRouter> getTriggerRoutersForSourceAndTargetNodes(String sourceNodeGroupId, String targetNodeGroupId)

    • getTriggersForCurrentNode

      List<Trigger> getTriggersForCurrentNode(boolean refreshCache)
      Returns a list of triggers that should be active for the current node.
      Parameters:
      refreshCache - Indicates that the cache should be refreshed

    • getTriggerRoutersByChannel

      Map<String,List<TriggerRouter>> getTriggerRoutersByChannel(String nodeGroupId)

    • getTriggerRoutersByChannelFromDatabase

      Map<String,List<TriggerRouter>> getTriggerRoutersByChannelFromDatabase(String nodeGroupId)

    • getTriggerRoutersForCurrentNode

      Map<String,List<TriggerRouter>> getTriggerRoutersForCurrentNode(boolean refreshCache)
      Returns a map of trigger routers keyed by trigger id.
      Parameters:
      refreshCache - Indicates that the cache should be refreshed

    • getTriggerRoutersCacheByNodeGroupIdFromDatabase

      Map<String,TriggerRouterRoutersCache> getTriggerRoutersCacheByNodeGroupIdFromDatabase()

    • getTriggerRoutersByTriggerHist

      Map<Integer,TriggerRouter> getTriggerRoutersByTriggerHist(String targetNodeGroupId, boolean refreshCache)

    • getTriggerRoutersByTriggerHistFromDatabase

      Map<String,Map<Integer,TriggerRouter>> getTriggerRoutersByTriggerHistFromDatabase()

    • getTriggerRouterByTriggerHist

      TriggerRouter getTriggerRouterByTriggerHist(String targetNodeGroupId, int triggerHistId, boolean refreshCache)

    • getActiveRouterByIdForCurrentNode

      Router getActiveRouterByIdForCurrentNode(String routerId, boolean refreshCache)
      Get router that is currently in use by a trigger router at the node that is hosting this call.
      Parameters:
      routerId - The router_id to retrieve
      refreshCache - Whether to force the router to be re-retrieved from the database

    • getRouterById

      Router getRouterById(String routerId)

    • getRouterById

      Router getRouterById(String routerId, boolean refreshCache)

    • getRouters

      List<Router> getRouters()

    • getRouters

      List<Router> getRouters(boolean replaceVariables)

    • getRoutersByGroupLink

      List<Router> getRoutersByGroupLink(NodeGroupLink link)
      Get a list of routers for a specific node group link.

    • isRouterBeingUsed

      boolean isRouterBeingUsed(String routerId)

    • deleteRouter

      void deleteRouter(Router router)

    • deleteAllRouters

      void deleteAllRouters()

    • saveRouter

      void saveRouter(Router router)

    • saveRouterAsCopy

      Router saveRouterAsCopy(Router router)

    • renameRouter

      void renameRouter(String oldId, Router router)

    • getAllTriggerRoutersForCurrentNode

      List<TriggerRouter> getAllTriggerRoutersForCurrentNode(String sourceNodeGroupId)

    • getTriggers

      List<Trigger> getTriggers()
      Get a list of all the triggers that have been defined for the system.

    • getTriggers

      List<Trigger> getTriggers(boolean replaceTokens)

    • saveTrigger

      void saveTrigger(Trigger trigger)

    • insertTriggers

      void insertTriggers(Collection<Trigger> triggers)

    • updateTriggers

      void updateTriggers(Collection<Trigger> triggers)

    • saveTriggerAsCopy

      void saveTriggerAsCopy(String originalId, Trigger trigger)

    • renameTrigger

      void renameTrigger(String oldId, Trigger trigger)

    • deleteTrigger

      void deleteTrigger(Trigger trigger)

    • deleteTriggers

      void deleteTriggers(Collection<Trigger> triggers)

    • deleteAllTriggers

      void deleteAllTriggers()

    • dropTriggers

      void dropTriggers()

    • dropTriggers

      void dropTriggers(Set<String> tables)

    • createTriggersOnChannelForTables

      void createTriggersOnChannelForTables(String channelId, String catalogName, String schemaName, List<String> tables, String lastUpdateBy)

    • isTriggerBeingUsed

      boolean isTriggerBeingUsed(String triggerId)

    • doesTriggerExist

      boolean doesTriggerExist(String triggerId)

    • doesTriggerExistForTable

      boolean doesTriggerExistForTable(String tableName)

    • getAllTriggerRoutersForReloadForCurrentNode

      List<TriggerRouter> getAllTriggerRoutersForReloadForCurrentNode(String sourceNodeGroupId, String targetNodeGroupId)

    • getTriggerRouterForTableForCurrentNode

      Set<TriggerRouter> getTriggerRouterForTableForCurrentNode(NodeGroupLink link, String catalogName, String schemaName, String tableName, boolean refreshCache)

    • getTriggerRouterForTableForCurrentNode

      Set<TriggerRouter> getTriggerRouterForTableForCurrentNode(String catalog, String schema, String tableName, boolean refreshCache)

    • findTriggerRouterById

      TriggerRouter findTriggerRouterById(String triggerId, String routerId)

    • findTriggerRouterById

      TriggerRouter findTriggerRouterById(String triggerId, String routerId, boolean refreshCache)

    • findTriggerRoutersByTriggerId

      List<TriggerRouter> findTriggerRoutersByTriggerId(String triggerId, boolean refreshCache)

    • findTriggerRoutersByRouterId

      List<TriggerRouter> findTriggerRoutersByRouterId(String routerId, boolean refreshCache)

    • inactivateTriggerHistory

      void inactivateTriggerHistory(TriggerHistory history)

    • getNewestTriggerHistoryForTrigger

      TriggerHistory getNewestTriggerHistoryForTrigger(List<TriggerHistory> activeTriggerHistories, String triggerId, String catalogName, String schemaName, String tableName)

    • getNewestTriggerHistoryForTrigger

      TriggerHistory getNewestTriggerHistoryForTrigger(String triggerId, String catalogName, String schemaName, String tableName)

    • getTriggerHistory

      TriggerHistory getTriggerHistory(int historyId)

    • findTriggerHistories

      List<TriggerHistory> findTriggerHistories(String catalogName, String schemaName, String tableName)

    • findTriggerHistory

      TriggerHistory findTriggerHistory(String catalogName, String schemaName, String tableName)

    • getTriggerById

      Trigger getTriggerById(String triggerId)

    • getTriggerById

      Trigger getTriggerById(String triggerId, boolean refreshCache)

    • getTriggerName

      String getTriggerName(DataEventType dml, int maxTriggerNameLength, Trigger trigger, Table table, List<TriggerHistory> activeTriggerHistories, TriggerHistory oldhist, List<String> triggerNamesGeneratedThisSession)

    • insert

      void insert(TriggerHistory newAuditRecord)

    • getHistoryRecords

      Map<Long,TriggerHistory> getHistoryRecords()

    • deleteTriggerRouter

      void deleteTriggerRouter(TriggerRouter triggerRouter)

    • deleteTriggerRouter

      void deleteTriggerRouter(String triggerId, String routerId)

    • deleteTriggerRouters

      void deleteTriggerRouters(Collection<TriggerRouter> triggerRouters)

    • deleteAllTriggerRouters

      void deleteAllTriggerRouters()

    • saveTriggerRouter

      void saveTriggerRouter(TriggerRouter triggerRouter, boolean updateTriggerRouterTableOnly)

    • saveTriggerRouter

      void saveTriggerRouter(TriggerRouter triggerRouter)

    • renameTriggerRouter

      void renameTriggerRouter(String oldTriggerId, String oldRouterId, TriggerRouter TriggerRouter)

    • insertTriggerRouters

      void insertTriggerRouters(Collection<TriggerRouter> triggerRouters)

    • insertTriggersAndTriggerRouters

      void insertTriggersAndTriggerRouters(Collection<Trigger> triggers, Collection<TriggerRouter> triggerRouters)

    • updateTriggerRouters

      void updateTriggerRouters(Collection<TriggerRouter> triggerRouters)

    • syncTrigger

      void syncTrigger(Trigger trigger, ITriggerCreationListener listener, boolean force)

    • syncTrigger

      void syncTrigger(Trigger trigger, ITriggerCreationListener listener, boolean force, boolean verifyTrigger)

    • syncTriggers

      boolean syncTriggers(List<Trigger> triggers, ITriggerCreationListener listener, boolean force, boolean verifyInDatabase)

    • syncTriggers

      boolean syncTriggers(Table table, boolean genAlways)

    • syncTriggers

      boolean syncTriggers(List<Table> tables, boolean genAlways)

    • syncTriggers

      boolean syncTriggers(String targetExternalId, boolean force)

    • dropTriggers

      void dropTriggers(TriggerHistory history)

    • syncTriggers

      boolean syncTriggers(boolean genAlways)

    • syncTriggers

      boolean syncTriggers()

    • syncTriggers

      boolean syncTriggers(StringBuilder sqlBuffer, boolean genAlways)

    • getFailedTriggers

      Map<Trigger,Exception> getFailedTriggers()

    • fillTriggerRoutersByHistIdAndSortHist

      Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistIdAndSortHist(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories, List<TriggerRouter> triggerRouters)

    • fillTriggerRoutersByHistIdAndSortHist

      Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistIdAndSortHist(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories)

    • fillTriggerRoutersByHistId

      Map<Integer,List<TriggerRouter>> fillTriggerRoutersByHistId(String sourceNodeGroupId, String targetNodeGroupId, String targetExternalId, List<TriggerHistory> triggerHistories)

    • findTriggerHistoryForGenericSync

      TriggerHistory findTriggerHistoryForGenericSync()

    • clearCache

      void clearCache()

    • findMatchingTriggers

      Collection<Trigger> findMatchingTriggers(List<Trigger> triggers, String catalog, String schema, String table)

    • getTablesFor

      List<Table> getTablesFor(List<TriggerHistory> histories)

    • getSortedTablesFor

      List<Table> getSortedTablesFor(List<TriggerHistory> histories)

    • buildTriggersForSymmetricTables

      List<Trigger> buildTriggersForSymmetricTables(String version, String... tablesToExclude)