org.jumpmind.symmetric.service.impl

Class RegistrationService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.RegistrationService

All Implemented Interfaces:

IRegistrationService, IService

public class RegistrationService
extends AbstractService
implements IRegistrationService

See Also:

IRegistrationService

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
RegistrationService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method and Description
boolean	attemptToRegisterWithServer(int maxNumberOfAttempts) Client method which attempts to register with the registration.url to pull configuration if the node has not already been registered.
protected boolean	checkRegistrationSuccessful(boolean registered, int maxNumberOfAttempts)
boolean	deleteRegistrationRequest(RegistrationRequest request)
protected void	extractConfiguration(java.io.OutputStream out, Node registeredNode)
java.lang.String	getRedirectionUrlFor(java.lang.String externalId)
java.util.List<RegistrationRequest>	getRegistrationRequests(boolean includeNodesWithOpenRegistrations)
boolean	isAutoRegistration()
boolean	isRegisteredWithServer()
boolean	isRegistrationOpen(java.lang.String nodeGroupId, java.lang.String externalId)
void	markNodeAsRegistered(java.lang.String nodeId) Mark the passed in node as registered in node_security
protected void	markNodeAsRegistrationPending(java.lang.String nodeId)
java.lang.String	openRegistration(Node node)
protected java.lang.String	openRegistration(Node node, java.lang.String remoteHost, java.lang.String remoteAddress)
java.lang.String	openRegistration(java.lang.String nodeGroup, java.lang.String externalId) Open registration for a single new node given a node group (f.e., "STORE") and external ID (f.e., "00001").
java.lang.String	openRegistration(java.lang.String nodeGroup, java.lang.String externalId, java.lang.String remoteHost, java.lang.String remoteAddress)
protected Node	processRegistration(Node nodePriorToRegistration, java.lang.String remoteHost, java.lang.String remoteAddress, java.lang.String userId, java.lang.String password, boolean isRequestedRegistration)
boolean	registerNode(Node preRegisteredNode, java.io.OutputStream out, boolean isRequestedRegistration) Register a node for the given group name and external id if the registration is open.
boolean	registerNode(Node nodePriorToRegistration, java.lang.String remoteHost, java.lang.String remoteAddress, java.io.OutputStream out, java.lang.String userId, java.lang.String password, boolean isRequestedRegistration) Register a node for the given group name and external id if the registration is open.
Node	registerPullOnlyNode(java.lang.String externalId, java.lang.String nodeGroupId, java.lang.String databaseType, java.lang.String databaseVersion, java.lang.String databaseName) Register a "Pull Only" node.
boolean	registerWithServer() Client method which attempts to register with the registration.url to pull configuration if the node has not already been registered.
void	reOpenRegistration(java.lang.String nodeId) Re-open registration for a single node that already exists in the database.
protected void	reOpenRegistration(java.lang.String nodeId, java.lang.String remoteHost, java.lang.String remoteAddress)
void	requestNodeCopy()
void	saveRegistrationRedirect(java.lang.String externalIdToRedirect, java.lang.String nodeIdToRedirectTo) Add an entry to the registation_redirect table so that if a node tries to register here.
void	saveRegistrationRequest(RegistrationRequest request)
void	setAllowClientRegistration(boolean enabled)

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

RegistrationService

public RegistrationService(ISymmetricEngine engine)

Method Detail

registerPullOnlyNode

public Node registerPullOnlyNode(java.lang.String externalId,
                                 java.lang.String nodeGroupId,
                                 java.lang.String databaseType,
                                 java.lang.String databaseVersion,
                                 java.lang.String databaseName)
                          throws java.io.IOException

Description copied from interface: IRegistrationService

Register a "Pull Only" node. This type of node has no Symmetric configuration and can only be used to PULL data from another node. It can never track changes or push data to other nodes. When a node of this type is registered, it must complete all symmetric client functionality by itself including issue the pull, acknowledging batches, etc.

Specified by:

registerPullOnlyNode in interface IRegistrationService

Throws:

java.io.IOException

registerNode

public boolean registerNode(Node preRegisteredNode,
                            java.io.OutputStream out,
                            boolean isRequestedRegistration)
                     throws java.io.IOException

Description copied from interface: IRegistrationService

Register a node for the given group name and external id if the registration is open.

Specified by:

registerNode in interface IRegistrationService

isRequestedRegistration - An indicator that registration has been requested by the remote client

Throws:

java.io.IOException

extractConfiguration

protected void extractConfiguration(java.io.OutputStream out,
                                    Node registeredNode)

processRegistration

protected Node processRegistration(Node nodePriorToRegistration,
                                   java.lang.String remoteHost,
                                   java.lang.String remoteAddress,
                                   java.lang.String userId,
                                   java.lang.String password,
                                   boolean isRequestedRegistration)
                            throws java.io.IOException

Throws:

java.io.IOException

registerNode

public boolean registerNode(Node nodePriorToRegistration,
                            java.lang.String remoteHost,
                            java.lang.String remoteAddress,
                            java.io.OutputStream out,
                            java.lang.String userId,
                            java.lang.String password,
                            boolean isRequestedRegistration)
                     throws java.io.IOException

