Package com.evolveum.midpoint.repo.sql

Class SqlRepositoryServiceImpl

java.lang.Object

com.evolveum.midpoint.repo.sql.SqlBaseService

com.evolveum.midpoint.repo.sql.SqlRepositoryServiceImpl

All Implemented Interfaces:

RepositoryService

public class SqlRepositoryServiceImpl
extends SqlBaseService
implements RepositoryService

Main implementation of the RepositoryService, based on SQL database using ORM/Hibernate. Don't autowire by this class, use RepositoryService class instead.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SqlRepositoryServiceImpl.ResultQueryBasedSupplier<RV>
static interface	SqlRepositoryServiceImpl.ResultSupplier<RV>

Field Summary

Fields

Modifier and Type	Field	Description
static int	CONTENTION_LOG_DEBUG_THRESHOLD
static String	CONTENTION_LOG_NAME
static int	MAIN_LOG_WARN_THRESHOLD
static int	MAX_CONSTRAINT_NAME_LENGTH
static String	PERFORMANCE_LOG_NAME

Fields inherited from interface com.evolveum.midpoint.repo.api.RepositoryService

ADD_DIAGNOSTIC_INFORMATION, ADD_OBJECT, ADVANCE_SEQUENCE, CLASS_NAME_WITH_DOT, COUNT_CONTAINERS, COUNT_OBJECTS, DELETE_OBJECT, EXECUTE_QUERY_DIAGNOSTICS, GET_OBJECT, GET_VERSION, HAS_CONFLICT, KEY_DIAG_DATA, KEY_ORIGINAL_OBJECT, MODIFY_OBJECT, OP_ADD_OBJECT, OP_ADVANCE_SEQUENCE, OP_COUNT_OBJECTS, OP_DELETE_OBJECT, OP_EXECUTE_QUERY_DIAGNOSTICS, OP_FETCH_EXT_ITEMS, OP_GET_OBJECT, OP_GET_VERSION, OP_IS_ANY_SUBORDINATE, OP_MODIFY_OBJECT, OP_RETURN_UNUSED_VALUES_TO_SEQUENCE, OP_SEARCH_OBJECTS, OP_SEARCH_OBJECTS_ITERATIVE, OP_SEARCH_SHADOW_OWNER, RETURN_UNUSED_VALUES_TO_SEQUENCE, SEARCH_CONTAINERS, SEARCH_OBJECTS, SEARCH_OBJECTS_ITERATIVE, SEARCH_SHADOW_OWNER

Constructor Summary

Constructors

Constructor	Description
SqlRepositoryServiceImpl()

Method Summary

