Package org.jumpmind.symmetric.service.impl

Class ConfigurationService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.ConfigurationService

All Implemented Interfaces:

IConfigurationService, IService

public class ConfigurationService
extends AbstractService
implements IConfigurationService

See Also:

• IConfigurationService

Field Summary

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
ConfigurationService(ISymmetricEngine engine, ISymmetricDialect dialect)

Method Summary

Modifier and Type	Method	Description
void	clearCache()
boolean	containsMasterToMaster()
protected final void	createDefaultChannels()
void	deleteAllChannels()
void	deleteAllNodeGroupLinks()
void	deleteChannel(Channel channel)
void	deleteNodeChannelControl(String nodeId, String channelId)
void	deleteNodeGroup(String nodeGroupId)
void	deleteNodeGroupLink(NodeGroupLink link)
boolean	doesNodeGroupExist(String nodeGroupId)
Channel	getChannel(String channelId)
Map<String,Channel>	getChannels(boolean refreshCache)
Map<String,Channel>	getChannelsFromDb()
NodeGroupLinkAction	getDataEventActionByGroupLinkId(String sourceGroupId, String targetGroupId)
List<Channel>	getFileSyncChannels()
NodeChannel	getNodeChannel(String channelId, boolean refreshExtractMillis)
NodeChannel	getNodeChannel(String channelId, String nodeId, boolean refreshExtractMillis)
List<NodeChannel>	getNodeChannels(boolean refreshExtractMillis)
List<NodeChannel>	getNodeChannels(String nodeId, boolean refreshExtractMillis)
List<NodeChannel>	getNodeChannelsFromDb(String nodeId)
List<NodeGroupChannelWindow>	getNodeGroupChannelWindows(String notUsed, String channelId)
Map<String,List<NodeGroupChannelWindow>>	getNodeGroupChannelWindowsFromDb()
NodeGroupLink	getNodeGroupLinkFor(String sourceNodeGroupId, String targetNodeGroupId, boolean refreshCache)
List<NodeGroupLink>	getNodeGroupLinks(boolean refreshCache)
List<NodeGroupLink>	getNodeGroupLinksFor(String sourceNodeGroupId, boolean refreshCache)
List<NodeGroupLink>	getNodeGroupLinksFromDb()
List<NodeGroup>	getNodeGroups()
Collection<String>	getQueues(boolean refreshCache)
Map<String,String>	getRegistrationRedirectMap()
ChannelMap	getSuspendIgnoreChannelLists()
ChannelMap	getSuspendIgnoreChannelLists(String nodeId)	Returns two sets of channel names, one for suspended channels and one for ignored.
void	initDefaultChannels()
boolean	isBulkLoaderEnabled()
boolean	isChannelInUse(String channelId)	Check to see if the channel is currently being used in the system.
boolean	isMasterToMaster()	Indicates that this node participates in a master to master link
boolean	isMasterToMasterOnly()
boolean	isUseSourceStagingEnabled(String nodeId)
boolean	refreshFromDatabase()
void	renameChannel(String oldId, Channel channel)
void	renameNodeGroupLink(String oldSourceId, String oldTargetId, NodeGroupLink link)
void	saveChannel(Channel channel, boolean reloadChannels)
void	saveChannel(NodeChannel nodeChannel, boolean reloadChannels)
void	saveChannelAsCopy(Channel channel, boolean reloadChannels)
void	saveNodeChannel(NodeChannel nodeChannel, boolean reloadChannels)
void	saveNodeChannelControl(NodeChannel nodeChannel, boolean reloadChannels)
void	saveNodeGroup(NodeGroup group)
void	saveNodeGroupLink(NodeGroupLink link)
void	updateLastExtractTime(NodeChannel channel)

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Constructor Details

ConfigurationService

public ConfigurationService(ISymmetricEngine engine,
 ISymmetricDialect dialect)

Method Details

createDefaultChannels

protected final void createDefaultChannels()

isBulkLoaderEnabled

public boolean isBulkLoaderEnabled()

Specified by:

isBulkLoaderEnabled in interface IConfigurationService

isMasterToMaster

public boolean isMasterToMaster()

Description copied from interface: IConfigurationService

Indicates that this node participates in a master to master link

Specified by:

isMasterToMaster in interface IConfigurationService

Returns:

containsMasterToMaster

public boolean containsMasterToMaster()

Specified by:

containsMasterToMaster in interface IConfigurationService

isMasterToMasterOnly

public boolean isMasterToMasterOnly()

Specified by:

isMasterToMasterOnly in interface IConfigurationService

isUseSourceStagingEnabled

public boolean isUseSourceStagingEnabled(String nodeId)

Specified by:

isUseSourceStagingEnabled in interface IConfigurationService

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface IConfigurationService

saveNodeGroupLink

public void saveNodeGroupLink(NodeGroupLink link)

Specified by:

saveNodeGroupLink in interface IConfigurationService

renameNodeGroupLink

public void renameNodeGroupLink(String oldSourceId,
 String oldTargetId,
 NodeGroupLink link)

Specified by:

renameNodeGroupLink in interface IConfigurationService

doesNodeGroupExist

public boolean doesNodeGroupExist(String nodeGroupId)

saveNodeGroup

public void saveNodeGroup(NodeGroup group)

Specified by:

saveNodeGroup in interface IConfigurationService

deleteNodeGroup

public void deleteNodeGroup(String nodeGroupId)

Specified by:

deleteNodeGroup in interface IConfigurationService

deleteNodeGroupLink

public void deleteNodeGroupLink(NodeGroupLink link)

Specified by:

deleteNodeGroupLink in interface IConfigurationService

deleteAllNodeGroupLinks

public void deleteAllNodeGroupLinks()

Specified by:

deleteAllNodeGroupLinks in interface IConfigurationService

