1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
|
@echo off
setLocal enableDelayedExpansion
setlocal enableextensions
set ORIGINAL_ARGS=%*
if not defined TEST_SRCDIR (
set BASE_DIR=%cd%
) else (
set BASE_DIR=%TEST_SRCDIR%/%TEST_WORKSPACE%
set BASE_DIR=%BASE_DIR:/=\\%
)
if "%1" == "-C" (
cd %2
shift 2
)
:loop-args
if "%1" == "" goto :loop-args-end
if "%1" == "run-broker" (
set CMD=%1
shift
goto :loop-args
)
if "%1" == "start-background-broker" (
set CMD=%1
shift
goto :loop-args
)
if "%1" == "stop-node" (
set CMD=%1
shift
goto :loop-args
)
if "%1" == "set-resource-alarm" (
set CMD=%1
shift
goto :loop-args
)
if "%1" == "clean-resource-alarm" (
set CMD=%1
shift
goto :loop-args
)
for /F "tokens=1,3 delims=. " %%a in ("%1") do (
set %%a=%%b
)
shift
goto :loop-args
:loop-args-end
set DEFAULT_PLUGINS_DIR=%BASE_DIR%\{RABBITMQ_HOME}\plugins
if defined EXTRA_PLUGINS_DIR (
set DEFAULT_PLUGINS_DIR=%DEFAULT_PLUGINS_DIR%;%EXTRA_PLUGINS_DIR%
)
if not defined TEST_TMPDIR (
set TEST_TMPDIR=%TEMP%\rabbitmq-test-instances
)
set RABBITMQ_SCRIPTS_DIR=%BASE_DIR%\{RABBITMQ_HOME}\sbin
set RABBITMQ_PLUGINS=%RABBITMQ_SCRIPTS_DIR%\rabbitmq-plugins.bat
set RABBITMQ_SERVER=%RABBITMQ_SCRIPTS_DIR%\rabbitmq-server.bat
set RABBITMQCTL=%RABBITMQ_SCRIPTS_DIR%\rabbitmqctl.bat
set HOSTNAME=%COMPUTERNAME%
if not defined RABBITMQ_NODENAME set RABBITMQ_NODENAME=rabbit@%HOSTNAME%
if not defined RABBITMQ_NODENAME_FOR_PATHS set RABBITMQ_NODENAME_FOR_PATHS=%RABBITMQ_NODENAME%
set NODE_TMPDIR=%TEST_TMPDIR%\%RABBITMQ_NODENAME_FOR_PATHS%
set RABBITMQ_BASE=%NODE_TMPDIR%
set RABBITMQ_PID_FILE=%NODE_TMPDIR%\%{RABBITMQ_NODENAME_FOR_PATHS%.pid
set RABBITMQ_LOG_BASE=%NODE_TMPDIR%\log
set RABBITMQ_MNESIA_BASE=%NODE_TMPDIR%\mnesia
set RABBITMQ_MNESIA_DIR=%RABBITMQ_MNESIA_BASE%\%RABBITMQ_NODENAME_FOR_PATHS%
set RABBITMQ_QUORUM_DIR=%RABBITMQ_MNESIA_DIR%\quorum
set RABBITMQ_STREAM_DIR=%RABBITMQ_MNESIA_DIR%\stream
if not defined RABBITMQ_PLUGINS_DIR set RABBITMQ_PLUGINS_DIR=%DEFAULT_PLUGINS_DIR%
set RABBITMQ_PLUGINS_EXPAND_DIR=%NODE_TMPDIR%\plugins
set RABBITMQ_FEATURE_FLAGS_FILE=%NODE_TMPDIR%\feature_flags
set RABBITMQ_ENABLED_PLUGINS_FILE=%NODE_TMPDIR%\enabled_plugins
if not defined RABBITMQ_SERVER_START_ARGS (
set RABBITMQ_SERVER_START_ARGS=-ra wal_sync_method sync
)
if not defined RABBITMQ_LOG (
set RABBITMQ_LOG=debug,+color
)
if defined LEAVE_PLUGINS_DISABLED (
set RABBITMQ_ENABLED_PLUGINS=
) else (
set RABBITMQ_ENABLED_PLUGINS=ALL
)
if not exist "%TEST_TMPDIR%" mkdir %TEST_TMPDIR%
if not exist "%RABBITMQ_LOG_BASE%" mkdir %RABBITMQ_LOG_BASE%
if not exist "%RABBITMQ_MNESIA_BASE%" mkdir %RABBITMQ_MNESIA_BASE%
if not exist "%RABBITMQ_PLUGINS_EXPAND_DIR%" mkdir %RABBITMQ_PLUGINS_EXPAND_DIR%
if "%CMD%" == "run-broker" (
set RABBITMQ_ALLOW_INPUT=true
set RABBITMQ_CONFIG_FILE=%TEST_TMPDIR%\test.config
> !RABBITMQ_CONFIG_FILE! (
@echo [
@echo {rabbit, [
@echo {loopback_users, []}
@echo ]},
@echo {rabbitmq_management, []},
@echo {rabbitmq_mqtt, []},
@echo {rabbitmq_stomp, []},
@echo {ra, [
@echo {data_dir, "!RABBITMQ_QUORUM_DIR:\=\\!"},
@echo {wal_sync_method, sync}
@echo ]},
@echo {osiris, [
@echo {data_dir, "!RABBITMQ_STREAM_DIR:\=\\!"}
@echo ]}
@echo ].
)
call %RABBITMQ_SCRIPTS_DIR%\rabbitmq-server.bat
if ERRORLEVEL 1 (
exit /B %ERRORLEVEL%
)
exit /B 0
)
if "%CMD%" == "start-background-broker" (
echo ERROR: not implemented by rabbitmq-run.bat
exit /b 1
)
if "%CMD%" == "stop-node" (
echo ERROR: not implemented by rabbitmq-run.bat
exit /b 1
)
if "%CMD%" == "set-resource-alarm" (
echo ERROR: not implemented by rabbitmq-run.bat
exit /b 1
)
if "%CMD%" == "clear-resource-alarm" (
echo ERROR: not implemented by rabbitmq-run.bat
exit /b 1
)
echo ERROR: unrecognized rabbitmq-run.bat args: "%ORIGINAL_ARGS%"
exit /b 1
|