Modifier and Type	Method	Description
<T extends ObjectType> void	addDiagnosticInformation(Class<T> type, String oid, DiagnosticInformationType information, OperationResult parentResult)	This is an approximate implementation, not taking care of two clients appending the diag information concurrently.
<T extends ObjectType> String	addObject(PrismObject<T> object, RepoAddOptions options, OperationResult result)	Add new object.
long	advanceSequence(String oid, OperationResult parentResult)	This operation is guaranteed to be atomic.
void	applyFullTextSearchConfiguration(FullTextSearchConfigurationType fullTextSearch)
<T extends Containerable> int	countContainers(Class<T> type, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult parentResult)
<T extends ObjectType> int	countObjects(Class<T> type, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult result)	Returns the number of objects that match specified criteria.
ConflictWatcher	createAndRegisterConflictWatcher(@NotNull String oid)
<T extends ObjectType> @NotNull DeleteObjectResult	deleteObject(Class<T> type, String oid, OperationResult result)	Deletes object with specified OID.
RepositoryQueryDiagResponse	executeQueryDiagnostics(RepositoryQueryDiagRequest request, OperationResult result)	A bit of hack - execute arbitrary query, e.g.
OrgClosureManager	getClosureManager()
FullTextSearchConfigurationType	getFullTextSearchConfiguration()
<T extends ObjectType> @NotNull PrismObject<T>	getObject(Class<T> type, String oid, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult result)	Returns object for provided OID.
RepositoryDiag	getRepositoryDiag()	Provide repository run-time configuration and diagnostic information.
<T extends ObjectType> String	getVersion(Class<T> type, String oid, OperationResult parentResult)	Returns object version for provided OID.
boolean	hasConflict(ConflictWatcher watcher, OperationResult parentResult)
void	invokeConflictWatchers(Consumer<ConflictWatcherImpl> consumer)
<O extends ObjectType> boolean	isAncestor(PrismObject<O> object, String oid)
boolean	isAnySubordinate(String upperOrgOid, Collection<String> lowerObjectOids)
static boolean	isCustomPagingOkWithPagedSeqIteration(ObjectQuery query)
<O extends ObjectType> boolean	isDescendant(PrismObject<O> object, String orgOid)
<T extends ObjectType> @NotNull ModifyObjectResult<T>	modifyObject(Class<T> type, String oid, Collection<? extends ItemDelta> modifications, ModificationPrecondition<T> precondition, RepoModifyOptions options, OperationResult result)
<T extends ObjectType> @NotNull ModifyObjectResult<T>	modifyObject(Class<T> type, String oid, Collection<? extends ItemDelta> modifications, RepoModifyOptions options, OperationResult result)
<T extends ObjectType> @NotNull ModifyObjectResult<T>	modifyObject(Class<T> type, String oid, Collection<? extends ItemDelta> modifications, OperationResult result)	Modifies object using relative change description.
void	postInit(OperationResult result)
void	repositorySelfTest(OperationResult parentResult)	Runs a short, non-destructive repository self test.
void	returnUnusedValuesToSequence(String oid, Collection<Long> unusedValues, OperationResult parentResult)	The sequence may ignore the values, e.g.
<T extends Containerable> SearchResultList<T>	searchContainers(Class<T> type, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult parentResult)	Search for "sub-object" structures, i.e.
<T extends ObjectType> @NotNull SearchResultList<PrismObject<T>>	searchObjects(Class<T> type, ObjectQuery query, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult result)	Search for objects in the repository.
<T extends ObjectType> SearchResultMetadata	searchObjectsIterative(Class<T> type, ObjectQuery query, ResultHandler<T> handler, Collection<SelectorOptions<GetOperationOptions>> options, boolean strictlySequential, OperationResult result)	Search for objects in the repository in an iterative fashion.
<F extends FocusType> PrismObject<F>	searchShadowOwner(String shadowOid, Collection<SelectorOptions<GetOperationOptions>> options, OperationResult result)	Returns the object representing owner of specified shadow.
<O extends ObjectType> boolean	selectorMatches(ObjectSelectorType objectSelector, PrismObject<O> object, ObjectFilterExpressionEvaluator filterEvaluator, Trace logger, String logMessagePrefix)
SqlRepositoryConfiguration	sqlConfiguration()
void	testOrgClosureConsistency(boolean repairIfNecessary, OperationResult testResult)	Checks a closure for consistency, repairing any problems found.
void	unregisterConflictWatcher(ConflictWatcher watcher)

Methods inherited from class com.evolveum.midpoint.repo.sql.SqlBaseService

destroy, getPerformanceMonitor

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.evolveum.midpoint.repo.api.RepositoryService

getPerformanceMonitor

Field Detail

PERFORMANCE_LOG_NAME

public static final String PERFORMANCE_LOG_NAME

CONTENTION_LOG_NAME

public static final String CONTENTION_LOG_NAME

CONTENTION_LOG_DEBUG_THRESHOLD

public static final int CONTENTION_LOG_DEBUG_THRESHOLD

See Also:

Constant Field Values

MAIN_LOG_WARN_THRESHOLD

public static final int MAIN_LOG_WARN_THRESHOLD

See Also:

Constant Field Values

MAX_CONSTRAINT_NAME_LENGTH

public static final int MAX_CONSTRAINT_NAME_LENGTH

See Also:

Constant Field Values

Constructor Detail

SqlRepositoryServiceImpl

public SqlRepositoryServiceImpl()

Method Detail

sqlConfiguration

public SqlRepositoryConfiguration sqlConfiguration()

Specified by:

sqlConfiguration in class SqlBaseService

getClosureManager

public OrgClosureManager getClosureManager()

getObject

@NotNull
public <T extends ObjectType> @NotNull PrismObject<T> getObject(Class<T> type,
                                                                String oid,
                                                                Collection<SelectorOptions<GetOperationOptions>> options,
                                                                OperationResult result)
                                                         throws ObjectNotFoundException,
                                                                SchemaException

Description copied from interface: RepositoryService

Returns object for provided OID.

