Modifier and Type | Method and Description |
---|---|
boolean |
DeadLetteringEventHandlerInvoker.process(Predicate<DeadLetter<? extends EventMessage<?>>> sequenceFilter) |
Modifier and Type | Class and Description |
---|---|
class |
JdbcDeadLetter<E extends EventMessage<?>>
A
DeadLetter that was saved to a JDBC-backed database and reconstructed from it. |
Modifier and Type | Method and Description |
---|---|
DeadLetter<E> |
JdbcDeadLetter.markTouched() |
DeadLetter<E> |
JdbcDeadLetter.withCause(Throwable requeueCause) |
DeadLetter<E> |
JdbcDeadLetter.withDiagnostics(MetaData diagnostics) |
Modifier and Type | Method and Description |
---|---|
Iterable<Iterable<DeadLetter<? extends E>>> |
JdbcSequencedDeadLetterQueue.deadLetters() |
Iterable<DeadLetter<? extends E>> |
JdbcSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier,
DeadLetter<? extends E> letter) |
PreparedStatement |
DefaultDeadLetterStatementFactory.enqueueStatement(Connection connection,
String processingGroup,
String sequenceIdentifier,
DeadLetter<? extends E> letter,
long sequenceIndex) |
PreparedStatement |
DeadLetterStatementFactory.enqueueStatement(Connection connection,
String processingGroup,
String sequenceIdentifier,
DeadLetter<? extends E> letter,
long sequenceIndex)
Constructs the
PreparedStatement used for the
JdbcSequencedDeadLetterQueue.enqueue(Object, DeadLetter) operation. |
void |
JdbcSequencedDeadLetterQueue.evict(DeadLetter<? extends E> letter) |
void |
JdbcSequencedDeadLetterQueue.requeue(DeadLetter<? extends E> letter,
UnaryOperator<DeadLetter<? extends E>> letterUpdater) |
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) |
boolean |
JdbcSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends E>> sequenceFilter,
Function<DeadLetter<? extends E>,EnqueueDecision<E>> processingTask) |
void |
JdbcSequencedDeadLetterQueue.requeue(DeadLetter<? extends E> letter,
UnaryOperator<DeadLetter<? extends E>> letterUpdater) |
Modifier and Type | Method and Description |
---|---|
DeadLetter<M> |
JpaDeadLetter.markTouched() |
DeadLetter<M> |
JpaDeadLetter.withCause(Throwable requeueCause) |
DeadLetter<M> |
JpaDeadLetter.withDiagnostics(MetaData diagnostics) |
Modifier and Type | Method and Description |
---|---|
Iterable<Iterable<DeadLetter<? extends M>>> |
JpaSequencedDeadLetterQueue.deadLetters() |
Iterable<DeadLetter<? extends M>> |
JpaSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
JpaSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier,
DeadLetter<? extends M> letter) |
void |
JpaSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter) |
void |
JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater) |
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) |
boolean |
JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask) |
void |
JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater) |
Modifier and Type | Class and Description |
---|---|
class |
JpaDeadLetter<M extends EventMessage<?>>
Deprecated.
in favor of using
JpaDeadLetter which moved to
jakarta. |
Modifier and Type | Method and Description |
---|---|
DeadLetter<M> |
JpaDeadLetter.markTouched()
Deprecated.
|
DeadLetter<M> |
JpaDeadLetter.withCause(Throwable requeueCause)
Deprecated.
|
DeadLetter<M> |
JpaDeadLetter.withDiagnostics(MetaData diagnostics)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Iterable<Iterable<DeadLetter<? extends M>>> |
JpaSequencedDeadLetterQueue.deadLetters()
Deprecated.
|
Iterable<DeadLetter<? extends M>> |
JpaSequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
JpaSequencedDeadLetterQueue.enqueue(Object sequenceIdentifier,
DeadLetter<? extends M> letter)
Deprecated.
|
void |
JpaSequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter)
Deprecated.
|
void |
JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater)
Deprecated.
|
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.
|
boolean |
JpaSequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
Deprecated.
|
void |
JpaSequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericDeadLetter<M extends Message<?>>
Generic implementation of the
dead letter allowing any type of Message to be dead
lettered. |
Modifier and Type | Method and Description |
---|---|
DeadLetter<M> |
GenericDeadLetter.markTouched() |
DeadLetter<M> |
DeadLetter.markTouched()
Construct a copy of this
DeadLetter , replacing the lastTouched() with the current time. |
DeadLetter<M> |
GenericDeadLetter.withCause(Throwable requeueCause) |
DeadLetter<M> |
DeadLetter.withCause(Throwable requeueCause)
|
DeadLetter<? extends M> |
ShouldEnqueue.withDiagnostics(DeadLetter<? extends M> letter) |
default DeadLetter<? extends M> |
EnqueueDecision.withDiagnostics(DeadLetter<? extends M> letter)
|
DeadLetter<M> |
GenericDeadLetter.withDiagnostics(MetaData diagnostics) |
DeadLetter<M> |
DeadLetter.withDiagnostics(MetaData diagnostics)
|
default DeadLetter<M> |
DeadLetter.withDiagnostics(UnaryOperator<MetaData> diagnosticsBuilder)
Construct a copy of this
DeadLetter , replacing the diagnostics() with the result of
the given diagnosticsBuilder . |
Modifier and Type | Method and Description |
---|---|
ParameterResolver<DeadLetter<?>> |
DeadLetterParameterResolverFactory.createInstance(Executable executable,
Parameter[] parameters,
int parameterIndex) |
Iterable<Iterable<DeadLetter<? extends M>>> |
SequencedDeadLetterQueue.deadLetters()
Return all
dead letter sequences held by this queue. |
Iterable<Iterable<DeadLetter<? extends M>>> |
InMemorySequencedDeadLetterQueue.deadLetters() |
Iterable<DeadLetter<? extends M>> |
SequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier)
Return all the
dead letters for the given sequenceIdentifier in insert order. |
Iterable<DeadLetter<? extends M>> |
InMemorySequencedDeadLetterQueue.deadLetterSequence(Object sequenceIdentifier) |
Modifier and Type | Method and Description |
---|---|
EnqueueDecision<M> |
EnqueuePolicy.decide(DeadLetter<? extends M> letter,
Throwable cause)
|
void |
SequencedDeadLetterQueue.enqueue(Object sequenceIdentifier,
DeadLetter<? extends M> letter)
Enqueues a
dead letter containing an implementation of M to this queue. |
void |
InMemorySequencedDeadLetterQueue.enqueue(Object sequenceIdentifier,
DeadLetter<? extends M> letter) |
void |
SequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter)
Evict the given
letter from this queue. |
void |
InMemorySequencedDeadLetterQueue.evict(DeadLetter<? extends M> letter) |
void |
SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater)
Reenters the given
letter , updating the contents with the letterUpdater . |
void |
InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater) |
DeadLetter<? extends M> |
ShouldEnqueue.withDiagnostics(DeadLetter<? extends M> letter) |
default DeadLetter<? extends M> |
EnqueueDecision.withDiagnostics(DeadLetter<? extends M> letter)
|
Modifier and Type | Method and Description |
---|---|
static <M extends Message<?>> |
Decisions.enqueue(Throwable enqueueCause,
Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder)
Construct a
ShouldEnqueue defining that a dead letter should be enqueued because of
the given enqueueCause . |
default boolean |
SequencedDeadLetterQueue.enqueueIfPresent(Object sequenceIdentifier,
Supplier<DeadLetter<? extends M>> letterBuilder)
Enqueue the result of the given
letterBuilder only if there already are other
dead letters with the same sequenceIdentifier present in this queue. |
default boolean |
SequencedDeadLetterQueue.process(Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask)
Process a sequence of enqueued
dead letters with the given processingTask . |
boolean |
SequencedDeadLetterProcessor.process(Predicate<DeadLetter<? extends M>> sequenceFilter)
Process a sequence of
dead letters matching the given sequenceFilter . |
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 |
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) |
boolean |
InMemorySequencedDeadLetterQueue.process(Predicate<DeadLetter<? extends M>> sequenceFilter,
Function<DeadLetter<? extends M>,EnqueueDecision<M>> processingTask) |
void |
SequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater)
Reenters the given
letter , updating the contents with the letterUpdater . |
void |
InMemorySequencedDeadLetterQueue.requeue(DeadLetter<? extends M> letter,
UnaryOperator<DeadLetter<? extends M>> letterUpdater) |
static <M extends Message<?>> |
Decisions.requeue(Throwable requeueCause,
Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder)
Construct a
ShouldEnqueue defining that a dead letter should be requeued because of
the given requeueCause . |
Constructor and Description |
---|
ShouldEnqueue(Throwable enqueueCause,
Function<DeadLetter<? extends M>,MetaData> diagnosticsBuilder)
Constructs a default
EnqueueDecision to enqueue using the given enqueueCause as the
ShouldEnqueue.enqueueCause() . |
Copyright © 2010–2024. All rights reserved.