Package org.apache.ace.client.repository.RepositoryObject

Examples of org.apache.ace.client.repository.RepositoryObject.WorkingState

563
564
565
566
567
568
569
570
571
572
573
        }
        return result;
    }

    public WorkingState getWorkingState(RepositoryObject object) {
        WorkingState result = null;
        synchronized (m_lock) {
            for (RepositorySet set : m_repositorySets) {
                result = set.getWorkingState(object);
                if (result != null) {
                    break;
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
        }
        // Then, go through all objects and check whether they match a definition we know.
        // This prevents calling getDefinition more than once per object.
        for (ObjectRepository<RepositoryObject> repo : m_repos) {
            for (RepositoryObject o : repo.get()) {
                WorkingState state = entries.get(o.getDefinition());
                if (state != null) {
                    m_workingState.put(o, state);
                }
            }
        }
View Full Code Here
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
            boolean wasModified = isModified();
           
            RepositoryObject object = (RepositoryObject) event.getProperty(RepositoryObject.EVENT_ENTITY);
            String topic = event.getTopic();
           
            WorkingState newState = WorkingState.Unchanged;
            if (topic.endsWith("/ADDED")) {
                newState = WorkingState.New;
            }
            else if (topic.endsWith("/CHANGED")) {
                newState = WorkingState.Changed;
            }
            else if (topic.endsWith("/REMOVED")) {
                newState = WorkingState.Removed;
            }
           
            if (!newState.equals(m_workingState.get(object))) {
                m_workingState.put(object, newState);
               
                Properties props = new Properties();
                props.put(RepositoryObject.EVENT_ENTITY, object);
                m_notifier.notifyChanged(RepositoryAdmin.TOPIC_STATUSCHANGED_SUFFIX, props);
View Full Code Here
616
617
618
619
620
621
622
623
624
625
626
        }
        return result;
    }

    public WorkingState getWorkingState(RepositoryObject object) {
        WorkingState result = null;
        synchronized (m_lock) {
            for (RepositorySet set : m_repositorySets) {
                result = set.getWorkingState(object);
                if (result != null) {
                    break;
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
        }
        // Then, go through all objects and check whether they match a definition we know.
        // This prevents calling getDefinition more than once per object.
        for (ObjectRepository<RepositoryObject> repo : m_repos) {
            for (RepositoryObject o : repo.get()) {
                WorkingState state = entries.get(o.getDefinition());
                if (state != null) {
                    m_workingState.put(o, state);
                }
            }
        }
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
            boolean wasModified = isModified();
           
            RepositoryObject object = (RepositoryObject) event.getProperty(RepositoryObject.EVENT_ENTITY);
            String topic = event.getTopic();
           
            WorkingState newState = WorkingState.Unchanged;
            if (topic.endsWith("/ADDED")) {
                newState = WorkingState.New;
            }
            else if (topic.endsWith("/CHANGED")) {
                newState = WorkingState.Changed;
            }
            else if (topic.endsWith("/REMOVED")) {
                newState = WorkingState.Removed;
            }
           
            if (!newState.equals(m_workingState.get(object))) {
                m_workingState.put(object, newState);
               
                Properties props = new Properties();
                props.put(RepositoryObject.EVENT_ENTITY, object);
                m_notifier.notifyChanged(RepositoryAdmin.TOPIC_STATUSCHANGED_SUFFIX, props);
View Full Code Here
539
540
541
542
543
544
545
546
547
548
549
        return result;
    }

    public WorkingState getWorkingState(RepositoryObject object) {
        for (RepositorySet set : m_repositorySets) {
            WorkingState result = set.getWorkingState(object);
            if (result != null) {
                return result;
            }
        }
        return WorkingState.Unchanged;
View Full Code Here
152
153
154
155
156
157
158
159
160
161
162
        }
        // Then, go through all objects and check whether they match a definition we know.
        // This prevents calling getDefinition more than once per object.
        for (ObjectRepository<RepositoryObject> repo : m_repos) {
            for (RepositoryObject o : repo.get()) {
                WorkingState state = entries.get(o.getDefinition());
                if (state != null) {
                    m_workingState.put(o, state);
                }
            }
        }
View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
             */

            boolean wasModified = isModified();
            RepositoryObject object = (RepositoryObject) event.getProperty(RepositoryObject.EVENT_ENTITY);

            WorkingState newState = WorkingState.Unchanged;
            if (event.getTopic().endsWith("/ADDED")) {
                newState = WorkingState.New;
            }
            else if (event.getTopic().endsWith("/CHANGED")) {
                newState = WorkingState.Changed;
            }
            else if (event.getTopic().endsWith("/REMOVED")) {
                newState = WorkingState.Removed;
            }

            if (!newState.equals(m_workingState.get(object))) {
                m_workingState.put(object, newState);
                Properties props = new Properties();
                props.put(RepositoryObject.EVENT_ENTITY, object);
                m_notifier.notifyChanged(RepositoryAdmin.TOPIC_STATUSCHANGED_SUFFIX, props);
            }
View Full Code Here
TOP

Related Classes of org.apache.ace.client.repository.RepositoryObject.WorkingState

  • org.apache.ace.client.repository.impl.RepositoryAdminImpl
  • org.apache.ace.client.repository.impl.RepositorySet
  • org.apache.ace.client.repository.impl.RepositorySet$ModifiedHandler
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.