org.jumpmind.symmetric.service.jmx
Class NodeManagementService

java.lang.Object
  org.jumpmind.symmetric.service.jmx.NodeManagementService

@ManagedResource(description="The management interface for a node")
public class NodeManagementService
extends java.lang.Object

Constructor Summary

NodeManagementService()

Method Summary

void	addNodeToWhiteList(java.lang.String nodeId)
void	clearAllLocks()
java.lang.String	getCurrentNodeConcurrencyReservationsAsText()
java.lang.String	getExternalId()
java.lang.String	getNodeConcurrencyStatisticsAsText()
java.lang.String	getNodeGroupId()
java.lang.String	getNodeId()
java.lang.String	getNodesInWhiteList()
int	getNumberOfActiveConnections()
int	getNumfNodeConnectionsPerInstance()
long	getNumOfNodesWhoConnectedAndWereRejectedForInstanceLifetime()
long	getNumOfNodesWhoConnectedForInstanceLifetime()
long	getNumOfNodesWhoReservedConnectionsForInstanceLifetime()
void	ignoreNodeChannelForExternalId(boolean ignore, java.lang.String channelId, java.lang.String nodeGroupId, java.lang.String externalId)
boolean	isBasicDataSource()
boolean	isExternalIdRegistered(java.lang.String nodeGroupdId, java.lang.String externalId)
boolean	isInitialLoadComplete(java.lang.String nodeId)
void	openRegistration(java.lang.String nodeGroupId, java.lang.String externalId)
void	purge()
java.lang.String	reloadNode(java.lang.String nodeId)
java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String tableName)
java.lang.String	reloadTable(java.lang.String nodeId, java.lang.String tableName, java.lang.String overrideInitialLoadSelect)
void	removeNodeFromWhiteList(java.lang.String nodeId)
java.lang.String	sendSQL(java.lang.String nodeId, java.lang.String tableName, java.lang.String sql)
void	setBootstrapService(IBootstrapService bootstrapService)
void	setClusterService(IClusterService clusterService)
void	setConcurrentConnectionManager(IConcurrentConnectionManager concurrentConnectionManager)
void	setDataExtractorService(IDataExtractorService dataExtractorService)
void	setDataService(IDataService dataService)
void	setDataSource(javax.sql.DataSource dataSource)
void	setNodeService(INodeService nodeService)
void	setNumOfNodeConnectionsPerInstance(int value)
void	setOutgoingBatchService(IOutgoingBatchService outgoingBatchService)
void	setParameterService(IParameterService parameterService)
void	setPurgeService(IPurgeService purgeService)
void	setRegistrationService(IRegistrationService registrationService)
void	setStatisticManager(IStatisticManager statisticManager)
boolean	setSyncEnabledForNode(java.lang.String nodeId, boolean syncEnabled)
void	syncTriggers()
void	writeBatchRangeToFile(java.lang.String startBatchId, java.lang.String endBatchId, java.lang.String fileName)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeManagementService

public NodeManagementService()

Method Detail

setStatisticManager

public void setStatisticManager(IStatisticManager statisticManager)

purge

@ManagedOperation(description="Run the purge process")
public void purge()

syncTriggers

@ManagedOperation(description="Synchronize the triggers")
public void syncTriggers()

getNumfNodeConnectionsPerInstance

@ManagedAttribute(description="Get the number of current connections allowed to this instance of the node via HTTP.  If this value is 20, then 20 concurrent push clients and 20 concurrent pull clients will be allowed")
public int getNumfNodeConnectionsPerInstance()

getNodeConcurrencyStatisticsAsText

@ManagedAttribute(description="Get connection statistics about indivdual nodes")
public java.lang.String getNodeConcurrencyStatisticsAsText()

getCurrentNodeConcurrencyReservationsAsText

public java.lang.String getCurrentNodeConcurrencyReservationsAsText()

getNodesInWhiteList

@ManagedAttribute(description="Get a list of nodes that have been added to the white list, a list of node ids that always get through the concurrency manager.")
public java.lang.String getNodesInWhiteList()

addNodeToWhiteList

@ManagedOperation(description="Add a node id to the list of nodes that will always get through the concurrency manager")
@ManagedOperationParameters(value=)
public void addNodeToWhiteList(java.lang.String nodeId)

removeNodeFromWhiteList

@ManagedOperation(description="Remove a node id to the list of nodes that will always get through the concurrency manager")
@ManagedOperationParameters(value=)
public void removeNodeFromWhiteList(java.lang.String nodeId)

setNumOfNodeConnectionsPerInstance

@ManagedAttribute(description="Configure the number of connections allowed to this node.  If the value is set to zero you are effectively disabling your transport (wihch can be useful for maintainance")
public void setNumOfNodeConnectionsPerInstance(int value)

getNumOfNodesWhoConnectedAndWereRejectedForInstanceLifetime

