com.sun.jini.mahalo

Class TxnManagerImpl

java.lang.Object

com.sun.jini.mahalo.TxnManagerImpl

All Implemented Interfaces:

DestroyAdmin, TimeConstants, Landlord, LocalLandlord, LeaseExpirationMgr.Expirer, LogRecovery, TxnManager, TxnSettler, ServiceProxyAccessor, Remote, Administrable, JoinAdmin, ExtendedTransactionManager, TransactionConstants, TransactionManager, ProxyAccessor, ServerProxyTrust

Direct Known Subclasses:

TransientMahaloImpl

public class TxnManagerImpl
extends Object
implements TxnManager, LeaseExpirationMgr.Expirer, LogRecovery, TxnSettler, TimeConstants, LocalLandlord, ServerProxyTrust, ProxyAccessor

An implementation of the Jini(TM) Transaction Specification.

Author:

Sun Microsystems, Inc.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TxnManagerImpl.IdGenT

Nested classes/interfaces inherited from interface com.sun.jini.landlord.Landlord

Landlord.RenewResults

Nested classes/interfaces inherited from interface net.jini.core.transaction.server.TransactionManager

TransactionManager.Created

Field Summary

Fields

Modifier and Type	Field and Description
protected Exporter	exporter The exporter for exporting and unexporting
protected LoginContext	loginContext The login context, for logging out

Fields inherited from interface com.sun.jini.mahalo.TxnManager

MAHALO

Fields inherited from interface net.jini.core.transaction.server.TransactionConstants

ABORTED, ACTIVE, COMMITTED, NOTCHANGED, PREPARED, VOTING

Fields inherited from interface com.sun.jini.constants.TimeConstants

DAYS, HOURS, MINUTES, SECONDS

Method Summary

Modifier and Type	Method and Description
void	abort_impl(Object id, long waitFor)
void	abort(long id) Abort the transaction.
void	abort(long id, long waitFor) Abort the transaction, waiting for participants to be notified of the decision.
void	abort(Object xid)
void	abort(Object xid, long waitFor)
void	addLookupAttributes(Entry[] attrSets) Add attribute sets for the service.
void	addLookupGroups(String[] groups) Add new groups to the set to join.
void	addLookupLocators(LookupLocator[] locators) Add locators for specific new lookup services to join.
void	cancel(Uuid uuid) Cancels the lease on a Transaction.
Map	cancelAll(Uuid[] cookies) Bulk cancel of leases on Transactions.
void	commit(long id) Commit the transaction.
void	commit(long id, long waitFor) Commit the transaction, waiting for participants to be notified of the decision.
void	commit(Object xid)
void	commit(Object xid, long waitFor)
TransactionManager.Created	create(long lease) Begin a new top-level transaction.
TransactionManager.Created	create(Object externalXid, long lease)
void	destroy() Cleans up and exits the transaction manager.
boolean	disJoin(long id, TransactionParticipant part) Remove a participant that was joined for a first time.
boolean	disJoin(Object id, TransactionParticipant part)
Object	getAdmin() Returns the administration object for the transaction manager.
TransactionManager	getLocalProxy()
Entry[]	getLookupAttributes() Get the current attribute sets for the service.
String[]	getLookupGroups() Get the list of groups to join.
LookupLocator[]	getLookupLocators() Get the list of locators of specific lookup services to join.
Object	getProxy() Returns a proxy object for this remote object.
TrustVerifier	getProxyVerifier() Returns a TrustVerifier that can be used to verify that a proxy can be trusted as a proxy for the service; that is, the isTrustedObject method of the returned verifier can be called with a candidate proxy.
Object	getServiceProxy() Returns a proxy object for this object.
int	getState(long id) Returns the current state of the given transaction.
int	getState(Object id)
Transaction	getTransaction(long id) Method from TxnManager which produces a Transaction from its ID.
Uuid	getTransactionManagerId()
protected void	initFailed(Throwable e) Log information about failing to initialize the service and rethrow the appropriate exception.
void	join(long id, TransactionParticipant part, long crashCount) Join a transaction that is managed by this transaction manager.
void	join(long id, TransactionParticipant part, long crashCount, int partitionId, String clusterName)
void	join(long id, TransactionParticipant part, long crashCount, ServerTransaction userXtnObject)
void	join(long id, TransactionParticipant part, long crashCount, ServerTransaction userXtnObject, int partitionId, String clusterName, Object clusterProxy)
void	join(Object xid, TransactionParticipant part, long crashCount)
void	join(Object xid, TransactionParticipant part, long crashCount, int partitionId, String clusterName)
void	join(Object xid, TransactionParticipant part, long crashCount, ServerTransaction userXtnObject)
void	join(Object xid, TransactionParticipant part, long crashCount, ServerTransaction userXtnObject, int partitionId, String clusterName, Object clusterProxy)
TransactionManager	manager() Returns a reference to the TransactionManager interface.
void	modifyLookupAttributes(Entry[] attrSetTemplates, Entry[] attrSets) Modify the current attribute sets, using the same semantics as ServiceRegistration.modifyAttributes.
boolean	needParticipantsJoin() returns true if this mgr which requires that the txn participants join into the txn in contrary to a mgr which the participants are known prior to txn propagation
void	noteUnsettledTxn(Object tid) Informs the transaction manager to attempt to settle a given transaction.
int	prepare(Object xid) prepare the underlying xtn designated by the rendered xid
void	recover(long cookie, LogRecord rec) This method recovers state changes resulting from committing a transaction.
void	reenterPreparedExternalXid(Object xid, List<TransactionParticipant> parts) given a prepared xid (retrieved from participants) reenlist it and its participants- used in XA
void	removeLookupGroups(String[] groups) Remove groups from the set to join.
void	removeLookupLocators(LookupLocator[] locators) Remove locators for specific lookup services from the set to join.
long	renew(Uuid uuid, long extension) Requests the renewal of a lease on a Transaction.
Landlord.RenewResults	renewAll(Uuid[] cookies, long[] extensions) Bulk renewal request of leases on Transactions.
void	setLookupGroups(String[] groups) Replace the list of groups to join with a new list.
void	setLookupLocators(LookupLocator[] locators) Replace the list of locators of specific lookup services to join with a new list.

