:DBMS_AQADM

ALTER_QUEUE

ALTER_QUEUE プロシージャを使用して、既存のキューを変更することができます。 プロシージャには次の署名があります。

ALTER_QUEUE(
  max_retries IN NUMBER DEFAULT NULL,
  retry_delay IN NUMBER DEFAULT 0
  retention_time IN NUMBER DEFAULT 0,
  auto_commit IN BOOLEAN DEFAULT TRUE)
  comment IN VARCHAR2 DEFAULT NULL,

パラメーター

例

次のコマンドを使用して、work_order という名前のキューを変更し、retry_delay パラメーターを 5 秒に設定します。

EXEC DBMS_AQADM.ALTER_QUEUE(queue_name => 'work_order', retry_delay => 5);

ALTER_QUEUE_TABLE

ALTER_QUEUE_TABLE プロシージャを使用して、既存のキューテーブルを変更することができます。 プロシージャには次の署名があります。

ALTER_QUEUE_TABLE (
  queue_table IN VARCHAR2,
  comment IN VARCHAR2 DEFAULT NULL,
  primary_instance IN BINARY_INTEGER DEFAULT 0,
  secondary_instance IN BINARY_INTEGER DEFAULT 0,

パラメーター

例

次のコマンドは、work_order_table という名前のキューテーブルを変更するために使用されます。

EXEC DBMS_AQADM.ALTER_QUEUE_TABLE
      (queue_table => 'work_order_table', comment => 'This queue table contains work orders for the shipping department.') ;

キューテーブルの名前は work_order_table です。 このコマンドは、キューテーブルの定義にコメントを追加するために使用されます。

CREATE_QUEUE

CREATE_QUEUE プロシージャを使用して、既存のキューテーブルにキューを作成することができます。 プロシージャには次の署名があります。

CREATE_QUEUE(
  queue_name IN VARCHAR2
  queue_table IN VARCHAR2,
  queue_type IN BINARY_INTEGER DEFAULT NORMAL_QUEUE,
  max_retries IN NUMBER DEFAULT 5,
  retry_delay IN NUMBER DEFAULT 0
  retention_time IN NUMBER DEFAULT 0,
  dependency_tracking IN BOOLEAN DEFAULT FALSE,
  comment IN VARCHAR2 DEFAULT NULL,
  auto_commit IN BOOLEAN DEFAULT TRUE)

パラメーター

例

次の匿名ブロックは、work_order_table テーブルに work_order という名前のキューを作成するために使用されます。

BEGIN
DBMS_AQADM.CREATE_QUEUE ( queue_name => 'work_order', queue_table => 'work_order_table', comment => 'This queue contains pending work orders.') ;
END;

CREATE_QUEUE_TABLE

CREATE_QUEUE_TABLE プロシージャを使用して、キューテーブルを作成することができます。 プロシージャには次の署名があります。

CREATE_QUEUE_TABLE (
  queue_table IN VARCHAR2,
  queue_payload_type IN VARCHAR2,
  storage_clause IN VARCHAR2 DEFAULT NULL,
  sort_list IN VARCHAR2 DEFAULT NULL,
  multiple_consumers IN BOOLEAN DEFAULT FALSE,
  message_grouping IN BINARY_INTEGER DEFAULT NONE,
  comment IN VARCHAR2 DEFAULT NULL,
  auto_commit IN BOOLEAN DEFAULT TRUE,
  primary_instance IN BINARY_INTEGER DEFAULT 0,
  secondary_instance IN BINARY_INTEGER DEFAULT 0,
  compatible IN VARCHAR2 DEFAULT NULL,
  secure IN BOOLEAN DEFAULT FALSE)

パラメーター

例

次の匿名ブロックは、VARCHAR2 名と TEXT プロジェクトの説明を保持する属性を持つ work_order 型を作成するために使用されます。 ブロックはこの型を使用してキューテーブルを作成します。

BEGIN

CREATE TYPE work_order AS (name VARCHAR2, project TEXT, completed BOOLEAN);

EXEC DBMS_AQADM.CREATE_QUEUE_TABLE
      (queue_table => 'work_order_table',
       queue_payload_type => 'work_order',
       comment => 'Work order message queue table');
END;

キューテーブルの名前は work_order_table で、work_order 型のペイロードが含まれています。 これが作業指示メッセージキューテーブルであることを示すコメントが追加されます。

DROP_QUEUE

DROP_QUEUE プロシージャを使用して、キューを削除することができます。 プロシージャには次の署名があります。

DROP_QUEUE(
  queue_name  IN VARCHAR2,
  auto_commit IN BOOLEAN DEFAULT TRUE)

パラメーター

例

次の匿名ブロックは、work_order という名前のキューを削除します。

BEGIN
DBMS_AQADM.DROP_QUEUE(queue_name => 'work_order');
END;

DROP_QUEUE_TABLE

DROP_QUEUE_TABLE プロシージャを使用して、キューテーブルを削除することができます。 プロシージャには次の署名があります。

DROP_QUEUE_TABLE(
  queue_table IN VARCHAR2,
  force IN BOOLEAN default FALSE,
  auto_commit IN BOOLEAN default TRUE)

パラメーター

例

次の匿名ブロックは、work_order_table という名前のテーブルを削除するために使用されます。

BEGIN
   DBMS_AQADM.DROP_QUEUE_TABLE ('work_order_table', force => TRUE);
END;

PURGE_QUEUE_TABLE

PURGE_QUEUE_TABLE プロシージャを使用して、キューテーブルからメッセージを削除することができます。 プロシージャには次の署名があります。

PURGE_QUEUE_TABLE(
  queue_table IN VARCHAR2,
  purge_condition IN VARCHAR2,
  purge_options IN aq$_purge_options_t)

パラメーター

例

次の匿名ブロックは、completed という名前の列の値が YES である work_order_table からメッセージを削除するために使用されます。

DECLARE
   purge_options dbms_aqadm.aq$_purge_options_t;
BEGIN
   dbms_aqadm.purge_queue_table('work_order_table', 'completed = YES', purge_options);
  END;

START_QUEUE

START_QUEUE プロシージャを使用すると、キューをエンキューおよびデキューできるようになります。 プロシージャには次の署名があります。

START_QUEUE(
  queue_name IN VARCHAR2,
  enqueue IN BOOLEAN DEFAULT TRUE,
  dequeue IN BOOLEAN DEFAULT TRUE)

パラメーター

例

次の匿名ブロックは、work_order という名前のキューをエンキューに使用できるようにするために使用されます。

BEGIN
DBMS_AQADM.START_QUEUE
(queue_name => 'work_order);
END;

STOP_QUEUE

STOP_QUEUE プロシージャを使用して、指定したキューのエンキューまたはデキューを無効化することができます。 プロシージャには次の署名があります。

STOP_QUEUE(
  queue_name IN VARCHAR2,
  enqueue IN BOOLEAN DEFAULT TRUE,
  dequeue IN BOOLEAN DEFAULT TRUE,
  wait IN BOOLEAN DEFAULT TRUE)

パラメーター

例

次の匿名ブロックを使用して、work_order という名前のキューへのエンキューとデキューを無効にします。

BEGIN
DBMS_AQADM.STOP_QUEUE(queue_name =>'work_order', enqueue=>TRUE, dequeue=>TRUE, wait=>TRUE);
END;

未処理のトランザクションがすべて完了すると、エンキューとデキューが停止します。