Class QueueItemFactory
- java.lang.Object
-
- org.apache.sling.distribution.journal.queue.QueueItemFactory
-
@ParametersAreNonnullByDefault public final class QueueItemFactory extends Object
-
-
Field Summary
Fields Modifier and Type Field Description static String
PACKAGE_MSG
static String
RECORD_OFFSET
static String
RECORD_PARTITION
static String
RECORD_TIMESTAMP
static String
RECORD_TOPIC
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static org.apache.sling.distribution.queue.DistributionQueueItem
fromPackage(org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage> fMessage)
static org.apache.sling.distribution.queue.DistributionQueueItem
fromPackage(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.PackageMessage message, boolean addMessage)
-
-
-
Field Detail
-
RECORD_TOPIC
public static final String RECORD_TOPIC
- See Also:
- Constant Field Values
-
RECORD_PARTITION
public static final String RECORD_PARTITION
- See Also:
- Constant Field Values
-
RECORD_OFFSET
public static final String RECORD_OFFSET
- See Also:
- Constant Field Values
-
RECORD_TIMESTAMP
public static final String RECORD_TIMESTAMP
- See Also:
- Constant Field Values
-
PACKAGE_MSG
public static final String PACKAGE_MSG
- See Also:
- Constant Field Values
-
-
Method Detail
-
fromPackage
public static org.apache.sling.distribution.queue.DistributionQueueItem fromPackage(org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.PackageMessage> fMessage)
-
fromPackage
public static org.apache.sling.distribution.queue.DistributionQueueItem fromPackage(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.PackageMessage message, boolean addMessage)
-
-