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 and Description
ConfigurationService(IParameterService parameterService, ISymmetricDialect dialect, INodeService nodeService)

Method Summary

Modifier and Type	Method and Description
void	clearCache()
boolean	containsMasterToMaster()
protected void	createDefaultChannels()
void	deleteAllNodeGroupLinks()
void	deleteChannel(Channel channel)
void	deleteNodeGroup(java.lang.String nodeGroupId)
void	deleteNodeGroupLink(NodeGroupLink link)
boolean	doesNodeGroupExist(java.lang.String nodeGroupId)
Channel	getChannel(java.lang.String channelId)
java.util.Map<java.lang.String,Channel>	getChannels(boolean refreshCache)
NodeGroupLinkAction	getDataEventActionByGroupLinkId(java.lang.String sourceGroupId, java.lang.String targetGroupId)
java.util.List<Channel>	getFileSyncChannels()
NodeChannel	getNodeChannel(java.lang.String channelId, boolean refreshExtractMillis)
NodeChannel	getNodeChannel(java.lang.String channelId, java.lang.String nodeId, boolean refreshExtractMillis)
java.util.List<NodeChannel>	getNodeChannels(boolean refreshExtractMillis)
java.util.List<NodeChannel>	getNodeChannels(java.lang.String nodeId, boolean refreshExtractMillis)
java.util.List<NodeGroupChannelWindow>	getNodeGroupChannelWindows(java.lang.String notUsed, java.lang.String channelId)
NodeGroupLink	getNodeGroupLinkFor(java.lang.String sourceNodeGroupId, java.lang.String targetNodeGroupId, boolean refreshCache)
java.util.List<NodeGroupLink>	getNodeGroupLinks(boolean refreshCache)
java.util.List<NodeGroupLink>	getNodeGroupLinksFor(java.lang.String sourceNodeGroupId, boolean refreshCache)
java.util.List<NodeGroup>	getNodeGroups()
java.util.Map<java.lang.String,java.lang.String>	getRegistrationRedirectMap()
ChannelMap	getSuspendIgnoreChannelLists()
ChannelMap	getSuspendIgnoreChannelLists(java.lang.String nodeId) Returns two sets of channel names, one for suspended channels and one for ignored.
void	initDefaultChannels()
boolean	isChannelInUse(java.lang.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	refreshFromDatabase()
void	saveChannel(Channel channel, boolean reloadChannels)
void	saveChannel(NodeChannel nodeChannel, 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, buildBatchWhere, close, createSqlReplacementTokens, 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 Detail

ConfigurationService

public ConfigurationService(IParameterService parameterService,
                            ISymmetricDialect dialect,
                            INodeService nodeService)

Method Detail

createDefaultChannels

protected void createDefaultChannels()

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

refreshFromDatabase

public boolean refreshFromDatabase()

Specified by:

refreshFromDatabase in interface IConfigurationService

saveNodeGroupLink

public void saveNodeGroupLink(NodeGroupLink link)

Specified by:

saveNodeGroupLink in interface IConfigurationService

doesNodeGroupExist

public boolean doesNodeGroupExist(java.lang.String nodeGroupId)

saveNodeGroup

public void saveNodeGroup(NodeGroup group)

Specified by:

saveNodeGroup in interface IConfigurationService

deleteNodeGroup

public void deleteNodeGroup(java.lang.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 java.util.List<NodeGroup> getNodeGroups()

Specified by:

getNodeGroups in interface IConfigurationService

getNodeGroupLinks

public java.util.List<NodeGroupLink> getNodeGroupLinks(boolean refreshCache)

Specified by:

getNodeGroupLinks in interface IConfigurationService

getNodeGroupLinksFor

public java.util.List<NodeGroupLink> getNodeGroupLinksFor(java.lang.String sourceNodeGroupId,
                                                          boolean refreshCache)

Specified by:

getNodeGroupLinksFor in interface IConfigurationService

getNodeGroupLinkFor

public NodeGroupLink getNodeGroupLinkFor(java.lang.String sourceNodeGroupId,
                                         java.lang.String targetNodeGroupId,
                                         boolean refreshCache)

Specified by:

getNodeGroupLinkFor in interface IConfigurationService

isChannelInUse

public boolean isChannelInUse(java.lang.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

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

getNodeChannel

public NodeChannel getNodeChannel(java.lang.String channelId,
                                  boolean refreshExtractMillis)

Specified by:

getNodeChannel in interface IConfigurationService

getNodeChannel

public NodeChannel getNodeChannel(java.lang.String channelId,
                                  java.lang.String nodeId,
                                  boolean refreshExtractMillis)

Specified by:

getNodeChannel in interface IConfigurationService

getNodeChannels

public java.util.List<NodeChannel> getNodeChannels(boolean refreshExtractMillis)

Specified by:

getNodeChannels in interface IConfigurationService

getNodeChannels

public java.util.List<NodeChannel> getNodeChannels(java.lang.String nodeId,
                                                   boolean refreshExtractMillis)

Specified by:

getNodeChannels in interface IConfigurationService

clearCache

public void clearCache()

Specified by:

clearCache in interface IConfigurationService

getDataEventActionByGroupLinkId

public NodeGroupLinkAction getDataEventActionByGroupLinkId(java.lang.String sourceGroupId,
                                                           java.lang.String targetGroupId)

Specified by:

getDataEventActionByGroupLinkId in interface IConfigurationService

initDefaultChannels

public void initDefaultChannels()

Specified by:

initDefaultChannels in interface IConfigurationService

getNodeGroupChannelWindows

public java.util.List<NodeGroupChannelWindow> getNodeGroupChannelWindows(java.lang.String notUsed,
                                                                         java.lang.String channelId)

Specified by:

getNodeGroupChannelWindows in interface IConfigurationService

getSuspendIgnoreChannelLists

public ChannelMap getSuspendIgnoreChannelLists(java.lang.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 java.util.List<Channel> getFileSyncChannels()

Specified by:

getFileSyncChannels in interface IConfigurationService

getChannels

public java.util.Map<java.lang.String,Channel> getChannels(boolean refreshCache)

Specified by:

getChannels in interface IConfigurationService

getChannel

public Channel getChannel(java.lang.String channelId)

Specified by:

getChannel in interface IConfigurationService

getSuspendIgnoreChannelLists

public ChannelMap getSuspendIgnoreChannelLists()

Specified by:

getSuspendIgnoreChannelLists in interface IConfigurationService

getRegistrationRedirectMap

public java.util.Map<java.lang.String,java.lang.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