mq2: 该项目是用于内部系统总线的消息队列，非FIFO，基于 PostgreSQL 的物化队列实现

#MQ2 - 基于PG的物化队列 -- anthony chen

#使用

创建队列 select mq_create_queue('【QUEUE NAME】');
删除队列 select mq_drop_queue('【QUEUE NAME】');
数据入列 select mq_send('【QUEUE NAME】','【JSON STRING】',【 OPTIONAL MSG TYPE ID:bigint】);
数据出列 select mq_recv('【QUEUE NAME】', 【 OPTIONAL NUMBER OF MSG:big int】,【 OPTIONAL MSG TYPE ID:bigint】） number of msg 可以指定一次性出列的数据数量,默认1, msg type id 可以指定只取type id 相同的数据，不设定则取队列中任何type.
数据出列 select mq_recv('【QUEUE NAME】', '【MSG TYPE ID RESULT SET】',【 OPTIONAL MSG TYPE ID:bigint】） RESULT SET可以指定Raw SQL用于限定出列数据的类型范围 number of msg 可以指定一次性出列的数据数量,默认1

宏哥 / mq2