public class GroupletService extends AbstractService implements IGroupletService
| Modifier and Type | Field and Description |
|---|---|
protected java.util.List<Grouplet> |
cache |
protected ISymmetricEngine |
engine |
protected long |
lastCacheTime |
log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
GroupletService(ISymmetricEngine engine) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdsprotected ISymmetricEngine engine
protected java.util.List<Grouplet> cache
protected long lastCacheTime
public GroupletService(ISymmetricEngine engine)
public boolean refreshFromDatabase()
refreshFromDatabase in interface IGroupletServicepublic void clearCache()
clearCache in interface IGroupletServicepublic boolean isSourceEnabled(TriggerRouter triggerRouter)
isSourceEnabled in interface IGroupletServicepublic boolean isTargetEnabled(TriggerRouter triggerRouter, Node node)
isTargetEnabled in interface IGroupletServicepublic java.util.Set<Node> getTargetEnabled(TriggerRouter triggerRouter, java.util.Set<Node> nodes)
getTargetEnabled in interface IGroupletServicepublic java.util.List<Grouplet> getGrouplets(boolean refreshCache)
getGrouplets in interface IGroupletServiceprotected java.util.List<Grouplet> getGroupletsFor(TriggerRouter triggerRouter, TriggerRouterGrouplet.AppliesWhen appliesWhen, boolean refreshCache)
public void saveGrouplet(Grouplet grouplet)
saveGrouplet in interface IGroupletServicepublic void deleteGrouplet(Grouplet grouplet)
deleteGrouplet in interface IGroupletServicepublic void deleteAllGrouplets()
deleteAllGrouplets in interface IGroupletServicepublic void saveGroupletLink(Grouplet grouplet, GroupletLink link)
saveGroupletLink in interface IGroupletServicepublic void deleteGroupletLink(Grouplet grouplet, GroupletLink link)
deleteGroupletLink in interface IGroupletServicepublic void saveTriggerRouterGrouplet(Grouplet grouplet, TriggerRouterGrouplet triggerRouterGrouplet)
saveTriggerRouterGrouplet in interface IGroupletServicepublic void deleteTriggerRouterGroupletsFor(TriggerRouter triggerRouter)
deleteTriggerRouterGroupletsFor in interface IGroupletServicepublic void deleteTriggerRouterGrouplet(Grouplet grouplet, TriggerRouterGrouplet triggerRouterGrouplet)
deleteTriggerRouterGrouplet in interface IGroupletService