diff options
| author | Marko Kreen | 2010-10-25 10:25:03 +0000 |
|---|---|---|
| committer | Marko Kreen | 2010-10-25 10:25:03 +0000 |
| commit | 27617c203766fee1619561145207c4dcbbbd9c11 (patch) | |
| tree | 74ce11967344e950883ef90be8f3fcf5f94be2d8 /sql/pgq/expected | |
| parent | 2bc7573ff8eea6ee677424c0e100ac574d393b18 (diff) | |
Fix pgq.next_batch_custom()
Seems it was broken in some reorg.
Diffstat (limited to 'sql/pgq/expected')
| -rw-r--r-- | sql/pgq/expected/pgq_core.out | 18 |
1 files changed, 18 insertions, 0 deletions
diff --git a/sql/pgq/expected/pgq_core.out b/sql/pgq/expected/pgq_core.out index 31ecd02f..976726d2 100644 --- a/sql/pgq/expected/pgq_core.out +++ b/sql/pgq/expected/pgq_core.out @@ -173,6 +173,24 @@ select pgq.ticker(); 1 (1 row) +select * from pgq.next_batch_custom('myqueue', 'consumer', '1 hour', null, null); + batch_id | cur_tick_id | prev_tick_id | cur_tick_time | prev_tick_time | cur_tick_event_seq | prev_tick_event_seq +----------+-------------+--------------+---------------+----------------+--------------------+--------------------- + | | | | | | +(1 row) + +select * from pgq.next_batch_custom('myqueue', 'consumer', null, 10000, null); + batch_id | cur_tick_id | prev_tick_id | cur_tick_time | prev_tick_time | cur_tick_event_seq | prev_tick_event_seq +----------+-------------+--------------+---------------+----------------+--------------------+--------------------- + | | | | | | +(1 row) + +select * from pgq.next_batch_custom('myqueue', 'consumer', null, null, '10 minutes'); + batch_id | cur_tick_id | prev_tick_id | cur_tick_time | prev_tick_time | cur_tick_event_seq | prev_tick_event_seq +----------+-------------+--------------+---------------+----------------+--------------------+--------------------- + | | | | | | +(1 row) + select pgq.next_batch('myqueue', 'consumer'); next_batch ------------ |