nav[aria-label="Primary Navigation"] { padding: 0; & ul { list-style: none; width: 100%; display: flex; flex-direction: row; justify-content: start; align-items: start; gap: 30px; padding: 0; & li { margin: 0; } & ul li { list-style: none; } } }

Apply Retention in TBO

prasan_13

I am trying to apply retention in a TBO , but am getting a class cast exception.

java.lang.ClassCastException: com.are.tbo.SystemDocumentTBO___PROXY cannot be cast to com.documentum.records.policyengine.IPolicyCoordinator

at com.documentum.records.policyengine.PolicyService.applyPolicy(PolicyService.java:152)

at com.documentum.records.policyengine.PolicyService$PrivilegedApplyPolicy.run(PolicyService.java:128)

at com.documentum.fc.client.security.DfPrivilegedExceptionActionInRole.run(DfPrivilegedExceptionActionInRole.java:106)

at java.security.AccessController.doPrivileged(Native Method)

at com.documentum.records.policyengine.PolicyService.doPrivilegedApplyPolicy(PolicyService.java:100)

at com.documentum.records.policyengine.PolicyService.apply(PolicyService.java:79)

at com.documentum.records.policyengine.PolicyService.apply(PolicyService.java:1571)

at com.are.tbo.SystemDocumentTBO.doSave(SystemDocumentTBO.java:47)

Below is my code snippet.

IDfClientX client=new DfClientX();

IDfId fId=client.getId("0800136180006d09");

IPolicyService ips=(IPolicyService)DfClient.getLocalClient(). newModule(this.getSession().getDocbaseName(),(IPolicyService.class).

getName(),this.getSession().getSessionManager());

PolicyParamBean param=new PolicyParamBean();

param.setPolicyId(fId);

ips.apply(this,param);

super.doSave(isInSaveLock, strInVersionLabel, inExtendedArgs);

Any ideas on the issue?

Find more posts tagged with

Note:

If there are Accepted Answers, those will be shown by default. You can switch to 'All Replies' by selecting the tab below.

Button

Accepted answers

PanfilovAB

It seems RPS somewhere either reverts object or performs double save, so loop protection through extended data is not applicable here and another approach is required. I have implemented the same logic using ThreadLocal and all works smoothly:


import java.util.HashSet;
import java.util.Set;

import com.documentum.fc.client.DfClient;
import com.documentum.fc.client.DfSysObject;
import com.documentum.fc.client.IDfModule;
import com.documentum.fc.client.IDfSession;
import com.documentum.fc.client.IDfSessionManager;
import com.documentum.fc.client.IDfSysObject;
import com.documentum.fc.client.impl.IPersistentObject;
import com.documentum.fc.client.impl.util.TransactionalFunctorWithRetry;
import com.documentum.fc.common.DfException;
import com.documentum.fc.common.IDfId;
import com.documentum.fc.impl.util.Functor;
import com.documentum.records.policy.IPolicyService;
import com.documentum.records.policy.PolicyParamBean;

public class TestTBO extends DfSysObject {

    private static ThreadLocal<Set<IDfId>> PENDING = new ThreadLocal<Set<IDfId>>() {
        @Override
        protected Set<IDfId> initialValue() {
            return new HashSet<IDfId>();
        }
    };

    public TestTBO() {
        super();
    }

    private void setDoNotAttachPolicy(boolean value) throws DfException {
        if (value) {
            PENDING.get().add(getObjectId());
        } else {
            PENDING.get().remove(getObjectId());
        }
    }

    private boolean isDoNotAttachPolicy(IDfId policyId, boolean isNew)
        throws DfException {
        boolean pending = PENDING.get().contains(getObjectId());
        if (pending) {
            return true;
        }
        if (isNew) {
            return false;
        }
        // some business logic here
        return false;
    }

    private IDfSysObject getUncachedObject() throws DfException {
        return (IDfSysObject) getObjectSession().getUncachedObject(
                getObjectId(), null);
    }

    protected IDfId getRetentionPolicyId() throws DfException {
        return getObjectSession().getIdByQualification(
                "dmc_rps_retention_policy where object_name='test'");
    }

    private boolean attachPolicy(IDfId policyId, boolean isNew)
        throws DfException {
        if (isDoNotAttachPolicy(policyId, isNew)) {
            return false;
        }

        try {
            setDoNotAttachPolicy(true);
            IDfSysObject newInstance = getUncachedObject();
            ((IPersistentObject) newInstance).setCached(true);
            IPolicyService ips = getModule(IPolicyService.class,
                    getObjectSession());
            PolicyParamBean param = new PolicyParamBean();
            param.setPolicyId(policyId);
            ips.apply(newInstance, param);
            newInstance.save();
            return true;
        } finally {
            setDoNotAttachPolicy(false);
        }
    }

    protected void doSaveSuper(final boolean keepLock,
            final String versionLabels, final Object[] extendedArgs)
        throws DfException {
        super.doSave(keepLock, versionLabels, extendedArgs);
    }

    @Override
    protected synchronized void doSave(final boolean keepLock,
            final String versionLabels, final Object[] extendedArgs)
        throws DfException {
        final boolean isNew = isNew();
        new TransactionalFunctorWithRetry(getObjectSession(), new Functor() {
            @Override
            public Object evaluate() throws DfException {
                doSaveSuper(keepLock, versionLabels, extendedArgs);
                if (attachPolicy(getRetentionPolicyId(), isNew)) {
                    updateStateAfterSave();
                }
                return null;
            }
        }, true).evaluate();
    }

    @SuppressWarnings("unchecked")
    static <T> T getModule(Class<T> cls, IDfSession session) throws DfException {
        return (T) getModule(cls.getName(), session.getSessionManager(),
                session.getDocbaseName());
    }

    static IDfModule getModule(String name, IDfSessionManager sMgr,
            String docbase) throws DfException {
        return new DfClient().newModule(docbase, name, sMgr);
    }
}


API>create,c,test_rps
...
0901d9208058676d
API>save,c,l
...
OK
API>dump,c,l
...
USER ATTRIBUTES

  object_name                     :
  title                           :
  subject                         :
  authors                       []: <none>
  keywords                      []: <none>
  resolution_label                :
  owner_name                      : dmadmin
  owner_permit                    : 7
  group_name                      : docu
  group_permit                    : 5
  world_permit                    : 4
  log_entry                       :
  acl_domain                      : dmadmin
  acl_name                        : dm_4501d92080000101
  language_code                   :

SYSTEM ATTRIBUTES

  r_object_type                   : test_rps
  r_creation_date                 : 22.03.2014 9:48:01
  r_modify_date                   : 22.03.2014 9:48:07
  r_modifier                      : dmadmin
  r_access_date                   : nulldate
  r_composite_id                []: <none>
  r_composite_label             []: <none>
  r_component_label             []: <none>
  r_order_no                    []: <none>
  r_link_cnt                      : 0
  r_link_high_cnt                 : 0
  r_assembled_from_id             : 0000000000000000
  r_frzn_assembly_cnt             : 0
  r_has_frzn_assembly             : F
  r_is_virtual_doc                : 0
  r_page_cnt                      : 0
  r_content_size                  : 0
  r_lock_owner                    :
  r_lock_date                     : nulldate
  r_lock_machine                  :
  r_version_label              [0]: 1.0
                               [1]: CURRENT
  r_immutable_flag                : F
  r_frozen_flag                   : F
  r_has_events                    : F
  r_creator_name                  : dmadmin
  r_is_public                     : T
  r_policy_id                     : 0000000000000000
  r_resume_state                  : 0
  r_current_state                 : 0
  r_alias_set_id                  : 0000000000000000
  r_full_content_size             : 0
  r_aspect_name                [0]: dmc_policy_coordinator
  r_object_id                     : 0901d9208058676d

APPLICATION ATTRIBUTES

  a_application_type              :
  a_status                        :
  a_is_hidden                     : F
  a_retention_date                : nulldate
  a_archive                       : F
  a_compound_architecture         :
  a_link_resolved                 : F
  a_content_type                  :
  a_full_text                     : T
  a_storage_type                  :
  a_special_app                   :
  a_effective_date              []: <none>
  a_expiration_date             []: <none>
  a_publish_formats             []: <none>
  a_effective_label             []: <none>
  a_effective_flag              []: <none>
  a_category                      :
  a_is_template                   : F
  a_controlling_app               :
  a_extended_properties         []: <none>
  a_is_signed                     : F
  a_last_review_date              : nulldate

