KubeMQ.QueuePolicy (kubemq v1.0.1)

Copy Markdown View Source

Delivery policy for queue messages.

  • expiration_seconds — message expires after N seconds (0 = no expiry)
  • delay_seconds — delay delivery by N seconds (0 = immediate)
  • max_receive_count — max delivery attempts before dead-letter (0 = unlimited)
  • max_receive_queue — dead-letter queue name (required when max_receive_count > 0)

Summary

Types

t()

Functions

new(opts \\ [])

Create a new QueuePolicy struct from keyword options.

Types

t()

@type t() :: %KubeMQ.QueuePolicy{
  delay_seconds: non_neg_integer(),
  expiration_seconds: non_neg_integer(),
  max_receive_count: non_neg_integer(),
  max_receive_queue: String.t()
}

Functions

new(opts \\ [])

@spec new(keyword()) :: t()

Create a new QueuePolicy struct from keyword options.

Options

  • :expiration_seconds — Message expires after N seconds, 0 = no expiry (default: 0)
  • :delay_seconds — Delay delivery by N seconds, 0 = immediate (default: 0)
  • :max_receive_count — Max delivery attempts before dead-letter, 0 = unlimited (default: 0)
  • :max_receive_queue — Dead-letter queue name (required when max_receive_count > 0, default: "")

Examples

iex> policy = KubeMQ.QueuePolicy.new(delay_seconds: 30, expiration_seconds: 300)
iex> policy.delay_seconds
30
iex> policy.max_receive_count
0