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 | cf028199e51f42eba2835fe8025a05076617d239 (patch) | |
| tree | cf0a78ec7f33d387749e24a9997323bf637d3fe3 | |
| parent | e2c57c78fcc0281eeb78dd1914287e539265244c (diff) | |
| download | rabbitmq-server-bug24313.tar.gz | |
Use acceptable message expiry valuebug24313
| -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 d358a041..22691ef9 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 |