File tree Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Expand file tree Collapse file tree 1 file changed +29
-0
lines changed Original file line number Diff line number Diff line change @@ -242,6 +242,35 @@ def test_read_with_poll_with_empty_queue(pgmq_setup_teardown: PGMQ_WITH_QUEUE):
242242 assert duration > 1.9
243243
244244
245+ def test_set_vt (pgmq_setup_teardown : PGMQ_WITH_QUEUE ):
246+ pgmq , queue_name = pgmq_setup_teardown
247+ msg = MSG
248+ msg_id = pgmq .send (queue_name , msg )
249+ msg_read = pgmq .set_vt (queue_name , msg_id , 2 )
250+ assert msg is not None
251+ assert pgmq .read (queue_name ) is None
252+ time .sleep (1.5 )
253+ assert pgmq .read (queue_name ) is None
254+ time .sleep (0.6 )
255+ msg_read = pgmq .read (queue_name )
256+ assert msg_read .message == msg
257+
258+
259+ def test_set_vt_to_smaller_value (pgmq_setup_teardown : PGMQ_WITH_QUEUE ):
260+ pgmq , queue_name = pgmq_setup_teardown
261+ msg = MSG
262+ msg_id = pgmq .send (queue_name , msg )
263+ _ = pgmq .read (queue_name , vt = 5 ) # set vt to 5 seconds
264+ assert msg is not None
265+ assert pgmq .read (queue_name ) is None
266+ time .sleep (0.5 )
267+ assert pgmq .set_vt (queue_name , msg_id , 1 ) is not None
268+ time .sleep (0.3 )
269+ assert pgmq .read (queue_name ) is None
270+ time .sleep (0.8 )
271+ assert pgmq .read (queue_name ) is not None
272+
273+
245274def test_pop (pgmq_setup_teardown : PGMQ_WITH_QUEUE ):
246275 pgmq , queue_name = pgmq_setup_teardown
247276 msg = MSG
You can’t perform that action at this time.
0 commit comments