Oracle高级队列(Advanced Queue)简单实例

Oracle高级队列(Advanced Queue)简单实例

最简单的高级队列的练习,基本上都使用了默认参数。

-- Create Type
create or replace type note as Object(
 subject varchar2(100),
 Content varchar2(2000),CreateTime date
);

-- Create queue table
begin
 sys.dbms_aqadm.create_queue_table(
  queue_table => 'NOTETAB',
  queue_payload_type => 'TEST.NOTE'
end;

--create queue
begin
 sys.dbms_aqadm.create_queue(
  queue_name => 'NOTEQ',
  queue_table => 'NOTETAB',
  queue_type => sys.dbms_aqadm.normal_queue,
  max_retries => 5,
  retry_delay => 0,
  retention_time => 0);
end;

--enqueue
declare
v_Message note;
v_MsgId RAW(16);
v_options DBMS_AQ.ENQUEUE_OPTIONS_T;
v_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
v_Recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;
begin
   v_Message:=note(subject => 'note3',Content => 'content3',createTime => sysdate);

--   v_Recipients(0) := sys.aq$_agent('NOTE','MTQ',0);
--   v_properties.recipient_list := v_Recipients;
   v_options.visibility :=DBMS_AQ.IMMEDIATE;
   dbms_aq.enqueue(queue_name => 'noteq',enqueue_options => v_options,message_properties => v_properties,payload => v_Message,msgid => v_MsgId);
   dbms_output.put_line('encode success,msgid is '||v_MsgId);

end;

--dequeue
declare
v_Message note;
v_MsgId RAW(16);
v_options DBMS_AQ.DEQUEUE_OPTIONS_T;
v_properties DBMS_AQ.MESSAGE_PROPERTIES_T;
v_Recipients DBMS_AQ.AQ$_RECIPIENT_LIST_T;
begin

--   v_Recipients(0) := sys.aq$_agent('NOTE','MTQ',0);
--   v_properties.recipient_list := v_Recipients;
   v_options.visibility :=DBMS_AQ.IMMEDIATE;
   dbms_aq.dequeue(queue_name => 'noteq',dequeue_options => v_options,message_properties => v_properties,payload => v_Message,msgid => v_MsgId);
   dbms_output.put_line('decode success,msgid is '||v_MsgId);
   dbms_output.put_line('subject is '||v_Message.subject);
   dbms_output.put_line('Content is '||v_Message.Content);
   dbms_output.put_line('createTime is '||to_char(v_Message.createTime,'yyyy-mm-dd hh24:mi:ss'));
end;

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!

(0)

相关推荐

  • Oracle高级队列(Advanced Queue)简单实例

    Oracle高级队列(Advanced Queue)简单实例 最简单的高级队列的练习,基本上都使用了默认参数. -- Create Type create or replace type note as Object( subject varchar2(100), Content varchar2(2000),CreateTime date ); -- Create queue table begin sys.dbms_aqadm.create_queue_table( queue_table

  • java队列之queue用法实例分析

    Queue: 基本上,一个队列就是一个先入先出(FIFO)的数据结构 Queue接口与List.Set同一级别,都是继承了Collection接口.LinkedList实现了Deque接 口. Queue的实现 1.没有实现的阻塞接口的LinkedList: 实现了java.util.Queue接口和java.util.AbstractQueue接口 内置的不阻塞队列: PriorityQueue 和 ConcurrentLinkedQueue PriorityQueue 和 Concurren

  • C#内置队列类Queue用法实例

    本文实例讲述了C#内置队列类Queue用法.分享给大家供大家参考.具体分析如下: 这里详细演示了C#内置的队列如何进行添加,移除等功能. using System; using System.Collections.Generic; class Example { public static void Main() { Queue<string> numbers = new Queue<string>(); numbers.Enqueue("one"); num

  • C#栈和队列的简介,算法与应用简单实例

    堆栈(Stack) 代表了一个后进先出的对象集合.当您需要对各项进行后进先出的访问时,则使用堆栈.当您在列表中添加一项,称为推入元素,当您从列表中移除一项时,称为弹出元素. 常用方法: 1 public virtual void Clear(); 从 Stack 中移除所有的元素. 2 public virtual bool Contains( object obj ); 判断某个元素是否在 Stack 中. 3 public virtual object Peek(); 返回在 Stack 的

  • Java 队列 Queue 用法实例详解

    队列是一种特殊的线性表,它只允许在表的前端进行删除操作,而在表的后端进行插入操作. LinkedList类实现了Queue接口,因此我们可以把LinkedList当成Queue来用. 以下实例演示了队列(Queue)的用法: /* author by w3cschool.cc Main.java */ import java.util.LinkedList; import java.util.Queue; public class Main { public static void main(S

  • C#队列Queue用法实例分析

    本文实例分析了C#队列Queue用法.分享给大家供大家参考.具体分析如下: 队列(Queue)在程序设计中扮演着重要的角色,因为它可以模拟队列的数据操作.例如,排队买票就是一个队列操作,后来的人排在后面,先来的人排在前面,并且买票请求先被处理.为了模拟队列的操作,Queue在ArrayList的基础上加入了以下限制 1.元素采用先入先出机制(FIFO,First In First Out),即先进入队列的元素必须先离开队列.最先进入的元素称为队头元素. 元素只能被添加到队尾(称为入队),不允许在

  • Java  队列 Queue 用法实例详解

    队列是一种特殊的线性表,它只允许在表的前端进行删除操作,而在表的后端进行插入操作. LinkedList类实现了Queue接口,因此我们可以把LinkedList当成Queue来用. 以下实例演示了队列(Queue)的用法: /* author by w3cschool.cc Main.java */ import java.util.LinkedList; import java.util.Queue; public class Main { public static void main(S

  • Java延迟队列原理与用法实例详解

    本文实例讲述了Java延迟队列原理与用法.分享给大家供大家参考,具体如下: 延时队列,第一他是个队列,所以具有对列功能第二就是延时,这就是延时对列,功能也就是将任务放在该延时对列中,只有到了延时时刻才能从该延时对列中获取任务否则获取不到-- 应用场景比较多,比如延时1分钟发短信,延时1分钟再次执行等,下面先看看延时队列demo之后再看延时队列在项目中的使用: 简单的延时队列要有三部分:第一实现了Delayed接口的消息体.第二消费消息的消费者.第三存放消息的延时队列,那下面就来看看延时队列dem

  • jsp登录页面的简单实例 雏形

    jsp登录页面的简单实例 雏形 <%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%> <!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.d

  • python 队列详解及实例代码

    队列特性:先进先出(FIFO)--先进队列的元素先出队列.来源于我们生活中的队列(先排队的先办完事). Queue模块最常与threading模块一起构成生产-消费者模型,提供了一个适用于多线程编程的先进先出的数据结构,即队列. 该模块源码中包含5个类: 其中,Empty和Full是两个异常类,当队列的Queue.get(block=0)或者调用get_nowait()时,如果队列为空,则抛EmptyException异常. 同理,当队列的Queue.put(block=0)或者调用put_no

随机推荐