Package org.jumpmind.symmetric.cache

Class CacheManager

java.lang.Object

org.jumpmind.symmetric.cache.CacheManager

All Implemented Interfaces:

ICacheManager

public class CacheManager
extends Object
implements ICacheManager

Constructor Summary

Constructors

Constructor	Description
CacheManager(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
Map<NodeGroupLink,Map<LoadFilter.LoadFilterType,Map<String,List<LoadFilter>>>>	findLoadFilters(NodeGroupLink nodeGroupLink, boolean useCache)
void	flushAllWithRouters()
void	flushChannels()
void	flushConflictSettingsNodeGroupLinks()
void	flushFileTriggerRouters()
void	flushGrouplets()
void	flushLoadFilters()
void	flushNodeChannels()
void	flushNodeGroupChannelWindows()
void	flushNodeGroupLinks()
void	flushReadyQueuesCache()
void	flushRouters()
void	flushSourceNodesCache()
void	flushTargetNodesCache()
void	flushTransformCache()
void	flushTriggerRouters()
void	flushTriggerRoutersByChannel()
void	flushTriggerRoutersById()
void	flushTriggerRoutersByNodeGroupId()
void	flushTriggerRoutersByTriggerHist()
void	flushTriggers()
Map<String,Channel>	getChannels(boolean refreshCache)
List<DataLoaderService.ConflictNodeGroupLink>	getConflictSettingsNodeGroupLinks(NodeGroupLink link, boolean refreshCache)
List<FileTriggerRouter>	getFileTriggerRouters(boolean refreshCache)
List<Grouplet>	getGrouplets(boolean refreshCache)
long	getNodeChannelCacheTime()
List<NodeChannel>	getNodeChannels(String nodeId)
Map<String,List<NodeGroupChannelWindow>>	getNodeGroupChannelWindows()
List<NodeGroupLink>	getNodeGroupLinks(boolean refreshCache)
Collection<Node>	getNodesByGroup(String nodeGroupId)
Collection<String>	getQueues(boolean refreshCache)
Map<String,Collection<String>>	getReadyQueues(boolean refreshCache)
Map<String,Router>	getRouters(boolean refreshCache)
List<Node>	getSourceNodesCache(NodeGroupLinkAction eventAction, Node node)
List<Node>	getTargetNodesCache(NodeGroupLinkAction eventAction, Node node)
Map<NodeGroupLink,Map<TransformPoint,List<TransformService.TransformTableNodeGroupLink>>>	getTransformCache()
List<TriggerRouter>	getTriggerRouters(boolean refreshCache)
Map<String,List<TriggerRouter>>	getTriggerRoutersByChannel(String nodeGroupId, boolean refreshCache)
Map<String,TriggerRouter>	getTriggerRoutersById(boolean refreshCache)
Map<String,TriggerRouterRoutersCache>	getTriggerRoutersByNodeGroupId(boolean refreshCache)
Map<String,Map<Integer,TriggerRouter>>	getTriggerRoutersByTriggerHist(boolean refreshCache)
Map<String,Trigger>	getTriggers(boolean refreshCache)
boolean	isUsingTargetExternalId(boolean refreshCache)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

CacheManager

public CacheManager(ISymmetricEngine engine)

Method Details

getTriggerRouters

public List<TriggerRouter> getTriggerRouters(boolean refreshCache)

Specified by:

getTriggerRouters in interface ICacheManager

getTriggerRoutersByChannel

public Map<String,List<TriggerRouter>> getTriggerRoutersByChannel(String nodeGroupId,
 boolean refreshCache)

Specified by:

getTriggerRoutersByChannel in interface ICacheManager

getTriggerRoutersByTriggerHist

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

Specified by:

getTriggerRoutersByTriggerHist in interface ICacheManager

getTriggers

public Map<String,Trigger> getTriggers(boolean refreshCache)

Specified by:

getTriggers in interface ICacheManager

getRouters

public Map<String,Router> getRouters(boolean refreshCache)

Specified by:

getRouters in interface ICacheManager

getTriggerRoutersById

public Map<String,TriggerRouter> getTriggerRoutersById(boolean refreshCache)

Specified by:

getTriggerRoutersById in interface ICacheManager

getTriggerRoutersByNodeGroupId

public Map<String,TriggerRouterRoutersCache> getTriggerRoutersByNodeGroupId(boolean refreshCache)

Specified by:

getTriggerRoutersByNodeGroupId in interface ICacheManager

isUsingTargetExternalId

public boolean isUsingTargetExternalId(boolean refreshCache)

Specified by:

isUsingTargetExternalId in interface ICacheManager

flushTriggerRoutersByNodeGroupId

public void flushTriggerRoutersByNodeGroupId()

Specified by:

flushTriggerRoutersByNodeGroupId in interface ICacheManager

flushTriggerRoutersByChannel

public void flushTriggerRoutersByChannel()

Specified by:

flushTriggerRoutersByChannel in interface ICacheManager

flushTriggerRouters

public void flushTriggerRouters()

Specified by:

flushTriggerRouters in interface ICacheManager

flushTriggerRoutersByTriggerHist

public void flushTriggerRoutersByTriggerHist()

Specified by:

flushTriggerRoutersByTriggerHist in interface ICacheManager

flushTriggerRoutersById

public void flushTriggerRoutersById()

Specified by:

flushTriggerRoutersById in interface ICacheManager

flushTriggers

public void flushTriggers()

Specified by:

flushTriggers in interface ICacheManager

flushRouters

public void flushRouters()

Specified by:

flushRouters in interface ICacheManager

flushAllWithRouters

public void flushAllWithRouters()

Specified by:

flushAllWithRouters in interface ICacheManager

getSourceNodesCache

public List<Node> getSourceNodesCache(NodeGroupLinkAction eventAction,
 Node node)

Specified by:

getSourceNodesCache in interface ICacheManager

getTargetNodesCache

public List<Node> getTargetNodesCache(NodeGroupLinkAction eventAction,
 Node node)

Specified by:

getTargetNodesCache in interface ICacheManager

getNodesByGroup

public Collection<Node> getNodesByGroup(String nodeGroupId)

Specified by:

getNodesByGroup in interface ICacheManager

flushSourceNodesCache

public void flushSourceNodesCache()

Specified by:

flushSourceNodesCache in interface ICacheManager

flushTargetNodesCache

public void flushTargetNodesCache()

Specified by:

flushTargetNodesCache in interface ICacheManager

getNodeChannels

public List<NodeChannel> getNodeChannels(String nodeId)

Specified by:

getNodeChannels in interface ICacheManager

getNodeChannelCacheTime

public long getNodeChannelCacheTime()

Specified by:

getNodeChannelCacheTime in interface ICacheManager

getChannels

public Map<String,Channel> getChannels(boolean refreshCache)

Specified by:

getChannels in interface ICacheManager

getQueues

public Collection<String> getQueues(boolean refreshCache)

Specified by:

getQueues in interface ICacheManager

getNodeGroupLinks

public List<NodeGroupLink> getNodeGroupLinks(boolean refreshCache)

Specified by:

getNodeGroupLinks in interface ICacheManager

getNodeGroupChannelWindows

public Map<String,List<NodeGroupChannelWindow>> getNodeGroupChannelWindows()

Specified by:

getNodeGroupChannelWindows in interface ICacheManager

flushNodeChannels

public void flushNodeChannels()

Specified by:

flushNodeChannels in interface ICacheManager

flushChannels

public void flushChannels()

Specified by:

flushChannels in interface ICacheManager

flushNodeGroupLinks

public void flushNodeGroupLinks()

Specified by:

flushNodeGroupLinks in interface ICacheManager

flushNodeGroupChannelWindows

public void flushNodeGroupChannelWindows()

Specified by:

flushNodeGroupChannelWindows in interface ICacheManager

getConflictSettingsNodeGroupLinks

public List<DataLoaderService.ConflictNodeGroupLink> getConflictSettingsNodeGroupLinks(NodeGroupLink link,
 boolean refreshCache)

Specified by:

getConflictSettingsNodeGroupLinks in interface ICacheManager

flushConflictSettingsNodeGroupLinks

public void flushConflictSettingsNodeGroupLinks()

Specified by:

flushConflictSettingsNodeGroupLinks in interface ICacheManager

getFileTriggerRouters

public List<FileTriggerRouter> getFileTriggerRouters(boolean refreshCache)

Specified by:

getFileTriggerRouters in interface ICacheManager

flushFileTriggerRouters

public void flushFileTriggerRouters()

Specified by:

flushFileTriggerRouters in interface ICacheManager

getGrouplets

public List<Grouplet> getGrouplets(boolean refreshCache)

Specified by:

getGrouplets in interface ICacheManager

flushGrouplets

public void flushGrouplets()

Specified by:

flushGrouplets in interface ICacheManager

findLoadFilters

public Map<NodeGroupLink,Map<LoadFilter.LoadFilterType,Map<String,List<LoadFilter>>>> findLoadFilters(NodeGroupLink nodeGroupLink,
 boolean useCache)

Specified by:

findLoadFilters in interface ICacheManager

flushLoadFilters

public void flushLoadFilters()

Specified by:

flushLoadFilters in interface ICacheManager

getTransformCache

public Map<NodeGroupLink,Map<TransformPoint,List<TransformService.TransformTableNodeGroupLink>>> getTransformCache()

Specified by:

getTransformCache in interface ICacheManager

flushTransformCache

public void flushTransformCache()

Specified by:

flushTransformCache in interface ICacheManager

getReadyQueues

public Map<String,Collection<String>> getReadyQueues(boolean refreshCache)

Specified by:

getReadyQueues in interface ICacheManager

flushReadyQueuesCache

public void flushReadyQueuesCache()

Specified by:

flushReadyQueuesCache in interface ICacheManager