INTERNAL ATTRIBUTES

  i_is_deleted                    : F
  i_reference_cnt                 : 1
  i_has_folder                    : T
  i_folder_id                  [0]: 0c01d92080000105
  i_contents_id                   : 0000000000000000
  i_cabinet_id                    : 0c01d92080000105
  i_antecedent_id                 : 0000000000000000
  i_chronicle_id                  : 0901d9208058676d
  i_latest_flag                   : T
  i_branch_cnt                    : 0
  i_direct_dsc                    : F
  i_is_reference                  : F
  i_retain_until                  : 22.03.2017 9:48:01
  i_retainer_id                [0]: 0801d92080586777
  i_partition                     : 0
  i_is_replica                    : F
  i_vstamp                        : 2

And somebody should think twice before writing wrong documentation

All comments

PanfilovAB


I am trying to apply retention in a TBO , but am getting a class cast exception.

java.lang.ClassCastException: com.are.tbo.SystemDocumentTBO___PROXY cannot be cast to com.documentum.records.policyengine.IPolicyCoordinator
    at com.documentum.records.policyengine.PolicyService.applyPolicy(PolicyService.java:152)

It's expected behavior when you're trying to attach aspect inside TBO.

prasan_13

Oh.Ok. So is there any way to apply retention in a TBO or does it have to be done outside the TBO?

Any suggestions?

Thanks

Haroon_A

Can you tell which line is 47 in your TBO that gives error?

Have you implemented IDfDynamicInheritance interface for your TBO?

If this error is truly caused due to attaching aspect in your TBO, then you need to use callback. See DFC Dev guide, under section "Using Aspects in TBO" for details.

https://community.emc.com/servlet/JiveServlet/previewBody/3230-102-2-8563/DFC%20Development%20Guide.pdf

prasan_13

The exact line that causes the error is

ips.apply(this,param);

where ips is the IpolicyService

IPolicyService ips=(IPolicyService)DfClient.getLocalClient().

newModule(this.getSession().getDocbaseName(),(IPolicyService.class).

getName(),this.getSession().getSessionManager());

and yes the TBO does implement the IDfDynamicInheritance.

Thanks

Haroon_A

See if this link if of any help to you.

prasan_13

Thanks Ahmad, I saw the code and i'm pretty much using the same api's . I'm pretty sure my code would work if i am calling it from an outside class or method but i I think the issue is exactly this line

ips.apply(this,param); I have a to pass my sysobject to the IPolicyService.apply method.

here the "this" is my TBO and that's seems to be the problem. Don't see any other way to apply retention in a TBO though.

Maybe i need to create an aspect to apply retention and call the aspect from my TBO. That could probably be something that would work.

Any other suggestions?

Haroon_A

Yeah true; but the difference between your way and the example, is that in the example, it's done through Retention Service, as opposed to Policy Service. This is what I noticed, not sure if there's any differences.

prasan_13

I did check that and the link seems to be pretty old. I think that was for RPS 5.3. I'm guessing the IRetentionService has been deprecated. Not sure. I checked the jar files in the records 6.7 sp2 web app and also the 6.7 sp2 RPS java docs. They do not have the IRetentionService. Only IPolicyService.And as you said i doubt that is the issue.

Thanks

prasan_13

I tried to move the apply retention policy code to a SBO and called the SBO from the TBO and tried to apply the retention policy there, but same issue.

Looks like we cant use the TBO's sysobject in the IPolicyService.apply method.

Michael McCollough

They way I do it, is I link to a folder with the retention policy. If I cannot do that, then I fire an automated workflow to apply the retention. The workflow is pretty quick, I have a template of about 70 folders that are a template file plan for different divisions of a company that, when copied to a new division cabinet, kickoff a workflow from the TBO to apply the correct retention policy.

There are callback interfaces you can use as Ahmad pointed out, the most reliable and easiest to implement way to apply retention I have found is through linking to a folder in the fileplan, or kicking off an automated workflow to apply the retention.

jsilver

Have you checked out this white paper?

prasan_13

Thanks McCollough and Jerry for the suggestions.

Jerry, based on the documentation it looks like it clearly states that "

The developer inside the doSave() method of a TBO or aspect will attempt to link to a retained or held folder.

This will not work

also "A better scenario is to record the intent to put the document under retention or hold in the doSave method and then have a separate process outside of the TBO link or apply the correct API to the object".

So basically i think as McCollough suggested , i have to kickoff a workflow from the TBO to apply the correct retention policy.

I was thinking maybe to use a asynchronous Server Method to apply the retention. D2 seems to use it currently with its D2ApplyRetention Policy method? Has anyone tried using a server method for applying retention.

PanfilovAB