Must fail if object with the OID does not exists.

Specified by:

getObject in interface RepositoryService

oid - OID of the object to get

result - parent OperationResult (in/out)

Returns:

Object fetched from repository

Throws:

ObjectNotFoundException - requested object does not exist

SchemaException - error dealing with storage schema

searchShadowOwner

public <F extends FocusType> PrismObject<F> searchShadowOwner(String shadowOid,
                                                              Collection<SelectorOptions<GetOperationOptions>> options,
                                                              OperationResult result)

Description copied from interface: RepositoryService

Returns the object representing owner of specified shadow.

Implements the backward "owns" association between account shadow and user. Forward association is implemented by linkRef reference in subclasses of FocusType.

Returns null if there is no owner for the shadow.

This is a "search" operation even though it may return at most one owner. However the operation implies searching the repository for an owner, which may be less efficient that following a direct association. Hence it is called "search" to indicate that there may be non-negligible overhead.

This method should not die even if the specified shadow does not exist. Even if the shadow is gone, it still may be used in some linkRefs. This method should be able to find objects with such linkeRefs otherwise we will not be able to do proper cleanup.

Specified by:

searchShadowOwner in interface RepositoryService

Parameters:

shadowOid - OID of shadow

result - parentResult parent OperationResult (in/out)

Returns:

Object representing owner of specified account (subclass of FocusType)

searchObjects

@NotNull
public <T extends ObjectType> @NotNull SearchResultList<PrismObject<T>> searchObjects(Class<T> type,
                                                                                      ObjectQuery query,
                                                                                      Collection<SelectorOptions<GetOperationOptions>> options,
                                                                                      OperationResult result)
                                                                               throws SchemaException

Description copied from interface: RepositoryService

Search for objects in the repository.

If no search criteria specified, list of all objects of specified type is returned.

Searches through all object types. Returns a list of objects that match search criteria.

Returns empty list if object type is correct but there are no objects of that type. The ordering of the results is not significant and may be arbitrary unless sorting in the paging is used.

Should fail if object type is wrong. Should fail if unknown property is specified in the query.

Specified by:

searchObjects in interface RepositoryService

query - search query

result - parent OperationResult (in/out)

Returns:

all objects of specified type that match search criteria (subject to paging)

Throws:

SchemaException - unknown property used in search query

searchContainers

public <T extends Containerable> SearchResultList<T> searchContainers(Class<T> type,
                                                                      ObjectQuery query,
                                                                      Collection<SelectorOptions<GetOperationOptions>> options,
                                                                      OperationResult parentResult)
                                                               throws SchemaException

Description copied from interface: RepositoryService

Search for "sub-object" structures, i.e. containers. Currently, only one type of search is available: certification case search.

Specified by:

searchContainers in interface RepositoryService

Throws:

SchemaException

countContainers

public <T extends Containerable> int countContainers(Class<T> type,
                                                     ObjectQuery query,
                                                     Collection<SelectorOptions<GetOperationOptions>> options,
                                                     OperationResult parentResult)

Specified by:

countContainers in interface RepositoryService

addObject

public <T extends ObjectType> String addObject(PrismObject<T> object,
                                               RepoAddOptions options,
                                               OperationResult result)
                                        throws ObjectAlreadyExistsException,
                                               SchemaException

Description copied from interface: RepositoryService

Add new object.

The OID provided in the input message may be empty. In that case the OID will be assigned by the implementation of this method and it will be provided as return value.

This operation should fail if such object already exists (if object with the provided OID already exists).

The operation may fail if provided OID is in an unusable format for the storage. Generating own OIDs and providing them to this method is not recommended for normal operation.

Should be atomic. Should not allow creation of two objects with the same OID (even if created in parallel).

The operation may fail if the object to be created does not conform to the underlying schema of the storage system or the schema enforced by the implementation.

Note: no need for explicit type parameter here. The object parameter contains the information.

Specified by:

addObject in interface RepositoryService

Parameters:

object - object to create

result - parent OperationResult (in/out)

Returns:

OID assigned to the created object

Throws:

ObjectAlreadyExistsException - object with specified identifiers already exists, cannot add

SchemaException - error dealing with storage schema, e.g. schema violation

invokeConflictWatchers

public void invokeConflictWatchers(Consumer<ConflictWatcherImpl> consumer)

deleteObject