Methods inherited from class java.lang.Object

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

Field Detail

exporter

protected Exporter exporter

The exporter for exporting and unexporting

loginContext

protected LoginContext loginContext

The login context, for logging out

Method Detail

create

public TransactionManager.Created create(long lease)
                                  throws LeaseDeniedException

Description copied from interface: TransactionManager

Begin a new top-level transaction.

Specified by:

create in interface TransactionManager

Parameters:

lease - the requested lease time for the transaction

Returns:

the transaction ID and the lease granted

Throws:

LeaseDeniedException - if this manager is unwilling to grant the requested lease time

create

public TransactionManager.Created create(Object externalXid,
                                         long lease)
                                  throws LeaseDeniedException

Specified by:

create in interface ExtendedTransactionManager

Throws:

LeaseDeniedException

join

public void join(long id,
                 TransactionParticipant part,
                 long crashCount)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Description copied from interface: TransactionManager

Join a transaction that is managed by this transaction manager. The crashCount marks the state of the storage used by the participant for transactions. If the participant attempts to join a transaction more than once, the crash counts must be the same. Each system crash or other event that destroys the state of the participant's unprepared transaction storage must cause the crash count to increase by at least one.

Specified by:

join in interface TransactionManager

Parameters:

id - the transaction ID

part - the participant joining the transaction

crashCount - the participant's current crash count

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

CannotJoinException - if the transaction is known to the manager but is no longer active.

CrashCountException - if the crash count provided for the participant differs from the crash count in a previous invocation of the same pairing of participant and transaction

RemoteException - if there is a communication error

See Also:

ServerTransaction.join(net.jini.core.transaction.server.TransactionParticipant, long)

join

public void join(Object xid,
                 TransactionParticipant part,
                 long crashCount)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

join

public void join(long id,
                 TransactionParticipant part,
                 long crashCount,
                 int partitionId,
                 String clusterName)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

join

public void join(Object xid,
                 TransactionParticipant part,
                 long crashCount,
                 int partitionId,
                 String clusterName)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

join

public void join(long id,
                 TransactionParticipant part,
                 long crashCount,
                 ServerTransaction userXtnObject)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

join

public void join(Object xid,
                 TransactionParticipant part,
                 long crashCount,
                 ServerTransaction userXtnObject)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

join

