diff options
| author | Emile Joubert <emile@rabbitmq.com> | 2011-08-02 13:33:42 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@rabbitmq.com> | 2011-08-02 13:33:42 +0100 |
| commit | 71514c3b6b51cf1e39941dc107cb7eb534b5f89b (patch) | |
| tree | cf0a78ec7f33d387749e24a9997323bf637d3fe3 | |
| parent | d3509448afcd1f6f0783c13bc877560b43c9b5f5 (diff) | |
| download | rabbitmq-server-git-71514c3b6b51cf1e39941dc107cb7eb534b5f89b.tar.gz | |
Use acceptable message expiry value
| -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 d358a041ef..22691ef9d3 100644 --- a/src/rabbit_backing_queue_qc.erl +++ b/src/rabbit_backing_queue_qc.erl @@ -106,7 +106,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}) -> @@ -375,7 +375,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 queue:out(Messages) of |