otcextensions.sdk.dcs.v1.queue¶
The DMS Queue Class¶
The Queue class inherits from
Resource.
-
class
otcextensions.sdk.dms.v1.queue.Queue(_synchronized=False, connection=None, **attrs)¶ The base resource
- Parameters
_synchronized (bool) – This is not intended to be used directly. See
new()andexisting().connection (openstack.connection.Connection) – Reference to the Connection being used. Defaults to None to allow Resource objects to be used without an active Connection, such as in unit tests. Use of
self._connectionin Resource code should protect itself with a check for None.
-
created¶ Created time Type: int
-
description¶ Description for the queue. The value is a string of a maximum of 160 characters and cannot contain the angle brackets (<>).
-
id¶ Queue Id
-
max_consume_count¶ Max consume count number Type: int Value range: 1–100.
-
name¶ Queue name
-
queue_mode¶ Queue mode: NORMAL: Standard queue, which supports high concurrency performance but cannot guarantee that messages are retrieved in the exact sequence as how they are received. FIFO: First-in-first-out (FIFO) queue, which guarantees that messages are retrieved in the exact sequence as how they are received. KAFKA_HA: High-reliability Kafka queue. All message replicas are flushed to a disk synchronously, ensuring message reliability. KAFKA_HT: High-throughput Kafka queue. All message replicas are flushed to a disk asynchronously, ensuring high performance.
-
redrive_policy¶ Redrive policy. Supported values: enable, disable. Default: disable
-
retention_hours¶ Indicates the hours of storing messages in the Kafka queue. This parameter is valid only when queue_mode is set to KAFKA_HA or KAFKA_HT. Value range: 1–72. Type: int