public class RssDetectionQueue extends Object
Constructor and Description |
---|
RssDetectionQueue() |
Modifier and Type | Method and Description |
---|---|
RssDetectionWork |
enqueue(long repositoryId)
Enqueue work for a repository with the given Id.
|
RssDetectionWork |
enqueue(long repositoryId,
boolean force)
Enqueue work for a repository with the given Id.
|
RssDetectionWork |
getNext()
Retrieves the next unit of work for the RSS detection worker thread.
|
boolean |
hasNext()
Checks if there is any unit of work available for the RSS detection worker thread.
|
boolean |
isInProgress(long vcsRepositoryId) |
boolean |
isShuttingDown()
Yields true if the RSS detection service is currently shutting down.
|
void |
markDone(RssDetectionWork detectionWork)
Marks given work unit as finished.
|
List<RssDetectionWork> |
peekRemaining()
Returns all the remaining work from this queue.
|
List<RssDetectionWork> |
shutdown()
Registers shutdown of the RSS detection service and all the worker threads.
|
public RssDetectionWork enqueue(long repositoryId)
RssDetectionWork
for future
result reference. Specs execution is not enforced. See: enqueue(long, boolean)
public RssDetectionWork enqueue(long repositoryId, boolean force)
RssDetectionWork
for future
result reference.repositoryId
- id of the repositoryforce
- should the scan be executed even if there are no new commitspublic boolean hasNext()
public RssDetectionWork getNext()
Callee of this method becomes responsible for calling markDone(RssDetectionWork)
once the work unit is
completed or cancelled.
public List<RssDetectionWork> peekRemaining()
public void markDone(@NotNull RssDetectionWork detectionWork)
public List<RssDetectionWork> shutdown()
The RssDetectionWork
entities are returned without any modifications. It's the callee's responsibility to
update their state.
public boolean isShuttingDown()
public boolean isInProgress(long vcsRepositoryId)
Copyright © 2020 Atlassian Software Systems Pty Ltd. All rights reserved.