diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2015-01-27 11:58:16 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2015-01-27 11:58:16 +0000 |
| commit | a9d34ca8112b9022a523cb0eaa3d5c701578bc68 (patch) | |
| tree | ef71117db0637809d05d07db6132b8258209702b /test | |
| parent | 3a0e16bbc9ba25c7edb43d11de5d721ca590db4b (diff) | |
| parent | 5ade32876106ec6335400759f619627430886d4f (diff) | |
| download | rabbitmq-server-git-a9d34ca8112b9022a523cb0eaa3d5c701578bc68.tar.gz | |
Merge bug25430
Diffstat (limited to 'test')
| -rw-r--r-- | test/src/rabbit_tests.erl | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/src/rabbit_tests.erl b/test/src/rabbit_tests.erl index f19c361e94..c26dcf32aa 100644 --- a/test/src/rabbit_tests.erl +++ b/test/src/rabbit_tests.erl @@ -2262,7 +2262,7 @@ queue_index_publish(SeqIds, Persistent, Qi) -> MsgId = rabbit_guid:gen(), QiM = rabbit_queue_index:publish( MsgId, SeqId, #message_properties{size = 10}, - Persistent, QiN), + Persistent, infinity, QiN), ok = rabbit_msg_store:write(MsgId, MsgId, MSCState), {QiM, [{SeqId, MsgId} | SeqIdsMsgIdsAcc]} end, {Qi, []}, SeqIds), @@ -2285,7 +2285,8 @@ test_queue_index_props() -> fun(Qi0) -> MsgId = rabbit_guid:gen(), Props = #message_properties{expiry=12345, size = 10}, - Qi1 = rabbit_queue_index:publish(MsgId, 1, Props, true, Qi0), + Qi1 = rabbit_queue_index:publish( + MsgId, 1, Props, true, infinity, Qi0), {[{MsgId, 1, Props, _, _}], Qi2} = rabbit_queue_index:read(1, 2, Qi1), Qi2 |