prasan_13 wrote:

Oh.Ok. So is there any way to apply retention in a TBO or does it have to be done outside the TBO?

Any suggestions?

Thanks

Not sure that will work, try something like:


public interface ITestTBO extends IDfSysObject {

    void setDoNotAttachPolicy(boolean value) throws DfException;

    boolean isDoNotAttachPolicy() throws DfException;

}


public class TestTBO extends DfSysObject implements ITestTBO {

    public static String DO_NOT_ATTACH_POLICY = "_DO_NOT_ATTACH_POLICY_";

    public TestTBO() {
        super();
    }

    public void setDoNotAttachPolicy(boolean value) throws DfException {
        getExtendedData().setBoolean(DO_NOT_ATTACH_POLICY, value);
    }

    public boolean isDoNotAttachPolicy() throws DfException {
        ITypedData extendedData = getExtendedData();
        if (!extendedData.hasAttr(DO_NOT_ATTACH_POLICY)) {
            return false;
        }
        return extendedData.getBoolean(DO_NOT_ATTACH_POLICY);
    }

    private ITestTBO getUncachedObject() throws DfException {
        return (ITestTBO) getObjectSession().getUncachedObject(getObjectId(),
                null);
    }

    private void attachPolicy() throws DfException {
        ITestTBO newInstance = getUncachedObject();
        newInstance.setDoNotAttachPolicy(true);
        ((IPersistentObject)newInstance).setCached(true);
        IDfClientX client = new DfClientX();
        IDfId fId = client.getId("0800136180006d09");
        IPolicyService ips = (IPolicyService) DfClient.getLocalClient()
                .newModule(getSession().getDocbaseName(),
                        (IPolicyService.class).getName(),
                        getSession().getSessionManager());
        PolicyParamBean param = new PolicyParamBean();
        param.setPolicyId(fId);
        ips.apply(newInstance, param);
        newInstance.save();
    }

    @Override
    protected synchronized void doSave(boolean keepLock, String versionLabels,
            Object[] extendedArgs) throws DfException {
        boolean doNotAttachPolicy = isDoNotAttachPolicy();
        super.doSave(keepLock, versionLabels, extendedArgs);
        if (!doNotAttachPolicy) {
            attachPolicy();
        }
    }

}

prasan_13

Thanks for the code. It helped me get past the hurdle of the class cast exception. But it looks like there are some duplicate calls happening internally. below error.

15:02:51,618 ERROR [http-apr-80-exec-10] com.documentum.webcomponent.library.contenttransfer.importcontent.UcfImportContainer - WARNING: unexpected error occured

DfException:: THREAD: Timer-43; MSG: [DMC_RPS_RETENTION] Cannot directly apply the Retention Policy with ID='0800136180006d09' as it is already directly applied.; ERRORCODE: ff; NEXT: null

at com.documentum.rps.retention.RetentionPolicyOperations.guardAgainstTheRetentionPolicyAlreadyBeingApplied(RetentionPolicyOperations.java:3824)

at com.documentum.rps.retention.RetentionPolicyOperations.applyDirectRetention(RetentionPolicyOperations.java:3741)

at com.documentum.rps.retention.RetentionPolicyOperations.applyDirectRetentionPolicies(RetentionPolicyOperations.java:3724)

at com.documentum.rps.retention.RetentionPolicyOperations.preDoSaveNonFolder(RetentionPolicyOperations.java:3429)

at com.documentum.rps.retention.RetentionPolicyOperations.access$400(RetentionPolicyOperations.java:40)

at com.documentum.rps.retention.RetentionPolicyOperations$PrivilegedPreDoSave.run(RetentionPolicyOperations.java:2794)

at com.documentum.fc.client.security.DfPrivilegedExceptionActionInRole.run(DfPrivilegedExceptionActionInRole.java:106)

at java.security.AccessController.doPrivileged(Native Method)

at com.documentum.rps.retention.RetentionPolicyOperations.doPrivilegedPreDoSave(RetentionPolicyOperations.java:2764)

at com.documentum.rps.retention.RetentionPolicyOperations.preDoSave(RetentionPolicyOperations.java:2693)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.doSaveBeforeDoubleSaveIntroduced(DefaultPolicyCoordinator.java:802)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.doSave(DefaultPolicyCoordinator.java:610)

at com.documentum.fc.client.DfPersistentObject.saveEx(DfPersistentObject.java:912)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.saveEx(DefaultPolicyCoordinator.java:414)

