Package com.tnsai.resilience.dlq

Class InMemoryDeadLetterQueue

java.lang.Object

com.tnsai.resilience.dlq.InMemoryDeadLetterQueue

All Implemented Interfaces:

DeadLetterQueue

public final class InMemoryDeadLetterQueue
extends Object
implements DeadLetterQueue

Thread-safe in-memory implementation of DeadLetterQueue. Uses LinkedBlockingDeque for O(1) enqueue and eviction operations.

Constructor Summary

Constructors

Constructor	Description
InMemoryDeadLetterQueue()
InMemoryDeadLetterQueue(int maxEntries)

Method Summary

Modifier and Type	Method	Description
void	enqueue(DeadLetterEntry entry)	Stores a failed entry.
List<DeadLetterEntry>	getEntries()	Returns all entries in the queue.
List<DeadLetterEntry>	getEntries(String operationId)	Returns entries filtered by operation ID.
int	size()	Returns the current entry count.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

InMemoryDeadLetterQueue

public InMemoryDeadLetterQueue()

InMemoryDeadLetterQueue

public InMemoryDeadLetterQueue(int maxEntries)

Method Details

enqueue

public void enqueue(DeadLetterEntry entry)

Description copied from interface: DeadLetterQueue

Stores a failed entry.

Specified by:

enqueue in interface DeadLetterQueue

Parameters:

entry - Entry to store

getEntries

public List<DeadLetterEntry> getEntries()

Description copied from interface: DeadLetterQueue

Returns all entries in the queue.

Specified by:

getEntries in interface DeadLetterQueue

getEntries

public List<DeadLetterEntry> getEntries(String operationId)

Description copied from interface: DeadLetterQueue

Returns entries filtered by operation ID.

Specified by:

getEntries in interface DeadLetterQueue

size

public int size()

Description copied from interface: DeadLetterQueue

Returns the current entry count.

Specified by:

size in interface DeadLetterQueue