Skip to content

Commit 11002ab

Browse files
noxdafoxnoxdafox
committed
Merge branch 'master' of github.com:rabbitmq/rabbitmq-server
2 parents eb1b636 + 0c7c7d9 commit 11002ab

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

47 files changed

+6699
-423
lines changed

‎Makefile

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -96,6 +96,8 @@ define PROJECT_ENV
9696
%% see rabbitmq-server#143,
9797
%% rabbitmq-server#949, rabbitmq-server#1098
9898
{credit_flow_default_credit, {400, 200}},
99+
{quorum_commands_soft_limit, 256},
100+
{quorum_cluster_size, 5},
99101
%% see rabbitmq-server#248
100102
%% and rabbitmq-server#667
101103
{channel_operation_timeout, 15000},
@@ -127,13 +129,14 @@ define PROJECT_ENV
127129
%% vhost had to shut down, see server#1158 and server#1280
128130
{vhost_restart_strategy, continue},
129131
%% {global, prefetch count}
130-
{default_consumer_prefetch, {false, 0}}
132+
{default_consumer_prefetch, {false, 0}},
133+
{channel_queue_cleanup_interval, 60000}
131134
]
132135
endef
133136

134137
LOCAL_DEPS = sasl mnesia os_mon inets
135138
BUILD_DEPS = rabbitmq_cli syslog
136-
DEPS = ranch lager rabbit_common
139+
DEPS = ranch lager rabbit_common ra
137140
TEST_DEPS = rabbitmq_ct_helpers rabbitmq_ct_client_helpers amqp_client meck proper
138141

139142
dep_syslog = git https://github.com/schlagert/syslog 3.4.5

‎docs/rabbitmq.conf.example

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -78,6 +78,46 @@
7878
# ssl_options.cacertfile = /path/to/cacert.pem
7979
# ssl_options.certfile = /path/to/cert.pem
8080
# ssl_options.keyfile = /path/to/key.pem
81+
#
82+
# ssl_options.honor_cipher_order = true
83+
# ssl_options.honor_ecc_order = true
84+
85+
# ssl_options.ciphers.1 = ECDHE-ECDSA-AES256-GCM-SHA384
86+
# ssl_options.ciphers.2 = ECDHE-RSA-AES256-GCM-SHA384
87+
# ssl_options.ciphers.3 = ECDHE-ECDSA-AES256-SHA384
88+
# ssl_options.ciphers.4 = ECDHE-RSA-AES256-SHA384
89+
# ssl_options.ciphers.5 = ECDH-ECDSA-AES256-GCM-SHA384
90+
# ssl_options.ciphers.6 = ECDH-RSA-AES256-GCM-SHA384
91+
# ssl_options.ciphers.7 = ECDH-ECDSA-AES256-SHA384
92+
# ssl_options.ciphers.8 = ECDH-RSA-AES256-SHA384
93+
# ssl_options.ciphers.9 = DHE-RSA-AES256-GCM-SHA384
94+
# ssl_options.ciphers.10 = DHE-DSS-AES256-GCM-SHA384
95+
# ssl_options.ciphers.11 = DHE-RSA-AES256-SHA256
96+
# ssl_options.ciphers.12 = DHE-DSS-AES256-SHA256
97+
# ssl_options.ciphers.13 = ECDHE-ECDSA-AES128-GCM-SHA256
98+
# ssl_options.ciphers.14 = ECDHE-RSA-AES128-GCM-SHA256
99+
# ssl_options.ciphers.15 = ECDHE-ECDSA-AES128-SHA256
100+
# ssl_options.ciphers.16 = ECDHE-RSA-AES128-SHA256
101+
# ssl_options.ciphers.17 = ECDH-ECDSA-AES128-GCM-SHA256
102+
# ssl_options.ciphers.18 = ECDH-RSA-AES128-GCM-SHA256
103+
# ssl_options.ciphers.19 = ECDH-ECDSA-AES128-SHA256
104+
# ssl_options.ciphers.20 = ECDH-RSA-AES128-SHA256
105+
# ssl_options.ciphers.21 = DHE-RSA-AES128-GCM-SHA256
106+
# ssl_options.ciphers.22 = DHE-DSS-AES128-GCM-SHA256
107+
# ssl_options.ciphers.23 = DHE-RSA-AES128-SHA256
108+
# ssl_options.ciphers.24 = DHE-DSS-AES128-SHA256
109+
# ssl_options.ciphers.25 = ECDHE-ECDSA-AES256-SHA
110+
# ssl_options.ciphers.26 = ECDHE-RSA-AES256-SHA
111+
# ssl_options.ciphers.27 = DHE-RSA-AES256-SHA
112+
# ssl_options.ciphers.28 = DHE-DSS-AES256-SHA
113+
# ssl_options.ciphers.29 = ECDH-ECDSA-AES256-SHA
114+
# ssl_options.ciphers.30 = ECDH-RSA-AES256-SHA
115+
# ssl_options.ciphers.31 = ECDHE-ECDSA-AES128-SHA
116+
# ssl_options.ciphers.32 = ECDHE-RSA-AES128-SHA
117+
# ssl_options.ciphers.33 = DHE-RSA-AES128-SHA
118+
# ssl_options.ciphers.34 = DHE-DSS-AES128-SHA
119+
# ssl_options.ciphers.35 = ECDH-ECDSA-AES128-SHA
120+
# ssl_options.ciphers.36 = ECDH-RSA-AES128-SHA
81121

