You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sling.apache.org by ro...@apache.org on 2017/11/07 09:28:58 UTC

[sling-org-apache-sling-distribution-api] 24/41: SLING-4153 - improved queue's javadoc

This is an automated email from the ASF dual-hosted git repository.

rombert pushed a commit to annotated tag org.apache.sling.distribution.api-0.1.0
in repository https://gitbox.apache.org/repos/asf/sling-org-apache-sling-distribution-api.git

commit 635f7890bbc53dce410a6eb330d89a6ec46ab9c2
Author: Tommaso Teofili <to...@apache.org>
AuthorDate: Wed Dec 10 08:41:42 2014 +0000

    SLING-4153 - improved queue's javadoc
    
    git-svn-id: https://svn.apache.org/repos/asf/sling/trunk/contrib/extensions/distribution/api@1644350 13f79535-47bb-0310-9956-ffa450edef68
---
 .../distribution/queue/DistributionQueue.java      | 24 ++++++++++++++--------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/src/main/java/org/apache/sling/distribution/queue/DistributionQueue.java b/src/main/java/org/apache/sling/distribution/queue/DistributionQueue.java
index df23399..54a4ec0 100644
--- a/src/main/java/org/apache/sling/distribution/queue/DistributionQueue.java
+++ b/src/main/java/org/apache/sling/distribution/queue/DistributionQueue.java
@@ -22,11 +22,17 @@ import javax.annotation.CheckForNull;
 import javax.annotation.Nonnull;
 import javax.annotation.Nullable;
 
-import aQute.bnd.annotation.ConsumerType;
 import aQute.bnd.annotation.ProviderType;
 
 /**
- * a queue for handling {@link org.apache.sling.distribution.agent.DistributionAgent}s' requests
+ * A queue is responsible for collecting the {@link org.apache.sling.distribution.packaging.DistributionPackage}s
+ * exported by a {@link org.apache.sling.distribution.agent.DistributionAgent} in
+ * order to be able to process them also when there are multiple (concurrent)
+ * {@link org.apache.sling.distribution.communication.DistributionRequest}s executed
+ * on that same agent.
+ * <p/>
+ * The items (packages) in the queue can then get processed according to a FIFO
+ * strategy or in parallel, or some other way, via {@link org.apache.sling.distribution.queue.DistributionQueueProcessor}s.
  */
 @ProviderType
 public interface DistributionQueue {
@@ -42,25 +48,26 @@ public interface DistributionQueue {
     /**
      * add a distribution item to this queue
      *
-     * @param item a distribution item representing the package to distribute
+     * @param item a distribution item representing a {@link org.apache.sling.distribution.packaging.DistributionPackage}
+     *             to distribute
      * @return {@code true} if the distribution item was added correctly to the queue,
      * {@code false} otherwise
      */
     boolean add(@Nonnull DistributionQueueItem item);
 
     /**
-     * get the status of a certain item in the queue
+     * get the state of a certain item in the queue
      *
      * @param item the distribution item to get the status for
      * @return the item status in the queue
      * @throws DistributionQueueException if any error occurs while getting the status
      */
     @Nonnull
-    DistributionQueueItemState getStatus(@Nonnull DistributionQueueItem item)
+    DistributionQueueItemState getState(@Nonnull DistributionQueueItem item)
             throws DistributionQueueException;
 
     /**
-     * get the first item (FIFO wise, the next to be processed) into the queue
+     * get the first item (in a FIFO strategy, the next to be processed) from the queue
      *
      * @return the first item into the queue or {@code null} if the queue is empty
      */
@@ -75,7 +82,7 @@ public interface DistributionQueue {
     boolean isEmpty();
 
     /**
-     * get the items in the queue
+     * get all the items in the queue
      *
      * @param queueItemSelector represents the criteria to filter queue items.
      *                          if null is passed then all items are returned.
@@ -88,7 +95,8 @@ public interface DistributionQueue {
      * remove an item from the queue by specifying its id
      *
      * @param id an item's identifier
-     * @return the removed item, or {@code null} if no item could be removed
+     * @return the removed item, or {@code null} if the item with the given id
+     * doesn't exist
      */
     DistributionQueueItem remove(@Nonnull String id);
 }

-- 
To stop receiving notification emails like this one, please contact
"commits@sling.apache.org" <co...@sling.apache.org>.