初识AQ
[@more@]实现了以下内容
/** 存储过程描述
WW_AQ_ENQ 消息入队
WW_AQ_DEQ 提取消息
WW_AQ_ENQ2 以不同的优先级入队
WW_AQ_DEQ2 提取有优先级的消息
WW_AQ_ENQ3 建立6个消息并入队
WW_AQ_DEQ31 指定消息出队模式为browse 直接提取指定msgid的消息
WW_AQ_DEQ32 在locked模式下检索blue,然后删除blue消息
WW_AQ_ENQ4 对于消息延迟和过期的处理
WW_AQ_ADD_SUBSCRIBER 增加订阅者
W_AQ_RECIPIENTS message1入队,提供给订阅者,message2入队,重新定义接收者
W_AQ_RECIPIENTS_DEQ 根据不同接收者接收消息
W_AQ_RECIPIENTS_DEQ_BLUE blue接收消息
W_AQ_RECIPIENTS_DEQ_RED red接收消息
w_aq_group_enq 大循环三次,对应三个事务;小循环三次,对应每个事务有三个消息
w_aq_group_deq 分事务(组)取出消息
w_aq_listener 添加两个用户来监听msg_queue_multiple中的消息
w_aq_register 注册一个过程来处理接收的消息
aa 回调的存储过程
*/
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/271063/viewspace-898188/ ,如需转载,请注明出处,否则将追究法律责任。