Modifier and Type | Method and Description |
---|---|
boolean |
JdbcSequencedDeadLetterQueue.process(Function<DeadLetter<? extends E>,EnqueueDecision<E>> processingTask) |
boolean |
JdbcSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends E>> sequenceFilter,
Function<DeadLetter<? extends E>,EnqueueDecision<E>> processingTask) |
Modifier and Type | Method and Description |
---|---|
boolean |
JpaSequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask) |
boolean |
JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask) |
Modifier and Type | Method and Description |
---|---|
boolean |
JpaSequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
Deprecated.
|
boolean |
JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
DoNotEnqueue<M extends Message<?>>
An
EnqueueDecision stating a dead letter should not be enqueued. |
class |
Ignore<M extends Message<?>>
An
EnqueueDecision stating a dead letter should be ignored. |
class |
ShouldEnqueue<M extends Message<?>>
An
EnqueueDecision stating a dead letter should be enqueued. |
Modifier and Type | Method and Description |
---|---|
EnqueueDecision<M> |
EnqueuePolicy.decide(DeadLetter<? extends M> letter,
Throwable cause)
|
Modifier and Type | Method and Description |
---|---|
default boolean |
SequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
Process a sequence of enqueued
dead letters with the given processingTask . |
boolean |
SequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
Process a sequence of enqueued
dead letters through the given processingTask matching
the sequenceFilter . |
boolean |
InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask) |
Copyright © 2010–2024. All rights reserved.