public void join(long id,
                 TransactionParticipant part,
                 long crashCount,
                 ServerTransaction userXtnObject,
                 int partitionId,
                 String clusterName,
                 Object clusterProxy)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

join

public void join(Object xid,
                 TransactionParticipant part,
                 long crashCount,
                 ServerTransaction userXtnObject,
                 int partitionId,
                 String clusterName,
                 Object clusterProxy)
          throws UnknownTransactionException,
                 CannotJoinException,
                 CrashCountException,
                 RemoteException

Specified by:

join in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotJoinException

CrashCountException

RemoteException

disJoin

public boolean disJoin(long id,
                       TransactionParticipant part)
                throws UnknownTransactionException,
                       RemoteException

Description copied from interface: ExtendedTransactionManager

Remove a participant that was joined for a first time. called when a call to a participant returned empty so we can spare calling commit or abort on it, usually used in embedded mahalo

Specified by:

disJoin in interface ExtendedTransactionManager

part - The joining TransactionParticpant

Returns:

true if participant disjoined

Throws:

UnknownTransactionException

RemoteException

See Also:

TransactionParticipant

disJoin

public boolean disJoin(Object id,
                       TransactionParticipant part)
                throws UnknownTransactionException,
                       RemoteException

Throws:

UnknownTransactionException

RemoteException

prepare

public int prepare(Object xid)
            throws CannotCommitException,
                   UnknownTransactionException,
                   RemoteException

prepare the underlying xtn designated by the rendered xid

Specified by:

prepare in interface ExtendedTransactionManager

Returns:

int

Throws:

CannotCommitException

UnknownTransactionException

RemoteException

getState

public int getState(long id)
             throws UnknownTransactionException

Description copied from interface: TransactionManager

Returns the current state of the given transaction. The returned state can be any of the TransactionConstants values.

Specified by:

getState in interface TransactionManager

Parameters:

id - the transaction ID

Returns:

an int representing the state of the transaction

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

See Also:

ServerTransaction.getState(), TransactionConstants

getState

public int getState(Object id)
             throws UnknownTransactionException

Specified by:

getState in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

commit

public void commit(long id)
            throws UnknownTransactionException,
                   CannotCommitException,
                   RemoteException

Description copied from interface: TransactionManager

Commit the transaction. Commit asks the transaction manager to execute the voting process with the participants. Returns if the transaction successfully reaches either the NOTCHANGED or the COMMITTED state, without waiting for the transaction manager to notify all participants of the decision. If the transaction must be aborted (because one or more participants are unable to prepare), CannotCommitException is thrown without waiting for the transaction manager to notify all participants of the decision.

Specified by:

commit in interface TransactionManager

Parameters:

id - the transaction ID

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

CannotCommitException - if the transaction is being or already has been aborted

RemoteException - if there is a communication error

commit

public void commit(long id,
                   long waitFor)
            throws UnknownTransactionException,
                   CannotCommitException,
                   TimeoutExpiredException,
                   RemoteException

Description copied from interface: TransactionManager

Commit the transaction, waiting for participants to be notified of the decision. Commit asks the transaction manager to execute the voting process with the participants. Returns if the transaction successfully reaches either the NOTCHANGED or the COMMITTED state, and the transaction manager has notified all participants of the decision, before the specified timeout expires. If the transaction must be aborted (because one or more participants are unable to prepare), CannotCommitException is thrown if the transaction manager is able to notify all participants of the decision before the specified timeout expires. If the transaction manager reaches a decision, but is unable to notify all participants of that decision before the specified timeout expires, then TimeoutExpiredException is thrown. If the specified timeout expires before the transaction manager reaches a decision, TimeoutExpiredException is not thrown until the manager reaches a decision.

Specified by:

commit in interface TransactionManager

Parameters:

id - the transaction ID

waitFor - timeout to wait, from the start of the call until all participants have been notified of the transaction manager's decision

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

CannotCommitException - if the transaction is being or already has been aborted

TimeoutExpiredException - if the transaction manager reaches a decision, but is unable to notify all participants of that decision before the specified timeout expires

RemoteException - if there is a communication error

commit

public void commit(Object xid)
            throws UnknownTransactionException,
                   CannotCommitException,
                   RemoteException

Specified by:

commit in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotCommitException

RemoteException

commit

public void commit(Object xid,
                   long waitFor)
            throws UnknownTransactionException,
                   CannotCommitException,
                   TimeoutExpiredException,
                   RemoteException