at com.documentum.fc.client.DfPersistentObject.save(DfPersistentObject.java:907)

at com.documentum.records.policyengine.DefaultPolicyCoordinator___PROXY.save(DefaultPolicyCoordinator___PROXY.java)

at com.are.tbo.PropertyDocumentTBO.attachPolicy(PropertyDocumentTBO.java:57)

at com.are.tbo.PropertyDocumentTBO.doSave(PropertyDocumentTBO.java:69)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.internalDoSave(DefaultPolicyCoordinator.java:1261)

at com.documentum.records.policyengine.DefaultPolicyCoordinator$PrivilegedNestedDoSave.run(DefaultPolicyCoordinator.java:1251)

at com.documentum.fc.client.security.DfPrivilegedExceptionActionInRole.run(DfPrivilegedExceptionActionInRole.java:106)

at java.security.AccessController.doPrivileged(Native Method)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.doPrivilegedNestedDoSave(DefaultPolicyCoordinator.java:1055)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.doSaveBeforeDoubleSaveIntroduced(DefaultPolicyCoordinator.java:867)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.doSave(DefaultPolicyCoordinator.java:592)

at com.documentum.fc.client.DfPersistentObject.saveEx(DfPersistentObject.java:912)

at com.documentum.records.policyengine.DefaultPolicyCoordinator.saveEx(DefaultPolicyCoordinator.java:414)

at com.documentum.fc.client.DfPersistentObject.save(DfPersistentObject.java:907)

at com.are.tbo.PropertyDocumentTBO___PROXY.save(PropertyDocumentTBO___PROXY.java)

at com.are.tbo.PropertyDocumentTBO.attachPolicy(PropertyDocumentTBO.java:57)

at com.are.tbo.PropertyDocumentTBO.doSave(PropertyDocumentTBO.java:69)

at com.documentum.fc.client.DfPersistentObject.saveEx(DfPersistentObject.java:912)

at com.documentum.fc.client.DfPersistentObject.save(DfPersistentObject.java:907)

at com.are.tbo.PropertyDocumentTBO___PROXY.save(PropertyDocumentTBO___PROXY.java)

at com.documentum.operations.nodeactions.inbound.DfCheckinObject.checkin(DfCheckinObject.java:235)

at com.documentum.operations.nodeactions.inbound.DfCheckinObject.execute(DfCheckinObject.java:39)

at com.documentum.operations.steps.impl.OperationStep.executeStep(OperationStep.java:163)

at com.documentum.operations.steps.impl.OperationStep.execute(OperationStep.java:41)

at com.documentum.operations.impl.OperationExecutionEngine.execute(OperationExecutionEngine.java:51)

at com.documentum.operations.DfOperation.execute(DfOperation.java:401)

at com.documentum.operations.inbound.impl.InboundOperation.execute(InboundOperation.java:104)

at com.documentum.operations.inbound.DfImportOperation.execute(DfImportOperation.java:96)

at com.documentum.web.contentxfer.DFCOperationSupport.execute(DFCOperationSupport.java:61)

at com.documentum.web.contentxfer.ContentTransferService.execute(ContentTransferService.java:377)

at com.documentum.web.contentxfer.JobAdapter.execute(JobAdapter.java:108)

at com.documentum.job.async.AsyncJobManager$AsyncTimerJob.executeJob(AsyncJobManager.java:236)

at com.documentum.job.async.AsyncJobManager$AsyncTimerJob.run(AsyncJobManager.java:215)

at java.util.TimerThread.mainLoop(Unknown Source)

at java.util.TimerThread.run(Unknown Source)

PanfilovAB

Show your resulting code, I bet you missed something,

PanfilovAB


PanfilovAB wrote:

Show your resulting code, I bet you missed something,

Let's clarify my code and why something does not work in yours.

IPolicyService tries to attach aspect dmc_policy_coordinator
the problem is dmc_policy_coordinator introduces new class behavior so to apply such changes the current TBO class should be reconstructed, but it's not possible to reconstruct class because you are currently performing some calls (save) inside this class (see also )
the trick was construct new object after complete of doSave() method (what getObjectSession().getUncachedObject(getObjectId(), null) call does) and apply policy to new object
but save() against new constructed object will cause a recursion in doSave() method because doSave() method tries to construct new object and apply policy ...
so you either forgot to add my important methods (isDoNotAttachPolicy(), setDoNotAttachPolicy and boolean doNotAttachPolicy = isDoNotAttachPolicy() before super.doSave()) or these methods do not wark and you need another trick to stop recursion

