public class ErrorQueueDispatchingStrategy extends Object implements DistributionQueueDispatchingStrategy
Modifier and Type | Field and Description |
---|---|
static String |
ERROR_PREFIX |
DEFAULT_QUEUE_NAME
Constructor and Description |
---|
ErrorQueueDispatchingStrategy(String[] queueNames) |
Modifier and Type | Method and Description |
---|---|
Iterable<DistributionQueueItemStatus> |
add(@NotNull DistributionPackage distributionPackage,
@NotNull DistributionQueueProvider queueProvider)
synchronously distribute a
DistributionPackage
to one or more DistributionQueue s provided by the given DistributionQueueProvider |
@NotNull List<String> |
getQueueNames()
Returns the queue names available for this strategy.
|
public static final String ERROR_PREFIX
public ErrorQueueDispatchingStrategy(String[] queueNames)
public Iterable<DistributionQueueItemStatus> add(@NotNull @NotNull DistributionPackage distributionPackage, @NotNull @NotNull DistributionQueueProvider queueProvider) throws DistributionException
DistributionQueueDispatchingStrategy
DistributionPackage
to one or more DistributionQueue
s provided by the given DistributionQueueProvider
add
in interface DistributionQueueDispatchingStrategy
distributionPackage
- a DistributionPackage
to distributequeueProvider
- the DistributionQueueProvider
used to provide the queues to be used for the given packageIterable
of DistributionQueueItemStatus
s representing
the states of the DistributionQueueItem
s added to one or more DistributionQueue
sDistributionException
- if any internal error happens during distribution@NotNull public @NotNull List<String> getQueueNames()
DistributionQueueDispatchingStrategy
getQueueNames
in interface DistributionQueueDispatchingStrategy
Copyright © 2007–2018 The Apache Software Foundation. All rights reserved.