diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-09-26 21:37:25 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-09-26 21:37:25 +0100 |
| commit | a61f1f416d4ac032f68de25757f924e7e1664a72 (patch) | |
| tree | 03bdd8658674c92321e355c261e7d5414648dbeb /src/rabbit_backing_queue_qc.erl | |
| parent | 8e975df2bcace8b4fe31bfe144e45e3e928cb944 (diff) | |
| parent | bc314f07b6059e8e4344ccac34a82d04dd1d1650 (diff) | |
| download | rabbitmq-server-a61f1f416d4ac032f68de25757f924e7e1664a72.tar.gz | |
Merged default into bug23764
Diffstat (limited to 'src/rabbit_backing_queue_qc.erl')
| -rw-r--r-- | src/rabbit_backing_queue_qc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_backing_queue_qc.erl b/src/rabbit_backing_queue_qc.erl index 1203fb45..586ab6c7 100644 --- a/src/rabbit_backing_queue_qc.erl +++ b/src/rabbit_backing_queue_qc.erl @@ -108,7 +108,7 @@ qc_publish(#state{bqstate = BQ}) -> [qc_message(), #message_properties{needs_confirming = frequency([{1, true}, {20, false}]), - expiry = choose(0, 10)}, + expiry = oneof([undefined | lists:seq(1, 10)])}, self(), BQ]}. qc_publish_multiple(#state{bqstate = BQ}) -> @@ -386,7 +386,7 @@ rand_choice(List) -> [lists:nth(random:uniform(length(List)), List)]. dropfun(Props) -> Expiry = eval({call, erlang, element, [?RECORD_INDEX(expiry, message_properties), Props]}), - Expiry =/= 0. + Expiry =/= 1. drop_messages(Messages) -> case gb_trees:is_empty(Messages) of |