82122
## Select an authentication/authorisation backend to use.
83123
##

‎priv/schema/rabbit.schema

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ fun(Conf) ->
3535
end
3636
end}.
3737

38-
%% SSL listeners are configured in the same fashion as TCP listeners,
38+
%% TLS listeners are configured in the same fashion as TCP listeners,
3939
%% including the option to control the choice of interface.
4040
%%
4141
%% {ssl_listeners, [5671]},
@@ -129,7 +129,7 @@ fun(Conf) ->
129129
end
130130
end}.
131131

132-
%% Configuring SSL.
132+
%% TLS options.
133133
%% See http://www.rabbitmq.com/ssl.html for full documentation.
134134
%%
135135
%% {ssl_options, [{cacertfile, "/path/to/testca/cacert.pem"},
@@ -138,8 +138,6 @@ end}.
138138
%% {verify, verify_peer},
139139
%% {fail_if_no_peer_cert, false}]},
140140

141-
%% SSL options section ========================================================
142-
143141
{mapping, "ssl_allow_poodle_attack", "rabbit.ssl_allow_poodle_attack",
144142
[{datatype, {enum, [true, false]}}]}.
145143

@@ -251,7 +249,16 @@ end}.
251249
{translation, "rabbit.ssl_options.versions",
252250
fun(Conf) ->
253251
Settings = cuttlefish_variable:filter_by_prefix("ssl_options.versions", Conf),
254-
[ V || {_, V} <- Settings ]
252+
[V || {_, V} <- Settings]
253+
end}.
254+
255+
{mapping, "ssl_options.ciphers.$cipher", "rabbit.ssl_options.ciphers",
256+
[{datatype, string}]}.
257+
258+
{translation, "rabbit.ssl_options.ciphers",
259+
fun(Conf) ->
260+
Settings = cuttlefish_variable:filter_by_prefix("ssl_options.ciphers", Conf),
261+
[V || {_, V} <- Settings]
255262
end}.
256263

257264
%% ===========================================================================

‎rabbitmq-components.mk

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,6 @@ endif
4040
dep_amqp_client = git_rmq rabbitmq-erlang-client $(current_rmq_ref) $(base_rmq_ref) master
4141
dep_amqp10_client = git_rmq rabbitmq-amqp1.0-client $(current_rmq_ref) $(base_rmq_ref) master
4242
dep_amqp10_common = git_rmq rabbitmq-amqp1.0-common $(current_rmq_ref) $(base_rmq_ref) master
43-
dep_ra = git_rmq ra $(current_rmq_ref) $(base_rmq_ref) master
4443
dep_rabbit = git_rmq rabbitmq-server $(current_rmq_ref) $(base_rmq_ref) master
4544
dep_rabbit_common = git_rmq rabbitmq-common $(current_rmq_ref) $(base_rmq_ref) master
4645
dep_rabbitmq_amqp1_0 = git_rmq rabbitmq-amqp1.0 $(current_rmq_ref) $(base_rmq_ref) master
@@ -111,11 +110,12 @@ dep_rabbitmq_public_umbrella = git_rmq rabbitmq-public-umbrella $(curre
111110
# all projects use the same versions. It avoids conflicts and makes it
112111
# possible to work with rabbitmq-public-umbrella.
113112

114-
dep_cowboy = hex 2.4.0
115-
dep_cowlib = hex 2.3.0
113+
dep_cowboy = hex 2.6.0
114+
dep_cowlib = hex 2.7.0
116115
dep_jsx = hex 2.9.0
117116
dep_lager = hex 3.6.5
118-
dep_ranch = hex 1.6.2
117+
dep_ra = git https://github.com/rabbitmq/ra.git master
118+
dep_ranch = hex 1.7.0
119119
dep_ranch_proxy_protocol = hex 2.1.1
120120
dep_recon = hex 2.3.6
121121

@@ -124,7 +124,6 @@ dep_sockjs = git https://github.com/rabbitmq/sockjs-erlang.git 405990ea62353d98d
124124
RABBITMQ_COMPONENTS = amqp_client \
125125
amqp10_common \
126126
amqp10_client \
127-
ra \
128127
rabbit \
129128
rabbit_common \
130129
rabbitmq_amqp1_0 \

‎scripts/rabbitmq-diagnostics.bat

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,6 @@ if not defined ERL_CRASH_DUMP_SECONDS (
5353
-kernel inet_dist_listen_max !RABBITMQ_CTL_DIST_PORT_MAX! ^
5454
-sasl errlog_type error ^
5555
-mnesia dir \""!RABBITMQ_MNESIA_DIR:\=/!"\" ^
56-
-nodename !RABBITMQ_NODENAME! ^
5756
-run escript start ^
5857
-escript main rabbitmqctl_escript ^
5958
-extra "%RABBITMQ_HOME%\escript\rabbitmq-diagnostics" !STAR!
@@ -63,4 +62,3 @@ if ERRORLEVEL 1 (
6362
)
6463

6564
endlocal
66-
endlocal

‎scripts/rabbitmq-env

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -245,6 +245,7 @@ DEFAULT_NODE_PORT=5672
245245
[ "x" = "x$RABBITMQ_SERVER_CODE_PATH" ] && RABBITMQ_SERVER_CODE_PATH=${SERVER_CODE_PATH}
246246
[ "x" = "x$RABBITMQ_MNESIA_DIR" ] && RABBITMQ_MNESIA_DIR=${MNESIA_DIR}
247247
[ "x" = "x$RABBITMQ_MNESIA_DIR" ] && RABBITMQ_MNESIA_DIR=${RABBITMQ_MNESIA_BASE}/${RABBITMQ_NODENAME}
248+
[ "x" = "x$RABBITMQ_QUORUM_DIR" ] && RABBITMQ_QUORUM_DIR=${RABBITMQ_MNESIA_DIR}/quorum
248249
[ "x" = "x$RABBITMQ_GENERATED_CONFIG_DIR" ] && RABBITMQ_GENERATED_CONFIG_DIR=${GENERATED_CONFIG_DIR}
249250
[ "x" = "x$RABBITMQ_ADVANCED_CONFIG_FILE" ] && RABBITMQ_ADVANCED_CONFIG_FILE=${ADVANCED_CONFIG_FILE}
250251
[ "x" = "x$RABBITMQ_SCHEMA_DIR" ] && RABBITMQ_SCHEMA_DIR=${SCHEMA_DIR}
@@ -255,7 +256,8 @@ rmq_normalize_path_var \
255256
RABBITMQ_CONFIG_FILE \
256257
RABBITMQ_LOG_BASE \
257258
RABBITMQ_MNESIA_BASE \
258-
RABBITMQ_MNESIA_DIR
259+
RABBITMQ_MNESIA_DIR \
260+
RABBITMQ_QUORUM_DIR
259261

260262
[ "x" = "x$RABBITMQ_PID_FILE" ] && RABBITMQ_PID_FILE="$PID_FILE"
261263

@@ -349,6 +351,10 @@ if [ "${RABBITMQ_DEV_ENV}" ]; then
349351
"$RABBITMQ_MNESIA_DIR_source" != 'environment' ]; then
350352
RABBITMQ_MNESIA_DIR="${mnesia_dir}"
351353
fi
354+
if [ "${mnesia_dir}" -a \
355+
"$RABBITMQ_QUORUM_DIR_source" != 'environment' ]; then
356+
RABBITMQ_QUORUM_DIR="${mnesia_dir}/quorum"
357+
fi
352358
fi
353359

354360
if path_contains_existing_directory "${RABBITMQ_PLUGINS_DIR}" ; then
@@ -405,7 +411,6 @@ run_escript()
405411
-kernel inet_dist_listen_max "$RABBITMQ_CTL_DIST_PORT_MAX" \
406412
-sasl errlog_type error \
407413
-mnesia dir "\"$RABBITMQ_MNESIA_DIR\"" \
408-
-nodename "$RABBITMQ_NODENAME" \
409414
-run escript start \
410415
-escript main "$escript_main" \
411416
-extra "$escript" "$@"

‎scripts/rabbitmq-env.bat

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -262,6 +262,15 @@ if not exist "!RABBITMQ_MNESIA_DIR!" (
262262
)
263263
for /f "delims=" %%F in ("!RABBITMQ_MNESIA_DIR!") do set RABBITMQ_MNESIA_DIR=%%~sF
264264

265+
REM [ "x" = "x$RABBITMQ_QUORUM_DIR" ] && RABBITMQ_QUORUM_DIR=${RABBITMQ_MNESIA_DIR}/quorum
266+
if "!RABBITMQ_QUORUM_DIR!"=="" (
267+
set RABBITMQ_QUORUM_DIR=!RABBITMQ_MNESIA_DIR!\quorum
268+
)
269+
if not exist "!RABBITMQ_QUORUM_DIR!" (
270+
mkdir "!RABBITMQ_QUORUM_DIR!"
271+
)
272+
for /f "delims=" %%F in ("!RABBITMQ_QUORUM_DIR!") do set RABBITMQ_QUORUM_DIR=%%~sF
273+
265274
REM [ "x" = "x$RABBITMQ_PID_FILE" ] && RABBITMQ_PID_FILE=${PID_FILE}
266275
REM [ "x" = "x$RABBITMQ_PID_FILE" ] && RABBITMQ_PID_FILE=${RABBITMQ_MNESIA_DIR}.pid
267276
REM No Windows equivalent

‎scripts/rabbitmq-plugins.bat

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,6 @@ if not defined ERL_CRASH_DUMP_SECONDS (
5353
-kernel inet_dist_listen_max !RABBITMQ_CTL_DIST_PORT_MAX! ^
5454
-sasl errlog_type error ^
5555
-mnesia dir \""!RABBITMQ_MNESIA_DIR:\=/!"\" ^
56-
-nodename !RABBITMQ_NODENAME! ^
5756
-run escript start ^
5857
-escript main rabbitmqctl_escript ^
5958
-extra "%RABBITMQ_HOME%\escript\rabbitmq-plugins" !STAR!

‎scripts/rabbitmq-queues

Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
#!/bin/sh
2+
## The contents of this file are subject to the Mozilla Public License
3+
## Version 1.1 (the "License"); you may not use this file except in
4+
## compliance with the License. You may obtain a copy of the License
5+
## at http://www.mozilla.org/MPL/
6+
##
7+
## Software distributed under the License is distributed on an "AS IS"
8+
## basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
9+
## the License for the specific language governing rights and
10+
## limitations under the License.
11+
##
12+
## The Original Code is RabbitMQ.
13+
##
14+
## The Initial Developer of the Original Code is GoPivotal, Inc.
15+
## Copyright (c) 2007-2017 Pivotal Software, Inc. All rights reserved.
16+
##
17+
18+
# Exit immediately if a pipeline, which may consist of a single simple command,
19+
# a list, or a compound command returns a non-zero status
20+
set -e
21+
22+
# Each variable or function that is created or modified is given the export
23+
# attribute and marked for export to the environment of subsequent commands.
24+
set -a
25+
26+
# shellcheck source=/dev/null
27+
#
28+
# TODO: when shellcheck adds support for relative paths, change to
29+
# shellcheck source=./rabbitmq-env
30+
. "${0%/*}"/rabbitmq-env
31+
32+
run_escript rabbitmqctl_escript "${ESCRIPT_DIR:?must be defined}"/rabbitmq-queues "$@"

‎scripts/rabbitmq-queues.bat

Lines changed: 66 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,66 @@
1+
@echo off
2+
REM The contents of this file are subject to the Mozilla Public License
3+
REM Version 1.1 (the "License"); you may not use this file except in
4+
REM compliance with the License. You may obtain a copy of the License
5+
REM at http://www.mozilla.org/MPL/
6+
REM
7+
REM Software distributed under the License is distributed on an "AS IS"
8+
REM basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
9+
REM the License for the specific language governing rights and
10+
REM limitations under the License.
11+
REM
12+
REM The Original Code is RabbitMQ.
13+
REM
14+
REM The Initial Developer of the Original Code is GoPivotal, Inc.
15+
REM Copyright (c) 2007-2015 Pivotal Software, Inc. All rights reserved.
16+
REM
17+
18+
REM Scopes the variables to the current batch file
19+
setlocal
20+
21+
rem Preserve values that might contain exclamation marks before
22+
rem enabling delayed expansion
23+
set TDP0=%~dp0
24+
set STAR=%*
25+
setlocal enabledelayedexpansion
26+
27+
REM Get default settings with user overrides for (RABBITMQ_)<var_name>
28+
REM Non-empty defaults should be set in rabbitmq-env
29+
call "%TDP0%\rabbitmq-env.bat" %~n0
30+
31+
if not exist "!ERLANG_HOME!\bin\erl.exe" (
32+
echo.
33+
echo ******************************
34+
echo ERLANG_HOME not set correctly.
35+
echo ******************************
36+
echo.
37+
echo Please either set ERLANG_HOME to point to your Erlang installation or place the
38+
echo RabbitMQ server distribution in the Erlang lib folder.
39+
echo.
40+
exit /B 1
41+
)
42+
43+
REM Disable erl_crash.dump by default for control scripts.
44+
if not defined ERL_CRASH_DUMP_SECONDS (
45+
set ERL_CRASH_DUMP_SECONDS=0
46+
)
47+
48+
"!ERLANG_HOME!\bin\erl.exe" +B ^
49+
-boot !CLEAN_BOOT_FILE! ^
50+
-noinput -noshell -hidden -smp enable ^
51+
!RABBITMQ_CTL_ERL_ARGS! ^
52+
-kernel inet_dist_listen_min !RABBITMQ_CTL_DIST_PORT_MIN! ^
53+
-kernel inet_dist_listen_max !RABBITMQ_CTL_DIST_PORT_MAX! ^
54+
-sasl errlog_type error ^
55+
-mnesia dir \""!RABBITMQ_MNESIA_DIR:\=/!"\" ^
56+
-nodename !RABBITMQ_NODENAME! ^
57+
-run escript start ^
58+
-escript main rabbitmqctl_escript ^
59+
-extra "%RABBITMQ_HOME%\escript\rabbitmq-queues" !STAR!
60+
61+
if ERRORLEVEL 1 (
62+
exit /B 1
63+
)
64+
65+
endlocal
66+
endlocal

‎scripts/rabbitmq-server

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -311,6 +311,7 @@ start_rabbitmq_server() {
311311
-os_mon start_disksup false \
312312
-os_mon start_memsup false \
313313
-mnesia dir "\"${RABBITMQ_MNESIA_DIR}\"" \
314+
-ra data_dir "\"${RABBITMQ_QUORUM_DIR}\"" \
314315
${RABBITMQ_SERVER_START_ARGS} \
315316
${RABBITMQ_DIST_ARG} \
316317
"$@"

‎scripts/rabbitmq-server.bat

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -256,6 +256,7 @@ if "!ENV_OK!"=="false" (
256256
-os_mon start_disksup false ^
257257
-os_mon start_memsup false ^
258258
-mnesia dir \""!RABBITMQ_MNESIA_DIR:\=/!"\" ^
259+
-ra data_dir \""!RABBITMQ_QUORUM_DIR:\=/!"\" ^
259260
!RABBITMQ_SERVER_START_ARGS! ^
260261
!RABBITMQ_DIST_ARG! ^
261262
!STAR!

‎scripts/rabbitmq-service.bat

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -330,6 +330,7 @@ set ERLANG_SERVICE_ARGUMENTS= ^
330330
-os_mon start_disksup false ^
331331
-os_mon start_memsup false ^
332332
-mnesia dir \""!RABBITMQ_MNESIA_DIR:\=/!"\" ^
333+
-ra data_dir \""!RABBITMQ_QUORUM_DIR:\=/!"\" ^
333334
!RABBITMQ_SERVER_START_ARGS! ^
334335
!RABBITMQ_DIST_ARG! ^
335336
!STARVAR!

‎scripts/rabbitmqctl.bat

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,6 @@ if not defined ERL_CRASH_DUMP_SECONDS (
5353
-kernel inet_dist_listen_max !RABBITMQ_CTL_DIST_PORT_MAX! ^
5454
-sasl errlog_type error ^
5555
-mnesia dir \""!RABBITMQ_MNESIA_DIR:\=/!"\" ^
56-
-nodename !RABBITMQ_NODENAME! ^
5756
-run escript start ^
5857
-escript main rabbitmqctl_escript ^
5958
-extra "%RABBITMQ_HOME%\escript\rabbitmqctl" !STAR!

‎src/rabbit.erl

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
-export([start/0, boot/0, stop/0,
2626
stop_and_halt/0, await_startup/0, await_startup/1,
2727
status/0, is_running/0, alarms/0,
28-
is_running/1, environment/0, rotate_logs/0, force_event_refresh/1,
28+
is_running/1, environment/0, rotate_logs/0,
2929
start_fhc/0]).
3030

3131
-export([start/2, stop/1, prep_stop/1]).
@@ -225,7 +225,7 @@
225225
-include("rabbit_framing.hrl").
226226
-include("rabbit.hrl").
227227

228-
-define(APPS, [os_mon, mnesia, rabbit_common, rabbit]).
228+
-define(APPS, [os_mon, mnesia, rabbit_common, ra, rabbit]).
229229

230230
-define(ASYNC_THREADS_WARNING_THRESHOLD, 8).
231231

@@ -252,7 +252,6 @@
252252
-spec is_running(node()) -> boolean().
253253
-spec environment() -> [{param(), term()}].
254254
-spec rotate_logs() -> rabbit_types:ok_or_error(any()).
255-
-spec force_event_refresh(reference()) -> 'ok'.
256255

257256
-spec log_locations() -> [log_location()].
258257

@@ -941,12 +940,6 @@ start_logger() ->
941940
log_locations() ->
942941
rabbit_lager:log_locations().
943942

944-
force_event_refresh(Ref) ->
945-
rabbit_direct:force_event_refresh(Ref),
946-
rabbit_networking:force_connection_event_refresh(Ref),
947-
rabbit_channel:force_event_refresh(Ref),
948-
rabbit_amqqueue:force_event_refresh(Ref).
949-
950943
%%---------------------------------------------------------------------------
951944
%% misc
952945

0 commit comments

Comments
 (0)