org.apache.jackrabbit.core
Class XASessionImpl

java.lang.Object
  org.apache.jackrabbit.commons.AbstractSession
      org.apache.jackrabbit.core.SessionImpl
          org.apache.jackrabbit.core.XASessionImpl

All Implemented Interfaces:

javax.jcr.Session, javax.transaction.xa.XAResource, JackrabbitSession, XASession, Dumpable, NamePathResolver, NameResolver, PathResolver, NamespaceResolver

public class XASessionImpl
extends SessionImpl
implements XASession, javax.transaction.xa.XAResource

Session extension that provides XA support.

Field Summary

Fields inherited from class org.apache.jackrabbit.core.SessionImpl

accessMgr, ADD_NODE_ACTION, alive, attributes, hierMgr, itemMgr, itemStateMgr, listeners, lockTokens, loginContext, namePathResolver, ntMgr, READ_ACTION, REMOVE_ACTION, rep, SET_PROPERTY_ACTION, subject, userId, valueFactory, versionMgr, wsp

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Constructor Summary

protected	XASessionImpl(RepositoryImpl rep, AuthContext loginContext, WorkspaceConfig wspConfig) Create a new instance of this class.
protected	XASessionImpl(RepositoryImpl rep, javax.security.auth.Subject subject, WorkspaceConfig wspConfig) Create a new instance of this class.

Method Summary