@ManagedAttribute(description="This is a count of nodes who connected to push or pull data and were rejected because the server was too busy")
public long getNumOfNodesWhoConnectedAndWereRejectedForInstanceLifetime()

getNumOfNodesWhoConnectedForInstanceLifetime

@ManagedAttribute(description="This is a count of the number of reservations that were handled by this instance")
public long getNumOfNodesWhoConnectedForInstanceLifetime()

getNumOfNodesWhoReservedConnectionsForInstanceLifetime

@ManagedAttribute(description="This is a count of the number of reservations that handed out by this instance")
public long getNumOfNodesWhoReservedConnectionsForInstanceLifetime()

getNodeGroupId

@ManagedAttribute(description="The group this node belongs to")
public java.lang.String getNodeGroupId()

getExternalId

@ManagedAttribute(description="An external name given to this SymmetricDS node")
public java.lang.String getExternalId()

getNodeId

@ManagedAttribute(description="The node id given to this SymmetricDS node")
public java.lang.String getNodeId()

isBasicDataSource

@ManagedAttribute(description="Whether the basic DataSource is being used as the default datasource.")
public boolean isBasicDataSource()

getNumberOfActiveConnections

@ManagedAttribute(description="If a BasicDataSource, then show the number of active connections")
public int getNumberOfActiveConnections()

isExternalIdRegistered

@ManagedOperation(description="Check to see if the external id is registered")
@ManagedOperationParameters(value={,})
public boolean isExternalIdRegistered(java.lang.String nodeGroupdId,
                                                                                  java.lang.String externalId)

clearAllLocks

@ManagedOperation(description="Emergency remove all locks (if left abandoned on a cluster)")
public void clearAllLocks()

isInitialLoadComplete

@ManagedOperation(description="Check to see if the initial load for a node id is complete.  This method will throw an exception if the load error\'d out or was never started.")
@ManagedOperationParameters(value=)
public boolean isInitialLoadComplete(java.lang.String nodeId)

setSyncEnabledForNode

@ManagedOperation(description="Enable or disable synchronization completely for a node")
@ManagedOperationParameters(value={,})
public boolean setSyncEnabledForNode(java.lang.String nodeId,
                                                                                 boolean syncEnabled)

ignoreNodeChannelForExternalId

@ManagedOperation(description="Enable or disable a channel for a specific external id")
@ManagedOperationParameters(value={,,,})
public void ignoreNodeChannelForExternalId(boolean ignore,
                                                                                       java.lang.String channelId,
                                                                                       java.lang.String nodeGroupId,
                                                                                       java.lang.String externalId)

openRegistration

@ManagedOperation(description="Open the registration for a node with the specified external id")
@ManagedOperationParameters(value={,})
public void openRegistration(java.lang.String nodeGroupId,
                                                                         java.lang.String externalId)

reloadNode

@ManagedOperation(description="Send an initial load of data to a node.")
@ManagedOperationParameters(value=)
public java.lang.String reloadNode(java.lang.String nodeId)

sendSQL

@ManagedOperation(description="Send a SQL event to a node.")
@ManagedOperationParameters(value={,,})
public java.lang.String sendSQL(java.lang.String nodeId,
                                                                            java.lang.String tableName,
                                                                            java.lang.String sql)

reloadTable

@ManagedOperation(description="Send a delete and reload of a table to a node.")
@ManagedOperationParameters(value={,})
public java.lang.String reloadTable(java.lang.String nodeId,
                                                                                java.lang.String tableName)

reloadTable

@ManagedOperation(description="Send a delete and reload of a table to a node.")
@ManagedOperationParameters(value={,,})
public java.lang.String reloadTable(java.lang.String nodeId,
                                                                                java.lang.String tableName,
                                                                                java.lang.String overrideInitialLoadSelect)

writeBatchRangeToFile

@ManagedOperation(description="Write a range of batches to a file in SymmetricDS Data Format.")
@ManagedOperationParameters(value={,,})
public void writeBatchRangeToFile(java.lang.String startBatchId,
                                                                              java.lang.String endBatchId,
                                                                              java.lang.String fileName)
                           throws java.lang.Exception

Throws:

java.lang.Exception

setBootstrapService

public void setBootstrapService(IBootstrapService bootstrapService)

setPurgeService

public void setPurgeService(IPurgeService purgeService)

setDataSource

public void setDataSource(javax.sql.DataSource dataSource)

setDataService

public void setDataService(IDataService dataService)

setNodeService

public void setNodeService(INodeService nodeService)

setRegistrationService

public void setRegistrationService(IRegistrationService registrationService)

setOutgoingBatchService

public void setOutgoingBatchService(IOutgoingBatchService outgoingBatchService)

setDataExtractorService

public void setDataExtractorService(IDataExtractorService dataExtractorService)

setClusterService

public void setClusterService(IClusterService clusterService)

setParameterService

public void setParameterService(IParameterService parameterService)

setConcurrentConnectionManager

public void setConcurrentConnectionManager(IConcurrentConnectionManager concurrentConnectionManager)