@ParametersAreNonnullByDefault public final class QueueItemFactory extends Object
Modifier and Type | Field and Description |
---|---|
static String |
PACKAGE_MSG |
static String |
RECORD_OFFSET |
static String |
RECORD_PARTITION |
static String |
RECORD_TIMESTAMP |
static String |
RECORD_TOPIC |
Constructor and Description |
---|
QueueItemFactory() |
Modifier and Type | Method and Description |
---|---|
static org.apache.sling.distribution.queue.DistributionQueueItem |
fromPackage(org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.Messages.PackageMessage> fMessage) |
static org.apache.sling.distribution.queue.DistributionQueueItem |
fromPackage(org.apache.sling.distribution.journal.MessageInfo info,
org.apache.sling.distribution.journal.messages.Messages.PackageMessage message,
boolean addMessage) |
public static final String RECORD_TOPIC
public static final String RECORD_PARTITION
public static final String RECORD_OFFSET
public static final String RECORD_TIMESTAMP
public static final String PACKAGE_MSG
public static org.apache.sling.distribution.queue.DistributionQueueItem fromPackage(org.apache.sling.distribution.journal.FullMessage<org.apache.sling.distribution.journal.messages.Messages.PackageMessage> fMessage)
public static org.apache.sling.distribution.queue.DistributionQueueItem fromPackage(org.apache.sling.distribution.journal.MessageInfo info, org.apache.sling.distribution.journal.messages.Messages.PackageMessage message, boolean addMessage)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.