@NotNull
public <T extends ObjectType> @NotNull DeleteObjectResult deleteObject(Class<T> type,
                                                                       String oid,
                                                                       OperationResult result)
                                                                throws ObjectNotFoundException

Description copied from interface: RepositoryService

Deletes object with specified OID.

Must fail if object with specified OID does not exists. Should be atomic.

Specified by:

deleteObject in interface RepositoryService

oid - OID of object to delete

result - parent OperationResult (in/out)

Throws:

ObjectNotFoundException - specified object does not exist

countObjects

public <T extends ObjectType> int countObjects(Class<T> type,
                                               ObjectQuery query,
                                               Collection<SelectorOptions<GetOperationOptions>> options,
                                               OperationResult result)

Description copied from interface: RepositoryService

Returns the number of objects that match specified criteria.

If no search criteria specified, count of all objects of specified type is returned.

Should fail if object type is wrong. Should fail if unknown property is specified in the query.

Specified by:

countObjects in interface RepositoryService

query - search query

result - parent OperationResult (in/out)

Returns:

count of objects of specified type that match search criteria (subject to paging)

modifyObject

@NotNull
public <T extends ObjectType> @NotNull ModifyObjectResult<T> modifyObject(Class<T> type,
                                                                          String oid,
                                                                          Collection<? extends ItemDelta> modifications,
                                                                          OperationResult result)
                                                                   throws ObjectNotFoundException,
                                                                          SchemaException,
                                                                          ObjectAlreadyExistsException

Description copied from interface: RepositoryService

Modifies object using relative change description.

Must fail if user with provided OID does not exists. Must fail if any of the described changes cannot be applied. Should be atomic.

If two or more modify operations are executed in parallel, the operations should be merged. In case that the operations are in conflict (e.g. one operation adding a value and the other removing the same value), the result is not deterministic.

The operation may fail if the modified object does not conform to the underlying schema of the storage system or the schema enforced by the implementation.

TODO: optimistic locking

Note: the precondition is checked only if actual modification is going to take place (not e.g. if the list of modifications is empty).

Specified by:

modifyObject in interface RepositoryService

result - parent OperationResult (in/out)

Throws:

ObjectNotFoundException - specified object does not exist

SchemaException - resulting object would violate the schema

ObjectAlreadyExistsException - if resulting object would have name which already exists in another object of the same type

modifyObject

@NotNull
public <T extends ObjectType> @NotNull ModifyObjectResult<T> modifyObject(Class<T> type,
                                                                          String oid,
                                                                          Collection<? extends ItemDelta> modifications,
                                                                          RepoModifyOptions options,
                                                                          OperationResult result)
                                                                   throws ObjectNotFoundException,
                                                                          SchemaException,
                                                                          ObjectAlreadyExistsException

Specified by:

modifyObject in interface RepositoryService

Throws:

ObjectNotFoundException

SchemaException

ObjectAlreadyExistsException

modifyObject

@NotNull
public <T extends ObjectType> @NotNull ModifyObjectResult<T> modifyObject(Class<T> type,
                                                                          String oid,
                                                                          Collection<? extends ItemDelta> modifications,
                                                                          ModificationPrecondition<T> precondition,
                                                                          RepoModifyOptions options,
                                                                          OperationResult result)
                                                                   throws ObjectNotFoundException,
                                                                          SchemaException,
                                                                          ObjectAlreadyExistsException,
                                                                          PreconditionViolationException

Specified by:

modifyObject in interface RepositoryService

Throws:

ObjectNotFoundException

SchemaException

ObjectAlreadyExistsException

PreconditionViolationException

getRepositoryDiag

public RepositoryDiag getRepositoryDiag()

Description copied from interface: RepositoryService

Provide repository run-time configuration and diagnostic information.

Specified by:

getRepositoryDiag in interface RepositoryService

repositorySelfTest

public void repositorySelfTest(OperationResult parentResult)

Description copied from interface: RepositoryService

Runs a short, non-destructive repository self test. This methods should never throw a (checked) exception. All the results should be recorded under the provided result structure (including fatal errors).

This should implement ONLY self-tests that are IMPLEMENTATION-SPECIFIC. It must not implement self-tests that are generic and applies to all repository implementations. Such self-tests must be implemented in higher layers.

If the repository has no self-tests then the method should return immediately without changing the result structure. It must not throw an exception in this case.

