Find Jobs by Tag about android-priority-jobqueue HOT 8 OPEN

class MyQueueFactory implements QueueFactory {
    private final SqliteJobQueue.JobSerializer jobSerializer;

    private CachedJobQueue persistentJobQueue;
    private CachedJobQueue nonPersistentJobQueue;

    MyQueueFactory(){
        this(new SqliteJobQueue.JavaSerializer());
    }

    MyQueueFactory(SqliteJobQueue.JobSerializer jobSerializer) {
        this.jobSerializer = jobSerializer;
    }

    CachedJobQueue getPersistentJobQueue() {
        return persistentJobQueue;
    }

    CachedJobQueue getNonPersistentJobQueue() {
        return nonPersistentJobQueue;
    }


    @Override
    public JobQueue createPersistentQueue(Configuration configuration, long sessionId) {
        this.persistentJobQueue = new CachedJobQueue(new SqliteJobQueue(configuration, sessionId, jobSerializer));
        return persistentJobQueue;
    }

    @Override
    public JobQueue createNonPersistent(Configuration configuration, long sessionId) {
        this.nonPersistentJobQueue = new CachedJobQueue(new SimpleInMemoryPriorityQueue(configuration, sessionId));
        return nonPersistentJobQueue;
    }
}

class MyConstraint extends Constraint{
    @Override
    public int getMaxNetworkType() {
        // My jobs require network so I had to override this filter
        return NetworkUtil.METERED;
    }

    @Override
    public Set<String> getTags() {
        HashSet<String> tagsList = new HashSet<>();
        // Here you can filter by tags
        tagsList.add("MY_JOB_TAG");
        return tagsList;
    }
}

public class MyJobManager {
    private static final MyJobManager instance = new MyJobManager();

    private final JobManager jobManager;
    private final MyQueueFactory queueFactory;

    private MyJobManager(){
        this.queueFactory = new MyQueueFactory();
        this.jobManager = new JobManager(new Configuration.Builder(MyApp.getAppContext())
                .id("MyJobManager")
                .queueFactory(this.queueFactory)
                .build());

        this.listeners = new ArrayList<>();
    }

    public static MyJobManager getInstance(){
        return MyJobManager.instance;
    }

    public void addJobInBackground(Job job){
        this.jobManager.addJobInBackground(job);
    }

    public List<Job> getPendingJobs(){
        ArrayList<Job> jobList = new ArrayList<>();

        CachedJobQueue jobQueue = this.queueFactory.getPersistentJobQueue();
        if(jobQueue != null){
            // Here we use our Constraint override to filter the jobs.
            Set<JobHolder> jobs = jobQueue.findJobs(new MyConstraint());

            for(JobHolder jobHolder: jobs){
                Job job = jobHolder.getJob();

                if(job != null){
                    jobList.add(job);
                }
            }
        }

        return jobList;
    }
}

public class CustomQueueFactory implements QueueFactory {
    private SqliteJobQueue.JobSerializer jobSerializer;

    private CachedJobQueue persistentJobQueue;
    private CachedJobQueue nonPersistentJobQueue;

    CustomQueueFactory(){
        this(new SqliteJobQueue.JavaSerializer());
    }

    CustomQueueFactory(SqliteJobQueue.JobSerializer jobSerializer) {
        this.jobSerializer = jobSerializer;
    }

    CachedJobQueue getPersistentJobQueue() {
        return persistentJobQueue;
    }

    CachedJobQueue getNonPersistentJobQueue() {
        return nonPersistentJobQueue;
    }

    @Override
    public JobQueue createPersistentQueue(Context context, Long sessionId, String id, boolean inTestMode) {
        this.persistentJobQueue = new CachedJobQueue(new SqliteJobQueue(context, sessionId, id, jobSerializer,inTestMode));
        return persistentJobQueue;
    }

    @Override
    public JobQueue createNonPersistent(Context context, Long sessionId, String id, boolean inTestMode) {
        this.nonPersistentJobQueue = new CachedJobQueue(new NonPersistentPriorityQueue(sessionId, id, inTestMode));
        return nonPersistentJobQueue;
    }
}

CustomQueueFactory queueFactory = new CustomQueueFactory();
JobManager jobManager = new JobManager(context,
                new Configuration.Builder(context)
                .queueFactory(queueFactory)
                .build()
);
CachedJobQueue jobQueue = queueFactory.getPersistentJobQueue();
Set<JobHolder> jobs = jobQueue.findJobsByTags(TagConstraint.ANY, true, null, "my_awesome_tag");
// findJobsByTags(TagConstraint constraint, boolean excludeCancelled, Collection<Long> exclude, String... tags)