void	associate(TransactionContext tx) Associate this session with a global transaction.
void	commit(javax.transaction.xa.Xid xid, boolean onePhase)
protected VersionManager	createVersionManager(RepositoryImpl rep) Create the version manager.
protected WorkspaceImpl	createWorkspaceInstance(WorkspaceConfig wspConfig, SharedItemStateManager stateMgr, RepositoryImpl rep, SessionImpl session) Creates the workspace instance backing this session.
void	end(javax.transaction.xa.Xid xid, int flags) If TMSUCCESS is specified, we disassociate this session from the transaction specified.
void	forget(javax.transaction.xa.Xid xid) No recovery support yet.
LockManager	getLockManager() Return the lock manager for this session.
int	getTransactionTimeout()
javax.transaction.xa.XAResource	getXAResource() Retrieves an XAResource object that the transaction manager will use to manage this XASession object's participation in a distributed transaction.
boolean	isSameRM(javax.transaction.xa.XAResource xares) Two resources belong to the same resource manager if both connections (i.e.
void	logout() Clears the local namespace mappings.
int	prepare(javax.transaction.xa.Xid xid)
javax.transaction.xa.Xid[]	recover(int flags) No recovery support yet.
void	rollback(javax.transaction.xa.Xid xid)
boolean	setTransactionTimeout(int seconds)
void	start(javax.transaction.xa.Xid xid, int flags) If TMNOFLAGS is specified, we create a new transaction context and associate it with this resource.

Methods inherited from class org.apache.jackrabbit.core.SessionImpl

addListener, addLockToken, addLockToken, checkPermission, createAccessManager, createDataStoreGarbageCollector, createItemManager, createSession, createSessionItemStateManager, createWorkspace, createWorkspace, dump, finalize, getAccessControlManager, getAccessManager, getAttribute, getAttributeNames, getHierarchyManager, getImportContentHandler, getItem, getItemManager, getItemStateManager, getJCRName, getJCRPath, getLocks, getLockTokens, getNode, getNodeById, getNodeByIdentifier, getNodeByUUID, getNodeByUUID, getNodeTypeManager, getPrefix, getPrincipalManager, getProperty, getQName, getQPath, getRepository, getRetentionManager, getRootNode, getSubject, getURI, getUserID, getUserManager, getValueFactory, getVersionManager, getWorkspace, getWorkspaceNames, hasPendingChanges, hasPermission, impersonate, isLive, itemExists, move, nodeExists, notifyLoggedOut, notifyLoggingOut, propertyExists, refresh, removeListener, removeLockToken, removeLockToken, retrieveUserId, sanityCheck, save, setNamespacePrefix

Methods inherited from class org.apache.jackrabbit.commons.AbstractSession

exportDocumentView, exportDocumentView, exportSystemView, exportSystemView, getNamespacePrefix, getNamespacePrefixes, getNamespaceURI, importXML

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.jcr.Session

addLockToken, checkPermission, exportDocumentView, exportDocumentView, exportSystemView, exportSystemView, getAttribute, getAttributeNames, getImportContentHandler, getItem, getLockTokens, getNamespacePrefix, getNamespacePrefixes, getNamespaceURI, getNodeByUUID, getRepository, getRootNode, getUserID, getValueFactory, getWorkspace, hasPendingChanges, impersonate, importXML, isLive, itemExists, move, refresh, removeLockToken, save, setNamespacePrefix

Constructor Detail

XASessionImpl

protected XASessionImpl(RepositoryImpl rep,
                        AuthContext loginContext,
                        WorkspaceConfig wspConfig)
                 throws javax.jcr.AccessDeniedException,
                        javax.jcr.RepositoryException

Create a new instance of this class.

Parameters:

rep - repository

loginContext - login context containing authenticated subject

wspConfig - workspace configuration

Throws:

javax.jcr.AccessDeniedException - if the subject of the given login context is not granted access to the specified workspace

javax.jcr.RepositoryException - if another error occurs

XASessionImpl

protected XASessionImpl(RepositoryImpl rep,
                        javax.security.auth.Subject subject,
                        WorkspaceConfig wspConfig)
                 throws javax.jcr.AccessDeniedException,
                        javax.jcr.RepositoryException

Create a new instance of this class.

Parameters:

rep - repository

subject - authenticated subject

wspConfig - workspace configuration

Throws:

javax.jcr.AccessDeniedException - if the given subject is not granted access to the specified workspace

javax.jcr.RepositoryException - if another error occurs

Method Detail

createWorkspaceInstance

protected WorkspaceImpl createWorkspaceInstance(WorkspaceConfig wspConfig,
                                                SharedItemStateManager stateMgr,
                                                RepositoryImpl rep,
                                                SessionImpl session)

Creates the workspace instance backing this session.

Overrides:

createWorkspaceInstance in class SessionImpl

Parameters:

wspConfig - The workspace configuration

stateMgr - The shared item state manager

rep - The repository

session - The session

Returns:

An instance of the WorkspaceImpl class or an extension thereof.

createVersionManager

protected VersionManager createVersionManager(RepositoryImpl rep)
                                       throws javax.jcr.RepositoryException

Create the version manager. If we are not using XA, we may safely use the repository version manager.

Overrides:

createVersionManager in class SessionImpl

Returns:

version manager

Throws:

javax.jcr.RepositoryException

getLockManager

public LockManager getLockManager()
                           throws javax.jcr.RepositoryException

Return the lock manager for this session.

Overrides:

getLockManager in class SessionImpl

Returns:

lock manager for this session

Throws:

javax.jcr.RepositoryException

getXAResource

public javax.transaction.xa.XAResource getXAResource()

Retrieves an XAResource object that the transaction manager will use to manage this XASession object's participation in a distributed transaction.

Specified by:

getXAResource in interface XASession

Returns:

the XAResource object.

getTransactionTimeout

public int getTransactionTimeout()

Specified by:

getTransactionTimeout in interface javax.transaction.xa.XAResource

setTransactionTimeout

public boolean setTransactionTimeout(int seconds)

Specified by:

setTransactionTimeout in interface javax.transaction.xa.XAResource

isSameRM

public boolean isSameRM(javax.transaction.xa.XAResource xares)
                 throws javax.transaction.xa.XAException

Two resources belong to the same resource manager if both connections (i.e. sessions) have the same credentials.

Specified by:

isSameRM in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

start

public void start(javax.transaction.xa.Xid xid,
                  int flags)
           throws javax.transaction.xa.XAException

If TMNOFLAGS is specified, we create a new transaction context and associate it with this resource. If TMJOIN is specified, this resource should use the same transaction context as another, already known transaction. If TMRESUME is specified, we should resume work on a transaction context that was suspended earlier. All other flags generate an XAException of type XAER_INVAL

Specified by:

start in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

end

public void end(javax.transaction.xa.Xid xid,
                int flags)
         throws javax.transaction.xa.XAException

If TMSUCCESS is specified, we disassociate this session from the transaction specified. If TMFAIL is specified, we disassociate this session from the transaction specified and mark the transaction rollback only. If TMSUSPEND is specified, we disassociate this session from the transaction specified. All other flags generate an XAException of type XAER_INVAL

It is legal for a transaction association to be suspended and then ended (either with TMSUCCESS or TMFAIL) without having been resumed again.

Specified by:

end in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

prepare

public int prepare(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

Specified by:

prepare in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

commit

public void commit(javax.transaction.xa.Xid xid,
                   boolean onePhase)
            throws javax.transaction.xa.XAException

Specified by:

commit in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

rollback

public void rollback(javax.transaction.xa.Xid xid)
              throws javax.transaction.xa.XAException

Specified by:

rollback in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

recover

public javax.transaction.xa.Xid[] recover(int flags)
                                   throws javax.transaction.xa.XAException

No recovery support yet.

Specified by:

recover in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

forget

public void forget(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

No recovery support yet.

Specified by:

forget in interface javax.transaction.xa.XAResource

Throws:

javax.transaction.xa.XAException

associate

public void associate(TransactionContext tx)

Associate this session with a global transaction. Internally, set the transaction containing all transaction-local objects to be used when performing item retrieval and store.

logout

public void logout()

Clears the local namespace mappings. Subclasses that for example want to participate in a session pools should remember to call super.logout() when overriding this method to avoid namespace mappings to be carried over to a new session.

Specified by:

logout in interface javax.jcr.Session

Overrides:

logout in class SessionImpl