Specified by:

repositorySelfTest in interface RepositoryService

testOrgClosureConsistency

public void testOrgClosureConsistency(boolean repairIfNecessary,
                                      OperationResult testResult)

Description copied from interface: RepositoryService

Checks a closure for consistency, repairing any problems found. This methods should never throw a (checked) exception. All the results should be in the returned result structure (including fatal errors).

The current implementation expects closure to be of reasonable size - so it could be fetched into main memory as well as recomputed online (perhaps up to ~250K entries). In future, this method will be reimplemented.

BEWARE, this method locks out the M_ORG_CLOSURE table, so org-related operations would wait until it completes.

TODO this method is SQL service specific; it should be generalized/fixed somehow.

Specified by:

testOrgClosureConsistency in interface RepositoryService

getVersion

public <T extends ObjectType> String getVersion(Class<T> type,
                                                String oid,
                                                OperationResult parentResult)
                                         throws ObjectNotFoundException

Description copied from interface: RepositoryService

Returns object version for provided OID.

Must fail if object with the OID does not exists.

This is a supposed to be a very lightweight and cheap operation. It is used to support efficient caching of expensive objects.

Specified by:

getVersion in interface RepositoryService

oid - OID of the object to get

parentResult - parent OperationResult (in/out)

Returns:

Object version

Throws:

ObjectNotFoundException - requested object does not exist

searchObjectsIterative

public <T extends ObjectType> SearchResultMetadata searchObjectsIterative(Class<T> type,
                                                                          ObjectQuery query,
                                                                          ResultHandler<T> handler,
                                                                          Collection<SelectorOptions<GetOperationOptions>> options,
                                                                          boolean strictlySequential,
                                                                          OperationResult result)
                                                                   throws SchemaException

Description copied from interface: RepositoryService

Search for objects in the repository in an iterative fashion.

Searches through all object types. Calls a specified handler for each object found. If no search criteria specified, list of all objects of specified type is returned.

Searches through all object types. Returns a list of objects that match search criteria.

Returns empty list if object type is correct but there are no objects of that type. The ordering of the results is not significant and may be arbitrary unless sorting in the paging is used.

Should fail if object type is wrong. Should fail if unknown property is specified in the query.

Specified by:

searchObjectsIterative in interface RepositoryService

query - search query

handler - result handler

strictlySequential - takes care not to skip any object nor to process objects more than once; see below

result - parent OperationResult (in/out)

Returns:

all objects of specified type that match search criteria (subject to paging)

Throws:

SchemaException - unknown property used in search query

A note related to iteration method:

There are three iteration methods (see IterationMethodType): - SINGLE_TRANSACTION: Fetches objects in single DB transaction. Not supported for all DBMSs. - SIMPLE_PAGING: Uses the "simple paging" method: takes objects (e.g.) numbered 0 to 49, then 50 to 99, then 100 to 149, and so on. The disadvantage is that if the order of objects is changed during operation (e.g. by inserting/deleting some of them) then some objects can be processed multiple times, where others can be skipped. - STRICTLY_SEQUENTIAL_PAGING: Uses the "strictly sequential paging" method: sorting returned objects by OID. This is (almost) reliable in such a way that no object would be skipped. However, custom paging cannot be used in this mode.

If GetOperationOptions.iterationMethod is specified, it is used without any further considerations. Otherwise, the repository configuration determines whether to use SINGLE_TRANSACTION or a paging. In the latter case, strictlySequential flag determines between SIMPLE_PAGING (if false) and STRICTLY_SEQUENTIAL_PAGING (if true).

If explicit GetOperationOptions.iterationMethod is not provided, and paging is prescribed, and strictlySequential flag is true and client-provided paging conflicts with the paging used by the iteration method, a warning is issued, and iteration method is switched to SIMPLE_PAGING.

Sources of conflicts: - ordering is specified - offset is specified (limit is not a problem)

isCustomPagingOkWithPagedSeqIteration

public static boolean isCustomPagingOkWithPagedSeqIteration(ObjectQuery query)

isAnySubordinate

public boolean isAnySubordinate(String upperOrgOid,
                                Collection<String> lowerObjectOids)

Specified by:

isAnySubordinate in interface RepositoryService

advanceSequence

public long advanceSequence(String oid,
                            OperationResult parentResult)
                     throws ObjectNotFoundException,
                            SchemaException

