KubeMQ.QueueAttributes (kubemq v1.0.1)

Server-populated attributes attached to received queue messages.

These attributes are read-only and populated by the KubeMQ server when messages are received. They are not set by the sender.

Fields

timestamp (integer()) — Unix timestamp when the message was enqueued.
sequence (non_neg_integer()) — Monotonic sequence number within the queue.
md5_of_body (String.t()) — MD5 hash of the message body.
receive_count (non_neg_integer()) — Number of times this message has been delivered.
re_routed (boolean()) — Whether this message was re-routed from a dead-letter queue.
re_routed_from_queue (String.t()) — Original queue name if re_routed is true.
expiration_at (integer()) — Unix timestamp when the message will expire.
delayed_to (integer()) — Unix timestamp when the message became available.

Summary

Types

t()

Functions

new(opts \\ [])

Types

t()

@type t() :: %KubeMQ.QueueAttributes{
  delayed_to: integer(),
  expiration_at: integer(),
  md5_of_body: String.t(),
  re_routed: boolean(),
  re_routed_from_queue: String.t(),
  receive_count: non_neg_integer(),
  sequence: non_neg_integer(),
  timestamp: integer()
}

Functions

new(opts \\ [])

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