wow-core/me.ahoo.wow.messaging.handler

Package-level declarations

Types

object ExchangeAck

Utilities for acknowledging message exchanges.

fun interface ExchangeFilter<T : MessageExchange<*, *>> : Filter<T>

A filter for processing message exchanges in a filter chain.

MessageExchange

interface MessageExchange<SOURCE : MessageExchange<SOURCE, M>, out M : Message<*, *>> : ErrorAccessor, CommandResultAccessor

RetryableFilter

@Order(before = [DomainEventFunctionFilter::class, SnapshotFunctionFilter::class])

class RetryableFilter<T : MessageExchange<*, *>>(retrySpec: Retry = DEFAULT_RETRY_SPEC) : ExchangeFilter<T>

Filter that retries message processing for recoverable errors.

Properties

COMMAND_RESULT_KEY

const val COMMAND_RESULT_KEY: String

DEFAULT_RETRY_SPEC

val DEFAULT_RETRY_SPEC: RetryBackoffSpec

Default retry specification for recoverable errors.

const val ERROR_KEY: String

const val FUNCTION_KEY: String

SERVICE_PROVIDER_KEY

const val SERVICE_PROVIDER_KEY: String

Functions

acknowledgementWithheldBy

@InternalWowApi

fun MessageExchange<*, *>.acknowledgementWithheldBy(): String?

Who withheld the acknowledgement of this exchange (withholdAcknowledgement), or null.

isAcknowledgementWithheld

@InternalWowApi

fun MessageExchange<*, *>.isAcknowledgementWithheld(): Boolean

Whether withholdAcknowledgement was called on this exchange.

withholdAcknowledgement

@InternalWowApi

fun MessageExchange<*, *>.withholdAcknowledgement(withheldBy: String = getFunction()?.let { "${it.processorName}.${it.name}" } ?: "unknown")

Leaves this exchange unacknowledged when its processing ends, so a bus that redelivers unacknowledged messages delivers it again. For a processing failure that was neither handled nor durably recorded, for example when recording an event-processing failure for compensation fails.