public class RegistrationService extends AbstractService implements IRegistrationService
IRegistrationServicelog, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
RegistrationService(ISymmetricEngine engine) |
| 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) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdspublic RegistrationService(ISymmetricEngine engine)
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
IRegistrationServiceregisterPullOnlyNode in interface IRegistrationServicejava.io.IOExceptionpublic boolean registerNode(Node preRegisteredNode, java.io.OutputStream out, boolean isRequestedRegistration) throws java.io.IOException
IRegistrationServiceregisterNode in interface IRegistrationServiceisRequestedRegistration - An indicator that registration has been requested by the
remote clientjava.io.IOExceptionprotected void extractConfiguration(java.io.OutputStream out,
Node registeredNode)
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
java.io.IOExceptionpublic 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
IRegistrationServiceregisterNode in interface IRegistrationServiceisRequestedRegistration - An indicator that registration has been requested by the
remote clientjava.io.IOExceptionIRegistrationService.registerNode(Node, OutputStream, boolean)public java.util.List<RegistrationRequest> getRegistrationRequests(boolean includeNodesWithOpenRegistrations)
getRegistrationRequests in interface IRegistrationServicepublic boolean deleteRegistrationRequest(RegistrationRequest request)
deleteRegistrationRequest in interface IRegistrationServicepublic void saveRegistrationRequest(RegistrationRequest request)
saveRegistrationRequest in interface IRegistrationServicepublic java.lang.String getRedirectionUrlFor(java.lang.String externalId)
getRedirectionUrlFor in interface IRegistrationServicepublic void saveRegistrationRedirect(java.lang.String externalIdToRedirect,
java.lang.String nodeIdToRedirectTo)
IRegistrationServicesaveRegistrationRedirect in interface IRegistrationServicepublic void markNodeAsRegistered(java.lang.String nodeId)
IRegistrationServicemarkNodeAsRegistered in interface IRegistrationServicenodeId - is the node that has just finished 'successfully' registeringIRegistrationService#markNodeAsRegistered(Node)protected void markNodeAsRegistrationPending(java.lang.String nodeId)
public boolean isRegisteredWithServer()
isRegisteredWithServer in interface IRegistrationServicepublic boolean registerWithServer()
IRegistrationServiceregisterWithServer in interface IRegistrationServiceIRegistrationService.registerWithServer()public boolean attemptToRegisterWithServer(int maxNumberOfAttempts)
IRegistrationServiceattemptToRegisterWithServer in interface IRegistrationServiceprotected boolean checkRegistrationSuccessful(boolean registered,
int maxNumberOfAttempts)
public void reOpenRegistration(java.lang.String nodeId)
IRegistrationServicereOpenRegistration in interface IRegistrationServiceIRegistrationService.reOpenRegistration(String)protected void reOpenRegistration(java.lang.String nodeId,
java.lang.String remoteHost,
java.lang.String remoteAddress)
public java.lang.String openRegistration(java.lang.String nodeGroup,
java.lang.String externalId)
IRegistrationServiceopenRegistration in interface IRegistrationServiceIRegistrationService.openRegistration(String, String)public java.lang.String openRegistration(java.lang.String nodeGroup,
java.lang.String externalId,
java.lang.String remoteHost,
java.lang.String remoteAddress)
openRegistration in interface IRegistrationServicepublic java.lang.String openRegistration(Node node)
openRegistration in interface IRegistrationServiceprotected java.lang.String openRegistration(Node node, java.lang.String remoteHost, java.lang.String remoteAddress)
public boolean isAutoRegistration()
isAutoRegistration in interface IRegistrationServicepublic boolean isRegistrationOpen(java.lang.String nodeGroupId,
java.lang.String externalId)
isRegistrationOpen in interface IRegistrationServicepublic void requestNodeCopy()
requestNodeCopy in interface IRegistrationServicepublic void setAllowClientRegistration(boolean enabled)
setAllowClientRegistration in interface IRegistrationService