Specified by:

commit in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotCommitException

TimeoutExpiredException

RemoteException

abort

public void abort(long id)
           throws UnknownTransactionException,
                  CannotAbortException

Description copied from interface: TransactionManager

Abort the transaction. This can be called at any time by any object holding a reference to the transaction. Abort asks the transaction manager to abort the transaction and to notify each participant of the decision, resulting in them rolling back any state changes made as part of the transaction. Returns as soon as the transaction manager records the abort decision, without waiting for the transaction manager to notify all participants of the decision.

Specified by:

abort in interface TransactionManager

Parameters:

id - the transaction ID

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

CannotAbortException - if the transaction is known to have previously reached the COMMITTED state due to an earlier commit

abort

public void abort(long id,
                  long waitFor)
           throws UnknownTransactionException,
                  CannotAbortException,
                  TimeoutExpiredException

Description copied from interface: TransactionManager

Abort the transaction, waiting for participants to be notified of the decision. This can be called at any time by any object holding a reference to the transaction. Abort asks the transaction manager to abort the transaction and to notify each participant of the decision, resulting in them rolling back any state changes made as part of the transaction. Returns if the transaction manager records the decision and is able to notify all participants of the decision before the specified timeout expires. If the transaction manager is unable to notify all participants of the decision before the specified timeout expires, then TimeoutExpiredException is thrown.

Specified by:

abort in interface TransactionManager

Parameters:

id - the transaction ID

waitFor - timeout to wait, from the start of the call until all participants have been notified of the transaction manager's decision

Throws:

UnknownTransactionException - if the transaction is unknown to the transaction manager, either because the transaction ID is incorrect or because the transaction is complete and its state has been discarded by the manager.

CannotAbortException - if the transaction is known to have previously reached the COMMITTED state due to an earlier commit

TimeoutExpiredException - if the timeout expires before all participants have been notified

abort_impl

public void abort_impl(Object id,
                       long waitFor)
                throws UnknownTransactionException,
                       CannotAbortException,
                       TimeoutExpiredException

Throws:

UnknownTransactionException

CannotAbortException

TimeoutExpiredException

abort

public void abort(Object xid)
           throws UnknownTransactionException,
                  CannotAbortException,
                  RemoteException

Specified by:

abort in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotAbortException

RemoteException

abort

public void abort(Object xid,
                  long waitFor)
           throws UnknownTransactionException,
                  CannotAbortException,
                  TimeoutExpiredException,
                  RemoteException

Specified by:

abort in interface ExtendedTransactionManager

Throws:

UnknownTransactionException

CannotAbortException

TimeoutExpiredException

RemoteException

recover

public void recover(long cookie,
                    LogRecord rec)
             throws LogException

This method recovers state changes resulting from committing a transaction. This re-creates the internal representation of the transaction.

Specified by:

recover in interface LogRecovery

Parameters:

cookie - the transaction's ID

rec - the LogRecord

Throws:

LogException

noteUnsettledTxn

public void noteUnsettledTxn(Object tid)

Informs the transaction manager to attempt to settle a given transaction.

Specified by:

noteUnsettledTxn in interface TxnSettler

Parameters:

tid - the transaction's ID

getTransaction

public Transaction getTransaction(long id)
                           throws UnknownTransactionException

Method from TxnManager which produces a Transaction from its ID.

Specified by:

getTransaction in interface TxnManager

Parameters:

id - the ID

Throws:

UnknownTransactionException

See Also:

Transaction, TxnManager

renew

public long renew(Uuid uuid,
                  long extension)
           throws UnknownLeaseException,
                  LeaseDeniedException

Requests the renewal of a lease on a Transaction.

Specified by:

renew in interface Landlord

Specified by:

renew in interface LocalLandlord

Parameters:

uuid - identifies the leased resource

extension - requested lease extension

Returns:

The new duration the lease should have

Throws:

UnknownLeaseException - if landlord does not know about a lease with the specified cookie

LeaseDeniedException - if the landlord is unwilling to renew the lease

See Also:

Lease, LeasedResource, LeaseManager

cancel

public void cancel(Uuid uuid)
            throws UnknownLeaseException

Cancels the lease on a Transaction.

Specified by:

cancel in interface Landlord

Specified by:

cancel in interface LocalLandlord

Specified by:

cancel in interface LeaseExpirationMgr.Expirer

Parameters:

uuid - identifies the leased resource

Throws:

UnknownLeaseException - if landlord does not know about a lease with the specified cookie

See Also:

Lease, LeasedResource, LeaseManager

renewAll

public Landlord.RenewResults renewAll(Uuid[] cookies,
                                      long[] extensions)

Bulk renewal request of leases on Transactions.

Specified by:

renewAll in interface Landlord

Parameters:

cookies - identifies the leased resources

extensions - requested lease extensions

Returns:

A RenewResults object that contains the new duration of each lease that was successfully renewed or the exception encountered for each lease that could not be renewed

See Also:

Lease, LeasedResource, LeaseManager

cancelAll

public Map cancelAll(Uuid[] cookies)

Bulk cancel of leases on Transactions.

Specified by:

cancelAll in interface Landlord

Parameters:

cookies - identifies the leased resources

Returns:

If all the leases specified in the cookies could be cancelled return null. Otherwise, return a Map that for each failed cancel attempt maps the corresponding cookie object to an exception describing the failure.

See Also:

Lease, LeasedResource, LeaseManager

manager

public TransactionManager manager()

Returns a reference to the TransactionManager interface.

Specified by:

manager in interface TxnManager

See Also:

TransactionManager

reenterPreparedExternalXid

public void reenterPreparedExternalXid(Object xid,
                                       List<TransactionParticipant> parts)
                                throws CannotCommitException

Description copied from interface: TxnManager

given a prepared xid (retrieved from participants) reenlist it and its participants- used in XA

Specified by:

reenterPreparedExternalXid in interface TxnManager

Throws:

CannotCommitException

destroy

public void destroy()

Cleans up and exits the transaction manager.

Specified by:

destroy in interface DestroyAdmin

getAdmin

public Object getAdmin()

Returns the administration object for the transaction manager.

Specified by:

getAdmin in interface Administrable

Returns:

an object that implements whatever administration interfaces are appropriate for the particular service.

See Also:

JoinAdmin

getLookupAttributes

public Entry[] getLookupAttributes()

Description copied from interface: JoinAdmin

Get the current attribute sets for the service.

Specified by:

getLookupAttributes in interface JoinAdmin

Returns:

the current attribute sets for the service

addLookupAttributes

public void addLookupAttributes(Entry[] attrSets)

Description copied from interface: JoinAdmin

Add attribute sets for the service. The resulting set will be used for all future joins. The attribute sets are also added to all currently-joined lookup services.

Specified by:

addLookupAttributes in interface JoinAdmin

Parameters:

attrSets - the attribute sets to add

modifyLookupAttributes

public void modifyLookupAttributes(Entry[] attrSetTemplates,
                                   Entry[] attrSets)

Description copied from interface: JoinAdmin

Modify the current attribute sets, using the same semantics as ServiceRegistration.modifyAttributes. The resulting set will be used for all future joins. The same modifications are also made to all currently-joined lookup services.

Specified by:

modifyLookupAttributes in interface JoinAdmin

Parameters:

attrSetTemplates - the templates for matching attribute sets

attrSets - the modifications to make to matching sets

See Also:

ServiceRegistration.modifyAttributes(net.jini.core.entry.Entry[], net.jini.core.entry.Entry[])

getLookupGroups

public String[] getLookupGroups()

Description copied from interface: JoinAdmin

Get the list of groups to join. An empty array means the service joins no groups (as opposed to "all" groups).

Specified by:

getLookupGroups in interface JoinAdmin

Returns:

an array of groups to join. An empty array means the service joins no groups (as opposed to "all" groups).

See Also:

JoinAdmin.setLookupGroups(java.lang.String[])

addLookupGroups

public void addLookupGroups(String[] groups)

Description copied from interface: JoinAdmin

Add new groups to the set to join. Lookup services in the new groups will be discovered and joined.

Specified by:

addLookupGroups in interface JoinAdmin

Parameters:

groups - groups to join

See Also:

JoinAdmin.removeLookupGroups(java.lang.String[])

removeLookupGroups

public void removeLookupGroups(String[] groups)

Description copied from interface: JoinAdmin

Remove groups from the set to join. Leases are cancelled at lookup services that are not members of any of the remaining groups.

Specified by:

removeLookupGroups in interface JoinAdmin

Parameters:

groups - groups to leave

See Also:

JoinAdmin.addLookupGroups(java.lang.String[])

setLookupGroups

public void setLookupGroups(String[] groups)

Description copied from interface: JoinAdmin

Replace the list of groups to join with a new list. Leases are cancelled at lookup services that are not members of any of the new groups. Lookup services in the new groups will be discovered and joined.

Specified by:

setLookupGroups in interface JoinAdmin

Parameters:

groups - groups to join

See Also:

JoinAdmin.getLookupGroups()

getLookupLocators

public LookupLocator[] getLookupLocators()

Description copied from interface: JoinAdmin

Get the list of locators of specific lookup services to join.

Specified by:

getLookupLocators in interface JoinAdmin

Returns:

the list of locators of specific lookup services to join

See Also:

JoinAdmin.setLookupLocators(net.jini.core.discovery.LookupLocator[])

addLookupLocators

public void addLookupLocators(LookupLocator[] locators)
                       throws RemoteException

Description copied from interface: JoinAdmin

Add locators for specific new lookup services to join. The new lookup services will be discovered and joined.

Specified by:

addLookupLocators in interface JoinAdmin

Parameters:

locators - locators of specific lookup services to join

Throws:

RemoteException

See Also:

JoinAdmin.removeLookupLocators(net.jini.core.discovery.LookupLocator[])

removeLookupLocators

public void removeLookupLocators(LookupLocator[] locators)
                          throws RemoteException

Description copied from interface: JoinAdmin

Remove locators for specific lookup services from the set to join. Any leases held at the lookup services are cancelled.

Specified by:

removeLookupLocators in interface JoinAdmin

Parameters:

locators - locators of specific lookup services to leave

Throws:

RemoteException

See Also:

JoinAdmin.addLookupLocators(net.jini.core.discovery.LookupLocator[])

setLookupLocators

public void setLookupLocators(LookupLocator[] locators)
                       throws RemoteException

Description copied from interface: JoinAdmin

Replace the list of locators of specific lookup services to join with a new list. Leases are cancelled at lookup services that were in the old list but are not in the new list. Any new lookup services will be discovered and joined.

Specified by:

setLookupLocators in interface JoinAdmin

Parameters:

locators - locators of specific lookup services to join

Throws:

RemoteException

See Also:

JoinAdmin.getLookupLocators()

getProxy

public Object getProxy()

Description copied from interface: ProxyAccessor

Returns a proxy object for this remote object. If this remote object is not exported (and hence, no proxy is available), then null is returned.

Specified by:

getProxy in interface ProxyAccessor

Returns:

a proxy, or null

getLocalProxy

public TransactionManager getLocalProxy()

Specified by:

getLocalProxy in interface TxnManager

getServiceProxy

public Object getServiceProxy()

Description copied from interface: ServiceProxyAccessor

Returns a proxy object for this object. This value should not be null.

Specified by:

getServiceProxy in interface ServiceProxyAccessor

Returns:

a proxy object reference

initFailed

protected void initFailed(Throwable e)
                   throws Exception

Log information about failing to initialize the service and rethrow the appropriate exception.

Parameters:

e - the exception produced by the failure

Throws:

Exception

getProxyVerifier

public TrustVerifier getProxyVerifier()

Description copied from interface: ServerProxyTrust

Returns a TrustVerifier that can be used to verify that a proxy can be trusted as a proxy for the service; that is, the isTrustedObject method of the returned verifier can be called with a candidate proxy. The verifier should be able to verify all proxies for the service, including proxies for resources (such as leases and registrations).

Specified by:

getProxyVerifier in interface ServerProxyTrust

Returns:

a TrustVerifier that can be used to verify that a proxy can be trusted as a proxy for the service

needParticipantsJoin

public boolean needParticipantsJoin()
                             throws RemoteException

returns true if this mgr which requires that the txn participants join into the txn in contrary to a mgr which the participants are known prior to txn propagation

Specified by:

needParticipantsJoin in interface TransactionManager

Returns:

true if its a mgr which requires that the txn participants to join

Throws:

RemoteException

getTransactionManagerId

public Uuid getTransactionManagerId()
                             throws RemoteException

Specified by:

getTransactionManagerId in interface TransactionManager

Throws:

RemoteException