getNodeGroups

public List<NodeGroup> getNodeGroups()

Specified by:

getNodeGroups in interface IConfigurationService

getNodeGroupLinks

public List<NodeGroupLink> getNodeGroupLinks(boolean refreshCache)

Specified by:

getNodeGroupLinks in interface IConfigurationService

getNodeGroupLinksFromDb

public List<NodeGroupLink> getNodeGroupLinksFromDb()

Specified by:

getNodeGroupLinksFromDb in interface IConfigurationService

getNodeGroupLinksFor

public List<NodeGroupLink> getNodeGroupLinksFor(String sourceNodeGroupId,
 boolean refreshCache)

Specified by:

getNodeGroupLinksFor in interface IConfigurationService

getNodeGroupLinkFor

public NodeGroupLink getNodeGroupLinkFor(String sourceNodeGroupId,
 String targetNodeGroupId,
 boolean refreshCache)

Specified by:

getNodeGroupLinkFor in interface IConfigurationService

isChannelInUse

public boolean isChannelInUse(String channelId)

Description copied from interface: IConfigurationService

Check to see if the channel is currently being used in the system.

Specified by:

isChannelInUse in interface IConfigurationService

saveChannel

public void saveChannel(Channel channel,
 boolean reloadChannels)

Specified by:

saveChannel in interface IConfigurationService

saveChannel

public void saveChannel(NodeChannel nodeChannel,
 boolean reloadChannels)

Specified by:

saveChannel in interface IConfigurationService

saveChannelAsCopy

public void saveChannelAsCopy(Channel channel,
 boolean reloadChannels)

Specified by:

saveChannelAsCopy in interface IConfigurationService

renameChannel

public void renameChannel(String oldId,
 Channel channel)

Specified by:

renameChannel in interface IConfigurationService

saveNodeChannel

public void saveNodeChannel(NodeChannel nodeChannel,
 boolean reloadChannels)

Specified by:

saveNodeChannel in interface IConfigurationService

saveNodeChannelControl

public void saveNodeChannelControl(NodeChannel nodeChannel,
 boolean reloadChannels)

Specified by:

saveNodeChannelControl in interface IConfigurationService

deleteChannel

public void deleteChannel(Channel channel)

Specified by:

deleteChannel in interface IConfigurationService

deleteNodeChannelControl

public void deleteNodeChannelControl(String nodeId,
 String channelId)

Specified by:

deleteNodeChannelControl in interface IConfigurationService

deleteAllChannels

public void deleteAllChannels()

Specified by:

deleteAllChannels in interface IConfigurationService

getNodeChannel

public NodeChannel getNodeChannel(String channelId,
 boolean refreshExtractMillis)

Specified by:

getNodeChannel in interface IConfigurationService

getNodeChannel

public NodeChannel getNodeChannel(String channelId,
 String nodeId,
 boolean refreshExtractMillis)

Specified by:

getNodeChannel in interface IConfigurationService

getNodeChannels

public List<NodeChannel> getNodeChannels(boolean refreshExtractMillis)

Specified by:

getNodeChannels in interface IConfigurationService

getNodeChannels

public List<NodeChannel> getNodeChannels(String nodeId,
 boolean refreshExtractMillis)

Specified by:

getNodeChannels in interface IConfigurationService

getNodeChannelsFromDb

public List<NodeChannel> getNodeChannelsFromDb(String nodeId)

Specified by:

getNodeChannelsFromDb in interface IConfigurationService

clearCache

public void clearCache()

Specified by:

clearCache in interface IConfigurationService

getDataEventActionByGroupLinkId

public NodeGroupLinkAction getDataEventActionByGroupLinkId(String sourceGroupId,
 String targetGroupId)

Specified by:

getDataEventActionByGroupLinkId in interface IConfigurationService

initDefaultChannels

public void initDefaultChannels()

Specified by:

initDefaultChannels in interface IConfigurationService

getNodeGroupChannelWindows

public List<NodeGroupChannelWindow> getNodeGroupChannelWindows(String notUsed,
 String channelId)

Specified by:

getNodeGroupChannelWindows in interface IConfigurationService

getNodeGroupChannelWindowsFromDb

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

Specified by:

getNodeGroupChannelWindowsFromDb in interface IConfigurationService

getSuspendIgnoreChannelLists

public ChannelMap getSuspendIgnoreChannelLists(String nodeId)

Description copied from interface: IConfigurationService

Returns two sets of channel names, one for suspended channels and one for ignored.

Specified by:

getSuspendIgnoreChannelLists in interface IConfigurationService

Returns:

A Map with two entries, the sets of which will always be defined but may be empty.

getFileSyncChannels

public List<Channel> getFileSyncChannels()

Specified by:

getFileSyncChannels in interface IConfigurationService

getChannels

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

Specified by:

getChannels in interface IConfigurationService

getQueues

public Collection<String> getQueues(boolean refreshCache)

Specified by:

getQueues in interface IConfigurationService

getChannelsFromDb

public Map<String,Channel> getChannelsFromDb()

Specified by:

getChannelsFromDb in interface IConfigurationService

getChannel

public Channel getChannel(String channelId)

Specified by:

getChannel in interface IConfigurationService

getSuspendIgnoreChannelLists

public ChannelMap getSuspendIgnoreChannelLists()

Specified by:

getSuspendIgnoreChannelLists in interface IConfigurationService

getRegistrationRedirectMap

public Map<String,String> getRegistrationRedirectMap()

Specified by:

getRegistrationRedirectMap in interface IConfigurationService

Returns:

a map of nodes to redirect to that is keyed by a list of external_ids that should be redirected.

updateLastExtractTime

public void updateLastExtractTime(NodeChannel channel)

Specified by:

updateLastExtractTime in interface IConfigurationService