ReplicationQueue.java 1.35 KB
/*
 * Decompiled with CFR 0_118.
 */
package com.day.cq.replication;

import com.day.cq.replication.ReplicationAction;
import com.day.cq.replication.ReplicationContentFacade;

import java.util.Calendar;
import java.util.List;
import java.util.Set;

public interface ReplicationQueue {
    public String getName();

    public List<Entry> entries();

    public List<Entry> entries(String var1);

    public Entry getEntry(String var1, Calendar var2);

    public void clear();

    public void clear(Set<String> var1);

    public boolean isBlocked();

    public boolean isPaused();

    public void setPaused(boolean var1);

    public long lastProcessTime();

    public long nextRetryPeriod();

    public Status getStatus();

    public void forceRetry();

    public static interface Entry {
        public static final Entry[] EMPTY_ARRAY = new Entry[0];

        public String getId();

        public ReplicationQueue getQueue();

        public ReplicationAction getAction();

        public ReplicationContentFacade getContent();

        public int getQueuePosition();

        public Calendar getLastProcessTime();

        public int getNumProcessed();
    }

    public static interface Status {
        public long getStatusTime();

        public long getNextRetryTime();

        public long getProcessingSince();

        public long getLastProcessTime();
    }

}