diff options
| author | Luke Bakken <lbakken@pivotal.io> | 2017-10-12 06:20:44 -0700 |
|---|---|---|
| committer | Luke Bakken <lbakken@pivotal.io> | 2017-11-02 07:49:42 -0700 |
| commit | dff1d2072279ae5fbf237af9073cddee4fcdcb88 (patch) | |
| tree | 3e4ea839f6d80e22f8cda8f05948a4169a7f4353 /test | |
| parent | 27bf1d6869cba44122e595655a5c0d612152a3f4 (diff) | |
| download | rabbitmq-server-git-dff1d2072279ae5fbf237af9073cddee4fcdcb88.tar.gz | |
Use rabbit_queue_behaviour and callback
Alternative for #1388 that does not use process dictionary.
Requires rabbitmq/rabbitmq-common#228
Fix waiting_bump values
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) -> |