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; } } }

As we transition to the new Hyland Community, some post links may be temporarily disrupted as we finalize redirects. We apologize for the inconvenience and are working to resolve this as quickly as possible. Details.

CMIS Change Log Token problem using OpenCMIS

gregbpopstar

I'm successfully opening an OpenCMIS "Session" to Alfresco 3.4.b and getting a list of change log changes to support a sync operation.

The relevant code looks kinda like this:

ChangeEvents changes = session.getContentChanges(getLastToken(), true, 1000);
String newToken = changes.getLatestChangeLogToken();
…
saveAsLastToken(newToken);

Once I get the list of changes I'm trying keep the last change token and use it for the next getContentChanges call in order to get only new content changes.

My problem is that the changes.getLatestChangeLogToken() always returns null for me.

In order the get the change log stuff to work at all I have to turn it on in alfresco using the audit.cmischangelog.enabled=true option in the global config.

Has anyone had success getting a change log token?

Find more posts tagged with

Comments

fmui

You are probably using the AtomPub binding. It doesn't return a change log token. That's a binding limitation, not an Alfresco limitation.

You either have to switch to Web Services or you have to do something ugly like this:

RepositoryInfo ri = session.getBinding().getRepositoryService().getRepositoryInfo(session.getRepositoryInfo().getId(), null);
String latestChangeLogToken = ri.getLatestChangeLogToken();‍‍

- Florian

gregbpopstar

Thanks Florian.

When I use your "ugly solution", I get a token which is not null. That's progress!

keesvanbemmel

Hi,

I've tried getting changes (iteratively) from the repository… but I think I fail to understand the logic behind it. I thought it would work like this:

1. Get the changes from the repo using "null" token
2. This returns the changes as well as a new token
3. Process the changes
4. Get new changes using new token (because I don't want to process the same changes again of course)
5. rinse and repeat from 2

However, the test code below shows that the returned change token in the changes is always the same as the one that was passed?? Any idea why and how I should process changes??

By the way, the tokens that are returned using webservice calls are identical to the ones gotten from atompub binding.

Regards,

Kees.

OUTPUT:
<blockquote>
token: null total numbers: 33
New changes token: null
token: 27 total numbers: 7
New changes token: 27
token: 28 total numbers: 5
New changes token: 29
token: 29 total numbers: 6
New changes token: 28
token: 33 total numbers: 1
New changes token: 33
</blockquote>

CODE:

import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.logging.Level;

import org.apache.chemistry.opencmis.client.api.ChangeEvents;
import org.apache.chemistry.opencmis.client.api.Session;
import org.apache.chemistry.opencmis.client.api.SessionFactory;
import org.apache.chemistry.opencmis.client.bindings.CmisBindingFactory;
import org.apache.chemistry.opencmis.client.runtime.SessionFactoryImpl;
import org.apache.chemistry.opencmis.commons.SessionParameter;
import org.apache.chemistry.opencmis.commons.data.RepositoryInfo;
import org.apache.chemistry.opencmis.commons.enums.BindingType;
import org.apache.chemistry.opencmis.commons.spi.CmisBinding;

public class TempTest {

&nbsp;&nbsp;&nbsp;/**
&nbsp;&nbsp;&nbsp; * @param args
&nbsp;&nbsp;&nbsp; */
&nbsp;&nbsp;&nbsp;public static void main(String[] args) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final CmisBinding binding;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final Session session;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final Session websession;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String repositoryId;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String url = "http://10.20.1.110:8080/alfresco/cmisatom";

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// holder for the parameters
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final Map<String, String> parameters = new HashMap<String, String>();

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// User credentials.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;parameters.put(SessionParameter.USER, "admin");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;parameters.put(SessionParameter.PASSWORD, "admin");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// Connection settings.
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;parameters.put(SessionParameter.ATOMPUB_URL, url);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// type of binding
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;parameters.put(SessionParameter.BINDING_TYPE,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;BindingType.ATOMPUB.value());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;try {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// no repositoryId is set so first make a binding to fetch
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// the
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// first repository in the list
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;binding = CmisBindingFactory.newInstance()
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.createCmisAtomPubBinding(parameters);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// if there is no binding no use to get on
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (binding != null) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final List<RepositoryInfo> infos = binding
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.getRepositoryService()
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.getRepositoryInfos(null);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;if (!infos.isEmpty()) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final RepositoryInfo repInfo = infos.get(0);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// now we have the repository and use it as a
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// parameter
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;// to create the session
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;repositoryId = repInfo.getId();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;parameters.put(SessionParameter.REPOSITORY_ID,
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;repositoryId);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} else {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("No repository found!");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} else {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("Given credentials are probably not correct!");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;final SessionFactory sessionFactory = SessionFactoryImpl
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.newInstance();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;session = sessionFactory.createSession(parameters);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;RepositoryInfo ri = session.getBinding().getRepositoryService().getRepositoryInfo(session.getRepositoryInfo().getId(), null);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;String latestChangeLogToken = ri.getLatestChangeLogToken();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;ChangeEvents changes = session.getContentChanges(null, true, 1000);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("token: " + null + " total numbers: " +changes.getChangeEvents().size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("New changes token: " + changes.getLatestChangeLogToken());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;changes = session.getContentChanges("27", true, 1000);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("token: " +"27" + " total numbers: " +changes.getChangeEvents().size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("New changes token: " + changes.getLatestChangeLogToken());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;changes = session.getContentChanges("29", true, 1000);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("token: " +"28" + " total numbers: " +changes.getChangeEvents().size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("New changes token: " + changes.getLatestChangeLogToken());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;changes = session.getContentChanges("28", true, 1000);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("token: " +"29" + " total numbers: " +changes.getChangeEvents().size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("New changes token: " + changes.getLatestChangeLogToken());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;changes = session.getContentChanges(latestChangeLogToken, true, 1000);
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("token: " +latestChangeLogToken + " total numbers: " +changes.getChangeEvents().size());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("New changes token: " + changes.getLatestChangeLogToken());
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} catch (final Exception e) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;System.out.println("Given credentials are probably not correct! ");
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;e.printStackTrace();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;}

&nbsp;&nbsp;&nbsp;}

}
‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍‍