DeadLetterPublisher

com.worxbend.cobalt.DeadLetterPublisher

Where a record goes when the consumer gives up on it.

A trait rather than a concrete producer for one reason that matters: this is the only side effect in the batch path that is not the database, and the unit tests of BatchProcessor are exactly the tests that need to assert what was dead-lettered without a broker in the room.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Known subtypes

Members list

Value members

Abstract methods

def close(): Unit
def publish(deadLetter: DeadLetter): Future[Unit]

Publishes one dead letter. The Future fails only if the record could not be made durable — see BatchProcessor for why that failure must not be swallowed.

Publishes one dead letter. The Future fails only if the record could not be made durable — see BatchProcessor for why that failure must not be swallowed.

Attributes