diff options
| author | Michael Klishin <michael@clojurewerkz.org> | 2017-11-03 13:49:50 +0200 |
|---|---|---|
| committer | Michael Klishin <michael@clojurewerkz.org> | 2017-11-03 13:49:50 +0200 |
| commit | 9257d5e7b53ed3bb65dee09d42e3f570e090b55a (patch) | |
| tree | 273897f05f06c93d264fdcfe1b7020c682c6498f /test | |
| parent | da2b0ccda34e85048b35d2633836d2ec708dd488 (diff) | |
| parent | e811e30fff3ff9170c8103d100e24b4c0469f5ff (diff) | |
| download | rabbitmq-server-git-9257d5e7b53ed3bb65dee09d42e3f570e090b55a.tar.gz | |
Merge branch 'master' into rabbitmq-server-995
Diffstat (limited to 'test')
| -rw-r--r-- | test/channel_operation_timeout_test_queue.erl | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/test/channel_operation_timeout_test_queue.erl b/test/channel_operation_timeout_test_queue.erl index 247477bf40..59de0cb5c7 100644 --- a/test/channel_operation_timeout_test_queue.erl +++ b/test/channel_operation_timeout_test_queue.erl @@ -26,8 +26,7 @@ set_ram_duration_target/2, ram_duration/1, needs_timeout/1, timeout/1, handle_pre_hibernate/1, resume/1, msg_rates/1, info/2, invoke/3, is_duplicate/2, set_queue_mode/2, - zip_msgs_and_acks/4]). --export([start/2, stop/1]). + start/2, stop/1, zip_msgs_and_acks/4, handle_info/2]). %%---------------------------------------------------------------------------- %% This test backing queue follows the variable queue implementation, with @@ -91,7 +90,8 @@ memory_reduction_run_count, %% Queue data is grouped by VHost. We need to store it %% to work with queue index. - virtual_host + virtual_host, + waiting_bump = false }). -record(rates, { in, out, ack_in, ack_out, timestamp }). @@ -285,6 +285,9 @@ timeout(State) -> handle_pre_hibernate(State) -> rabbit_variable_queue:handle_pre_hibernate(State). +handle_info(Msg, State) -> + rabbit_variable_queue:handle_info(Msg, State). + resume(State) -> rabbit_variable_queue:resume(State). msg_rates(State) -> |