here is recursion:


   at com.documentum.records.policyengine.DefaultPolicyCoordinator___PROXY.save(DefaultPolicyCoordinator___PROXY.java)
    at com.are.tbo.PropertyDocumentTBO.attachPolicy(PropertyDocumentTBO.java:57)
    at com.are.tbo.PropertyDocumentTBO.doSave(PropertyDocumentTBO.java:69)
    at com.documentum.records.policyengine.DefaultPolicyCoordinator.internalDoSave(DefaultPolicyCoordinator.java:1261)

......

    at com.documentum.records.policyengine.DefaultPolicyCoordinator.doSave(DefaultPolicyCoordinator.java:592)
    at com.documentum.fc.client.DfPersistentObject.saveEx(DfPersistentObject.java:912)
    at com.documentum.records.policyengine.DefaultPolicyCoordinator.saveEx(DefaultPolicyCoordinator.java:414)
    at com.documentum.fc.client.DfPersistentObject.save(DfPersistentObject.java:907)
    at com.are.tbo.PropertyDocumentTBO___PROXY.save(PropertyDocumentTBO___PROXY.java)

prasan_13

Below is the code. Your's right , its getting called the second time. trying to figure out how to avoid that..

public static String DO_NOT_ATTACH_POLICY = "_DO_NOT_ATTACH_POLICY_";

public PropertyDocumentTBO() {

super();

}

public void setDoNotAttachPolicy(boolean value) throws DfException {

DfLogger.debug(this, "Inside setDoNotAttachPolicy", null,null);

getExtendedData().setBoolean(DO_NOT_ATTACH_POLICY, value);

}

public boolean isDoNotAttachPolicy() throws DfException {

DfLogger.debug(this, "Inside isDoNotAttachPolicy", null,null);

ITypedData extendedData = getExtendedData();

if (!extendedData.hasAttr(DO_NOT_ATTACH_POLICY)) {

DfLogger.debug(this, "returning fasle", null,null);

return false;

}

DfLogger.debug(this, "returning" + extendedData.getBoolean(DO_NOT_ATTACH_POLICY) , null,null);

return extendedData.getBoolean(DO_NOT_ATTACH_POLICY);

}

private IPropertyDocumentTBO getUncachedObject() throws DfException {

return (IPropertyDocumentTBO) getObjectSession().getUncachedObject(getObjectId(),

null);

}

private void attachPolicy() throws DfException {

DfLogger.debug(this, "attach policy", null,null);

IPropertyDocumentTBO newInstance = getUncachedObject();

newInstance.setDoNotAttachPolicy(true);

((IPersistentObject)newInstance).setCached(true);

IDfClientX client = new DfClientX();

IDfId fId = client.getId("0800136180006d09");

IPolicyService ips = (IPolicyService) DfClient.getLocalClient()

.newModule(getSession().getDocbaseName(),

(IPolicyService.class).getName(),

getSession().getSessionManager());

PolicyParamBean param = new PolicyParamBean();

param.setPolicyId(fId);

ips.apply(newInstance, param);

newInstance.save();

}

@Override