Description copied from interface: IRegistrationService

Register a node for the given group name and external id if the registration is open.

Specified by:

registerNode in interface IRegistrationService

isRequestedRegistration - An indicator that registration has been requested by the remote client

Throws:

java.io.IOException

See Also:

IRegistrationService.registerNode(Node, OutputStream, boolean)

getRegistrationRequests

public java.util.List<RegistrationRequest> getRegistrationRequests(boolean includeNodesWithOpenRegistrations)

Specified by:

getRegistrationRequests in interface IRegistrationService

deleteRegistrationRequest

public boolean deleteRegistrationRequest(RegistrationRequest request)

Specified by:

deleteRegistrationRequest in interface IRegistrationService

saveRegistrationRequest

public void saveRegistrationRequest(RegistrationRequest request)

Specified by:

saveRegistrationRequest in interface IRegistrationService

getRedirectionUrlFor

public java.lang.String getRedirectionUrlFor(java.lang.String externalId)

Specified by:

getRedirectionUrlFor in interface IRegistrationService

saveRegistrationRedirect

public void saveRegistrationRedirect(java.lang.String externalIdToRedirect,
                                     java.lang.String nodeIdToRedirectTo)

Description copied from interface: IRegistrationService

Add an entry to the registation_redirect table so that if a node tries to register here. It will be redirected to the correct node.

Specified by:

saveRegistrationRedirect in interface IRegistrationService

markNodeAsRegistered

public void markNodeAsRegistered(java.lang.String nodeId)

Description copied from interface: IRegistrationService

Mark the passed in node as registered in node_security

Specified by:

markNodeAsRegistered in interface IRegistrationService

Parameters:

nodeId - is the node that has just finished 'successfully' registering

See Also:

IRegistrationService#markNodeAsRegistered(Node)

markNodeAsRegistrationPending

protected void markNodeAsRegistrationPending(java.lang.String nodeId)

isRegisteredWithServer

public boolean isRegisteredWithServer()

Specified by:

isRegisteredWithServer in interface IRegistrationService

registerWithServer

public boolean registerWithServer()

Description copied from interface: IRegistrationService

Client method which attempts to register with the registration.url to pull configuration if the node has not already been registered. If the registration server cannot be reach this method will continue to try with random sleep periods up to one minute up until the registration succeeds or the maximum number of attempts has been reached. Returns true if we had to register with server and was successful. Returns false if we did not have to register.

Specified by:

registerWithServer in interface IRegistrationService

See Also:

IRegistrationService.registerWithServer()

attemptToRegisterWithServer

public boolean attemptToRegisterWithServer(int maxNumberOfAttempts)

Description copied from interface: IRegistrationService

Client method which attempts to register with the registration.url to pull configuration if the node has not already been registered. Returns true if registered successfully

Specified by:

attemptToRegisterWithServer in interface IRegistrationService

checkRegistrationSuccessful

protected boolean checkRegistrationSuccessful(boolean registered,
                                              int maxNumberOfAttempts)

reOpenRegistration

public void reOpenRegistration(java.lang.String nodeId)

Description copied from interface: IRegistrationService

Re-open registration for a single node that already exists in the database. A new password is generated and the registration_enabled flag is turned on. The next node to try registering for this node group and external ID will be given this information.

Specified by:

reOpenRegistration in interface IRegistrationService

See Also:

IRegistrationService.reOpenRegistration(String)

reOpenRegistration

protected void reOpenRegistration(java.lang.String nodeId,
                                  java.lang.String remoteHost,
                                  java.lang.String remoteAddress)

openRegistration

public java.lang.String openRegistration(java.lang.String nodeGroup,
                                         java.lang.String externalId)

Description copied from interface: IRegistrationService

Open registration for a single new node given a node group (f.e., "STORE") and external ID (f.e., "00001"). The unique node ID and password are generated and stored in the node and node_security tables with the registration_enabled flag turned on. The next node to try registering for this node group and external ID will be given this information.

Specified by:

openRegistration in interface IRegistrationService

Returns:

The nodeId of the registered node

See Also:

IRegistrationService.openRegistration(String, String)

openRegistration

public java.lang.String openRegistration(java.lang.String nodeGroup,
                                         java.lang.String externalId,
                                         java.lang.String remoteHost,
                                         java.lang.String remoteAddress)

Specified by:

openRegistration in interface IRegistrationService

openRegistration

public java.lang.String openRegistration(Node node)

Specified by:

openRegistration in interface IRegistrationService

openRegistration

protected java.lang.String openRegistration(Node node,
                                            java.lang.String remoteHost,
                                            java.lang.String remoteAddress)

isAutoRegistration

public boolean isAutoRegistration()

Specified by:

isAutoRegistration in interface IRegistrationService

isRegistrationOpen

public boolean isRegistrationOpen(java.lang.String nodeGroupId,
                                  java.lang.String externalId)

Specified by:

isRegistrationOpen in interface IRegistrationService

requestNodeCopy

public void requestNodeCopy()

Specified by:

requestNodeCopy in interface IRegistrationService

setAllowClientRegistration

public void setAllowClientRegistration(boolean enabled)

Specified by:

setAllowClientRegistration in interface IRegistrationService