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

Package-level declarations

Types

object ExchangeAck

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

MessageExchange

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

RetryableFilter

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

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

Properties

COMMAND_RESULT_KEY

const val COMMAND_RESULT_KEY: String

DEFAULT_RETRY_SPEC

val DEFAULT_RETRY_SPEC: RetryBackoffSpec

const val ERROR_KEY: String

const val FUNCTION_KEY: String

SERVICE_PROVIDER_KEY

const val SERVICE_PROVIDER_KEY: String

Functions

fun retryStrategy(maxAttempts: Long = MAX_RETRIES, minBackoff: Duration = MIN_BACKOFF, logger: KLogger): Retry