protected synchronized void doSave(boolean keepLock, String versionLabels,

Object[] extendedArgs) throws DfException {

DfLogger.debug(this, "PropertyDocumentTBO inside doSave", null,null);

boolean doNotAttachPolicy = isDoNotAttachPolicy();

super.doSave(keepLock, versionLabels, extendedArgs);

if (!doNotAttachPolicy) {

DfLogger.debug(this, "Attach policy Now", null,null);

attachPolicy();

}

prasan_13

Looking at the logs and my debug statements it looks like it works fine initially

16:26:32,119 DEBUG [Timer-44] com.are.tbo.PropertyDocumentTBO - PropertyDocumentTBO inside doSave

16:26:32,119 DEBUG [Timer-44] com.are.tbo.PropertyDocumentTBO - Inside isDoNotAttachPolicy

16:26:32,119 DEBUG [Timer-44] com.are.tbo.PropertyDocumentTBO - returning fasle

16:26:34,213 DEBUG [Timer-44] com.are.tbo.PropertyDocumentTBO - Attach policy Now

16:26:34,228 DEBUG [Timer-44] com.are.tbo.PropertyDocumentTBO - attach policy

16:26:34,228 DEBUG [Timer-44] com.are.tbo.PropertyDocumentTBO - Inside setDoNotAttachPolicy

16:26:47,322 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - PropertyDocumentTBO inside doSave

16:26:47,322 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - Inside isDoNotAttachPolicy

16:26:47,322 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - returningtrue

Also see the retainers getting created correctly.

But then it seems to get called again

16:26:55,588 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - PropertyDocumentTBO inside doSave

16:26:55,588 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - Inside isDoNotAttachPolicy

16:26:55,588 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - returning fasle

16:26:55,619 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - Attach policy Now

16:26:55,619 DEBUG [Timer-44] com.documentum.records.policyengine.DefaultPolicyCoordinator - attach policy

PanfilovAB


import java.util.HashSet;
import java.util.Set;

import com.documentum.fc.client.DfClient;
import com.documentum.fc.client.DfSysObject;
import com.documentum.fc.client.IDfModule;
import com.documentum.fc.client.IDfSession;
import com.documentum.fc.client.IDfSessionManager;
import com.documentum.fc.client.IDfSysObject;
import com.documentum.fc.client.impl.IPersistentObject;
import com.documentum.fc.client.impl.util.TransactionalFunctorWithRetry;
import com.documentum.fc.common.DfException;
import com.documentum.fc.common.IDfId;
import com.documentum.fc.impl.util.Functor;
import com.documentum.records.policy.IPolicyService;
import com.documentum.records.policy.PolicyParamBean;

public class TestTBO extends DfSysObject {

    private static ThreadLocal<Set<IDfId>> PENDING = new ThreadLocal<Set<IDfId>>() {
        @Override
        protected Set<IDfId> initialValue() {
            return new HashSet<IDfId>();
        }
    };

    public TestTBO() {
        super();
    }

    private void setDoNotAttachPolicy(boolean value) throws DfException {
        if (value) {
            PENDING.get().add(getObjectId());
        } else {
            PENDING.get().remove(getObjectId());
        }
    }

    private boolean isDoNotAttachPolicy(IDfId policyId, boolean isNew)
        throws DfException {
        boolean pending = PENDING.get().contains(getObjectId());
        if (pending) {
            return true;
        }
        if (isNew) {
            return false;
        }
        // some business logic here
        return false;
    }

    private IDfSysObject getUncachedObject() throws DfException {
        return (IDfSysObject) getObjectSession().getUncachedObject(
                getObjectId(), null);
    }

    protected IDfId getRetentionPolicyId() throws DfException {
        return getObjectSession().getIdByQualification(
                "dmc_rps_retention_policy where object_name='test'");
    }

    private boolean attachPolicy(IDfId policyId, boolean isNew)
        throws DfException {
        if (isDoNotAttachPolicy(policyId, isNew)) {
            return false;
        }

        try {
            setDoNotAttachPolicy(true);
            IDfSysObject newInstance = getUncachedObject();
            ((IPersistentObject) newInstance).setCached(true);
            IPolicyService ips = getModule(IPolicyService.class,
                    getObjectSession());
            PolicyParamBean param = new PolicyParamBean();
            param.setPolicyId(policyId);
            ips.apply(newInstance, param);
            newInstance.save();
            return true;
        } finally {
            setDoNotAttachPolicy(false);
        }
    }

    protected void doSaveSuper(final boolean keepLock,
            final String versionLabels, final Object[] extendedArgs)
        throws DfException {
        super.doSave(keepLock, versionLabels, extendedArgs);
    }

    @Override
    protected synchronized void doSave(final boolean keepLock,
            final String versionLabels, final Object[] extendedArgs)
        throws DfException {
        final boolean isNew = isNew();
        new TransactionalFunctorWithRetry(getObjectSession(), new Functor() {
            @Override
            public Object evaluate() throws DfException {
                doSaveSuper(keepLock, versionLabels, extendedArgs);
                if (attachPolicy(getRetentionPolicyId(), isNew)) {
                    updateStateAfterSave();
                }
                return null;
            }
        }, true).evaluate();
    }

    @SuppressWarnings("unchecked")
    static <T> T getModule(Class<T> cls, IDfSession session) throws DfException {
        return (T) getModule(cls.getName(), session.getSessionManager(),
                session.getDocbaseName());
    }

    static IDfModule getModule(String name, IDfSessionManager sMgr,
            String docbase) throws DfException {
        return new DfClient().newModule(docbase, name, sMgr);
    }
}


API>create,c,test_rps
...
0901d9208058676d
API>save,c,l
...
OK
API>dump,c,l
...
USER ATTRIBUTES

  object_name                     :
  title                           :
  subject                         :
  authors                       []: <none>
  keywords                      []: <none>
  resolution_label                :
  owner_name                      : dmadmin
  owner_permit                    : 7
  group_name                      : docu
  group_permit                    : 5
  world_permit                    : 4
  log_entry                       :
  acl_domain                      : dmadmin
  acl_name                        : dm_4501d92080000101
  language_code                   :

SYSTEM ATTRIBUTES

  r_object_type                   : test_rps
  r_creation_date                 : 22.03.2014 9:48:01
  r_modify_date                   : 22.03.2014 9:48:07
  r_modifier                      : dmadmin
  r_access_date                   : nulldate
  r_composite_id                []: <none>
  r_composite_label             []: <none>
  r_component_label             []: <none>
  r_order_no                    []: <none>
  r_link_cnt                      : 0
  r_link_high_cnt                 : 0
  r_assembled_from_id             : 0000000000000000
  r_frzn_assembly_cnt             : 0
  r_has_frzn_assembly             : F
  r_is_virtual_doc                : 0
  r_page_cnt                      : 0
  r_content_size                  : 0
  r_lock_owner                    :
  r_lock_date                     : nulldate
  r_lock_machine                  :
  r_version_label              [0]: 1.0
                               [1]: CURRENT
  r_immutable_flag                : F
  r_frozen_flag                   : F
  r_has_events                    : F
  r_creator_name                  : dmadmin
  r_is_public                     : T
  r_policy_id                     : 0000000000000000
  r_resume_state                  : 0
  r_current_state                 : 0
  r_alias_set_id                  : 0000000000000000
  r_full_content_size             : 0
  r_aspect_name                [0]: dmc_policy_coordinator
  r_object_id                     : 0901d9208058676d

APPLICATION ATTRIBUTES

  a_application_type              :
  a_status                        :
  a_is_hidden                     : F
  a_retention_date                : nulldate
  a_archive                       : F
  a_compound_architecture         :
  a_link_resolved                 : F
  a_content_type                  :
  a_full_text                     : T
  a_storage_type                  :
  a_special_app                   :
  a_effective_date              []: <none>
  a_expiration_date             []: <none>
  a_publish_formats             []: <none>
  a_effective_label             []: <none>
  a_effective_flag              []: <none>
  a_category                      :
  a_is_template                   : F
  a_controlling_app               :
  a_extended_properties         []: <none>
  a_is_signed                     : F
  a_last_review_date              : nulldate

INTERNAL ATTRIBUTES

  i_is_deleted                    : F
  i_reference_cnt                 : 1
  i_has_folder                    : T
  i_folder_id                  [0]: 0c01d92080000105
  i_contents_id                   : 0000000000000000
  i_cabinet_id                    : 0c01d92080000105
  i_antecedent_id                 : 0000000000000000
  i_chronicle_id                  : 0901d9208058676d
  i_latest_flag                   : T
  i_branch_cnt                    : 0
  i_direct_dsc                    : F
  i_is_reference                  : F
  i_retain_until                  : 22.03.2017 9:48:01
  i_retainer_id                [0]: 0801d92080586777
  i_partition                     : 0
  i_is_replica                    : F
  i_vstamp                        : 2

And somebody should think twice before writing wrong documentation

Haroon_A

I know when an aspect is attached to an object, doSave() gets triggered more than once. I remember having an issue when trying to manipulate an aspect in TBO. See if the following is relevant in your case.

I had to verify if aspect is attached, before attempting to do my logic.

PanfilovAB



Re: java.lang.ClassCastException: com.my.tbo.MyPhysicalFolder incompatible with com.documentum.records.prm.IPhysicalProxy

At first, your suggestion is irrelevant for @prasan_13 problem, at second, it's incorrect.

prasan_13

Thanks Andrew. That worked perfectly :-). Question - the dfc impl util classes that you have used , do we have api documentation for them or did you figure them out yourself.

PanfilovAB


Question - the dfc impl util classes that you have used , do we have api documentation for them

Existence of DFC documentation does not give EMC advantage over partners and third-party consultants

http://blog.tsgrp.com/2014/03/17/documentum-layoffs-alfresco-sales-kickoff-and-more-thoughts-on-documentum-to-alfresco-migration/