com.goldencode.p2j.persist.remote

Class IdentityManagerMultiplexerImpl

java.lang.Object

com.goldencode.p2j.persist.remote.DatabaseMultiplexer<IdentityManager>

com.goldencode.p2j.persist.remote.IdentityManagerMultiplexerImpl

All Implemented Interfaces:

IdentityManagerMultiplexer, RemoteMultiplexer<java.lang.String>

public final class IdentityManagerMultiplexerImpl
extends DatabaseMultiplexer<IdentityManager>
implements IdentityManagerMultiplexer

A singleton instance of this class services server-to-server requests for database identity management. This instance is registered as a remote object and serves identity management requests for one or more databases which the server authoritatively manages.

Service requests may originate from more than one external server, so this implementation is threadsafe.

Author:

SVL

Field Summary

Fields

Modifier and Type	Field and Description
private static IdentityManagerMultiplexer	instance Singleton instance of this class

Constructor Summary

Constructors

Modifier	Constructor and Description
private	IdentityManagerMultiplexerImpl() Default constructor which initializes the resources needed for this multiplexer to service identity manager requests.

Method Summary

Modifier and Type	Method and Description
protected IdentityManager	getWorker(Database database) Get the identity manager which is associated with the given database.
static void	initialize() Initialize the identity multiplexer for this server instance.
java.lang.Long	nextPrimaryKey(int database, java.lang.String table) Return the next primary key for the specified table.
void	reclaimKeys(int database, java.lang.Long[] keys) Inform the identity manager that the given primary keys can be reused.

Methods inherited from class com.goldencode.p2j.persist.remote.DatabaseMultiplexer

getMultiplexID, lookupWorker

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.goldencode.p2j.util.RemoteMultiplexer

getMultiplexID

Field Detail

instance

private static IdentityManagerMultiplexer instance

Singleton instance of this class

Constructor Detail

IdentityManagerMultiplexerImpl

private IdentityManagerMultiplexerImpl()

Default constructor which initializes the resources needed for this multiplexer to service identity manager requests.

Method Detail

initialize

public static void initialize()

Initialize the identity multiplexer for this server instance. This method is to be called during server bootstrap, but not before the local database manager has been initialized.

This method enforces the singleton pattern.

Throws:

java.lang.IllegalStateException - if this method is invoked more than once.

nextPrimaryKey

public java.lang.Long nextPrimaryKey(int database,
                                     java.lang.String table)
                              throws PersistenceException

Return the next primary key for the specified table.

Specified by:

nextPrimaryKey in interface IdentityManagerMultiplexer

Parameters:

database - Value that uniquely identifies the target database on the remote server.

table - Table for which the next primary key will be returned.

Returns:

The next primary key for the given table.

Throws:

PersistenceException - if there is an error determining the next primary key ID.

reclaimKeys

public void reclaimKeys(int database,
                        java.lang.Long[] keys)

Inform the identity manager that the given primary keys can be reused.

Specified by:

reclaimKeys in interface IdentityManagerMultiplexer

Parameters:

database - Value that uniquely identifies the target database on the remote server.

keys - Keys for reuse.

getWorker

protected IdentityManager getWorker(Database database)

Get the identity manager which is associated with the given database.

Specified by:

getWorker in class DatabaseMultiplexer<IdentityManager>

Parameters:

database - Physical database with which the returned worker is associated.

Returns:

Worker object to which service requests associated with the given database must be delegated.