Description copied from interface: RepositoryService

This operation is guaranteed to be atomic. If two threads or even two nodes request a value from the same sequence at the same time then different values will be returned.

Specified by:

advanceSequence in interface RepositoryService

Parameters:

oid - sequence OID

parentResult - Operation result

Returns:

next unallocated counter value

Throws:

ObjectNotFoundException - the sequence does not exist

SchemaException - the sequence cannot produce a value (e.g. maximum counter reached)

returnUnusedValuesToSequence

public void returnUnusedValuesToSequence(String oid,
                                         Collection<Long> unusedValues,
                                         OperationResult parentResult)
                                  throws ObjectNotFoundException,
                                         SchemaException

Description copied from interface: RepositoryService

The sequence may ignore the values, e.g. if value re-use is disabled or when the list of unused values is full. In such a case the values will be ignored silently and no error is indicated.

Specified by:

returnUnusedValuesToSequence in interface RepositoryService

Parameters:

oid - sequence OID

unusedValues - values to return

parentResult - Operation result

Throws:

ObjectNotFoundException

SchemaException

executeQueryDiagnostics

public RepositoryQueryDiagResponse executeQueryDiagnostics(RepositoryQueryDiagRequest request,
                                                           OperationResult result)

Description copied from interface: RepositoryService

A bit of hack - execute arbitrary query, e.g. hibernate query in case of SQL repository. Use with all the care!

Specified by:

executeQueryDiagnostics in interface RepositoryService

Parameters:

request - Diagnostics request

result - Operation result

Returns:

diagnostics response

selectorMatches

public <O extends ObjectType> boolean selectorMatches(ObjectSelectorType objectSelector,
                                                      PrismObject<O> object,
                                                      ObjectFilterExpressionEvaluator filterEvaluator,
                                                      Trace logger,
                                                      String logMessagePrefix)
                                               throws SchemaException,
                                                      ObjectNotFoundException,
                                                      ExpressionEvaluationException,
                                                      CommunicationException,
                                                      ConfigurationException,
                                                      SecurityViolationException

Specified by:

selectorMatches in interface RepositoryService

Throws:

SchemaException

ObjectNotFoundException

ExpressionEvaluationException

CommunicationException

ConfigurationException

SecurityViolationException

isDescendant

public <O extends ObjectType> boolean isDescendant(PrismObject<O> object,
                                                   String orgOid)

Specified by:

isDescendant in interface RepositoryService

isAncestor

public <O extends ObjectType> boolean isAncestor(PrismObject<O> object,
                                                 String oid)

Specified by:

isAncestor in interface RepositoryService

applyFullTextSearchConfiguration

public void applyFullTextSearchConfiguration(FullTextSearchConfigurationType fullTextSearch)

Specified by:

applyFullTextSearchConfiguration in interface RepositoryService

getFullTextSearchConfiguration

public FullTextSearchConfigurationType getFullTextSearchConfiguration()

Specified by:

getFullTextSearchConfiguration in interface RepositoryService

postInit

public void postInit(OperationResult result)
              throws SchemaException

Specified by:

postInit in interface RepositoryService

Throws:

SchemaException

createAndRegisterConflictWatcher

public ConflictWatcher createAndRegisterConflictWatcher(@NotNull
                                                        @NotNull String oid)

Specified by:

createAndRegisterConflictWatcher in interface RepositoryService

unregisterConflictWatcher

public void unregisterConflictWatcher(ConflictWatcher watcher)

Specified by:

unregisterConflictWatcher in interface RepositoryService

hasConflict

public boolean hasConflict(ConflictWatcher watcher,
                           OperationResult parentResult)

Specified by:

hasConflict in interface RepositoryService

addDiagnosticInformation

public <T extends ObjectType> void addDiagnosticInformation(Class<T> type,
                                                            String oid,
                                                            DiagnosticInformationType information,
                                                            OperationResult parentResult)
                                                     throws ObjectNotFoundException,
                                                            SchemaException,
                                                            ObjectAlreadyExistsException

This is an approximate implementation, not taking care of two clients appending the diag information concurrently. So there could be situations when obsolete information is not removed because of this.

Specified by:

addDiagnosticInformation in interface RepositoryService

Throws:

ObjectNotFoundException

SchemaException

ObjectAlreadyExistsException