merge bug19914 into default

6 files changed, 171 insertions, 123 deletions

diff --git a/scripts/rabbitmq-mnesia-current b/scripts/rabbitmq-mnesia-current
index e69e4976..e7e1118c 100755
--- a/scripts/rabbitmq-mnesia-current
+++ b/scripts/rabbitmq-mnesia-current
@@ -30,27 +30,34 @@
 ##   Contributor(s): ______________________________________.
 ##
 
-[ "x" = "x$NODENAME" ] && NODENAME=rabbit
-[ "x" = "x$NODE_IP_ADDRESS" ] && NODE_IP_ADDRESS=0.0.0.0
-[ "x" = "x$NODE_PORT" ] && NODE_PORT=5672
+[ -f /etc/default/rabbitmq ] && . /etc/default/rabbitmq
 
-CLUSTER_CONFIG_FILE=/etc/default/rabbitmq_cluster.config
+[ "x" = "x$RABBITMQ_CLUSTER_CONFIG_FILE" ] && RABBITMQ_CLUSTER_CONFIG_FILE=${CLUSTER_CONFIG_FILE}
+[ "x" = "x$RABBITMQ_CLUSTER_CONFIG_FILE" ] && RABBITMQ_CLUSTER_CONFIG_FILE=/etc/default/rabbitmq_cluster.config
+[ "x" = "x$RABBITMQ_NODENAME" ] && RABBITMQ_NODENAME=${NODENAME}
+[ "x" = "x$RABBITMQ_NODENAME" ] && RABBITMQ_NODENAME=rabbit
+[ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=${NODE_IP_ADDRESS}
+[ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=0.0.0.0
+[ "x" = "x$RABBITMQ_NODE_PORT" ] && RABBITMQ_NODE_PORT=${NODE_PORT}
+[ "x" = "x$RABBITMQ_NODE_PORT" ] && RABBITMQ_NODE_PORT=5672
+[ "x" = "x$RABBITMQ_LOG_BASE" ] && RABBITMQ_LOG_BASE=${LOG_BASE}
+[ "x" = "x$RABBITMQ_LOG_BASE" ] && RABBITMQ_LOG_BASE=/var/log/rabbitmq
+[ "x" = "x$RABBITMQ_MNESIA_BASE" ] && RABBITMQ_MNESIA_BASE=${MNESIA_BASE}
+[ "x" = "x$RABBITMQ_MNESIA_BASE" ] && RABBITMQ_MNESIA_BASE=/var/lib/rabbitmq/mnesia
+[ "x" = "x$RABBITMQ_MNESIA_DIR" ] && RABBITMQ_MNESIA_DIR=${MNESIA_DIR}
+[ "x" = "x$RABBITMQ_MNESIA_DIR" ] && RABBITMQ_MNESIA_DIR=${RABBITMQ_MNESIA_BASE}/${RABBITMQ_NODENAME}
 
-[ "x" = "x$LOG_BASE" ] && LOG_BASE=/var/log/rabbitmq
-[ "x" = "x$MNESIA_BASE" ] && MNESIA_BASE=/var/lib/rabbitmq/mnesia
-[ "x" = "x$MNESIA_DIR" ] && MNESIA_DIR=${MNESIA_BASE}/${NODENAME}
-
-if [ -f "$CLUSTER_CONFIG_FILE" ]; then
-    CLUSTER_CONFIG="-rabbit cluster_config \"$CLUSTER_CONFIG_FILE\""
+if [ -f "$RABBITMQ_CLUSTER_CONFIG_FILE" ]; then
+    RABBITMQ_CLUSTER_CONFIG_OPTION="-rabbit cluster_config \"$RABBITMQ_CLUSTER_CONFIG_FILE\""
 else
-    CLUSTER_CONFIG=""
+    RABBITMQ_CLUSTER_CONFIG_OPTION=""
 fi
 
 exec erl \
     -pa "`dirname $0`/../ebin" \
     -noshell \
-    -sname ${NODENAME} \
+    -sname ${RABBITMQ_NODENAME} \
     -eval 'halt(case rabbit_mnesia:schema_current() of true -> 0; false -> 1 end).' \
-    -mnesia dir "\"${MNESIA_DIR}\"" \
+    -mnesia dir "\"${RABBITMQ_MNESIA_DIR}\"" \
     -kernel error_logger '{file,"'/dev/null'"}' \
-    ${CLUSTER_CONFIG}
+    ${RABBITMQ_CLUSTER_CONFIG_OPTION}
diff --git a/scripts/rabbitmq-multi b/scripts/rabbitmq-multi
index 8c889a1a..84985e90 100755
--- a/scripts/rabbitmq-multi
+++ b/scripts/rabbitmq-multi
@@ -30,24 +30,36 @@
 ##   Contributor(s): ______________________________________.
 ##
 
-[ "x" = "x$NODENAME" ] && NODENAME=rabbit
-[ "x" = "x$NODE_IP_ADDRESS" ] && NODE_IP_ADDRESS=0.0.0.0
-[ "x" = "x$NODE_PORT" ] && NODE_PORT=5672
+[ -f /etc/default/rabbitmq ] && . /etc/default/rabbitmq
 
-ERL_ARGS=
-SCRIPT_HOME=$(dirname $0)
+[ "x" = "x$RABBITMQ_NODENAME" ] && RABBITMQ_NODENAME=${NODENAME}
+[ "x" = "x$RABBITMQ_NODENAME" ] && RABBITMQ_NODENAME=rabbit
+[ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=${NODE_IP_ADDRESS}
+[ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=0.0.0.0
+[ "x" = "x$RABBITMQ_NODE_PORT" ] && RABBITMQ_NODE_PORT=${NODE_PORT}
+[ "x" = "x$RABBITMQ_NODE_PORT" ] && RABBITMQ_NODE_PORT=5672
+[ "x" = "x$RABBITMQ_SCRIPT_HOME" ] && RABBITMQ_SCRIPT_HOME=${SCRIPT_HOME}
+[ "x" = "x$RABBITMQ_SCRIPT_HOME" ] && RABBITMQ_SCRIPT_HOME=$(dirname $0)
+[ "x" = "x$RABBITMQ_PIDS_FILE" ] && RABBITMQ_PIDS_FILE=${PIDS_FILE}
+[ "x" = "x$RABBITMQ_PIDS_FILE" ] && RABBITMQ_PIDS_FILE=/var/lib/rabbitmq/pids
+[ "x" = "x$RABBITMQ_MULTI_ERL_ARGS" ] && RABBITMQ_MULTI_ERL_ARGS=${MULTI_ERL_ARGS}
+[ "x" = "x$RABBITMQ_MULTI_ERL_ARGS" ] && RABBITMQ_MULTI_ERL_ARGS=
+[ "x" = "x$RABBITMQ_MULTI_START_ARGS" ] && RABBITMQ_MULTI_START_ARGS=${MULTI_START_ARGS}
+[ "x" = "x$RABBITMQ_MULTI_START_ARGS" ] && RABBITMQ_MULTI_START_ARGS=
 
-[ "x" = "x$PIDS_FILE" ] && PIDS_FILE=/var/lib/rabbitmq/pids
-
-export NODENAME NODE_IP_ADDRESS NODE_PORT SCRIPT_HOME PIDS_FILE
+export \
+    RABBITMQ_NODENAME \
+    RABBITMQ_NODE_IP_ADDRESS \
+    RABBITMQ_NODE_PORT \
+    RABBITMQ_SCRIPT_HOME \
+    RABBITMQ_PIDS_FILE
 
 exec erl \
     -pa "`dirname $0`/../ebin" \
     -noinput \
     -hidden \
-    ${ERL_ARGS} \
+    ${RABBITMQ_MULTI_ERL_ARGS} \
     -sname rabbitmq_multi$$ \
     -s rabbit_multi \
-    ${START_ARGS} \
+    ${RABBITMQ_MULTI_START_ARGS} \
     -extra "$@"
-
diff --git a/scripts/rabbitmq-multi.bat b/scripts/rabbitmq-multi.bat
index 7899b70d..30f33a5a 100755
--- a/scripts/rabbitmq-multi.bat
+++ b/scripts/rabbitmq-multi.bat
@@ -34,20 +34,20 @@ if "%RABBITMQ_BASE%"=="" (
     set RABBITMQ_BASE=%APPDATA%\RabbitMQ

 )

 

-if "%NODENAME%"=="" (

-    set NODENAME=rabbit

+if "%RABBITMQ_NODENAME%"=="" (

+    set RABBITMQ_NODENAME=rabbit

 )

 

-if "%NODE_IP_ADDRESS%"=="" (

-    set NODE_IP_ADDRESS=0.0.0.0

+if "%RABBITMQ_NODE_IP_ADDRESS%"=="" (

+    set RABBITMQ_NODE_IP_ADDRESS=0.0.0.0

 )

 

-if "%NODE_PORT%"=="" (

-    set NODE_PORT=5672

+if "%RABBITMQ_NODE_PORT%"=="" (

+    set RABBITMQ_NODE_PORT=5672

 )

 

-set PIDS_FILE=%RABBITMQ_BASE%\rabbitmq.pids

-set SCRIPT_HOME=%~dp0%

+set RABBITMQ_PIDS_FILE=%RABBITMQ_BASE%\rabbitmq.pids

+set RABBITMQ_SCRIPT_HOME=%~dp0%

 

 if "%ERLANG_HOME%"=="" (

     set ERLANG_HOME=%~dp0%..\..\..

diff --git a/scripts/rabbitmq-server b/scripts/rabbitmq-server
index f2971cb3..bb65d64d 100755
--- a/scripts/rabbitmq-server
+++ b/scripts/rabbitmq-server
@@ -30,54 +30,67 @@
 ##   Contributor(s): ______________________________________.
 ##
 
-[ "x" = "x$NODENAME" ] && NODENAME=rabbit
-[ "x" = "x$NODE_IP_ADDRESS" ] && NODE_IP_ADDRESS=0.0.0.0
-[ "x" = "x$NODE_PORT" ] && NODE_PORT=5672
+[ -f /etc/default/rabbitmq ] && . /etc/default/rabbitmq
 
-ERL_ARGS="+K true +A30 \
+[ "x" = "x$RABBITMQ_NODENAME" ] && RABBITMQ_NODENAME=${NODENAME}
+[ "x" = "x$RABBITMQ_NODENAME" ] && RABBITMQ_NODENAME=rabbit
+[ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=${NODE_IP_ADDRESS}
+[ "x" = "x$RABBITMQ_NODE_IP_ADDRESS" ] && RABBITMQ_NODE_IP_ADDRESS=0.0.0.0
+[ "x" = "x$RABBITMQ_NODE_PORT" ] && RABBITMQ_NODE_PORT=${NODE_PORT}
+[ "x" = "x$RABBITMQ_NODE_PORT" ] && RABBITMQ_NODE_PORT=5672
+[ "x" = "x$RABBITMQ_SERVER_ERL_ARGS" ] && RABBITMQ_ERL_ARGS=${SERVER_ERL_ARGS}
+[ "x" = "x$RABBITMQ_SERVER_ERL_ARGS" ] && RABBITMQ_ERL_ARGS="+K true +A30 \
 -kernel inet_default_listen_options [{nodelay,true},{sndbuf,16384},{recbuf,4096}] \
 -kernel inet_default_connect_options [{nodelay,true}]"
-
-CLUSTER_CONFIG_FILE=/etc/default/rabbitmq_cluster.config
-
-[ "x" = "x$LOG_BASE" ] && LOG_BASE=/var/log/rabbitmq
-[ "x" = "x$MNESIA_BASE" ] && MNESIA_BASE=/var/lib/rabbitmq/mnesia
-[ "x" = "x$MNESIA_DIR" ] && MNESIA_DIR=${MNESIA_BASE}/${NODENAME}
-[ "x" = "x$NODE_ONLY" ] && START_RABBIT='-noinput -s rabbit'
+[ "x" = "x$RABBITMQ_CLUSTER_CONFIG_FILE" ] && RABBITMQ_CLUSTER_CONFIG_FILE=${CLUSTER_CONFIG_FILE}
+[ "x" = "x$RABBITMQ_CLUSTER_CONFIG_FILE" ] && RABBITMQ_CLUSTER_CONFIG_FILE=/etc/default/rabbitmq_cluster.config
+[ "x" = "x$RABBITMQ_LOG_BASE" ] && RABBITMQ_LOG_BASE=${LOG_BASE}
+[ "x" = "x$RABBITMQ_LOG_BASE" ] && RABBITMQ_LOG_BASE=/var/log/rabbitmq
+[ "x" = "x$RABBITMQ_MNESIA_BASE" ] && RABBITMQ_MNESIA_BASE=${MNESIA_BASE}
+[ "x" = "x$RABBITMQ_MNESIA_BASE" ] && RABBITMQ_MNESIA_BASE=/var/lib/rabbitmq/mnesia
+[ "x" = "x$RABBITMQ_MNESIA_DIR" ] && RABBITMQ_MNESIA_DIR=${MNESIA_DIR}
+[ "x" = "x$RABBITMQ_MNESIA_DIR" ] && RABBITMQ_MNESIA_DIR=${RABBITMQ_MNESIA_BASE}/${RABBITMQ_NODENAME}
+[ "x" = "x$RABBITMQ_SERVER_START_ARGS" ] && RABBITMQ_SERVER_START_ARGS=${SERVER_START_ARGS}
+[ "x" = "x$RABBITMQ_SERVER_START_ARGS" ] && RABBITMQ_SERVER_START_ARGS=
 
 ## Log rotation
-LOGS="${LOG_BASE}/${NODENAME}.log"
-SASL_LOGS="${LOG_BASE}/${NODENAME}-sasl.log"
-BACKUP_EXTENSION=".1"
+[ "x" = "x$RABBITMQ_LOGS" ] && RABBITMQ_LOGS=${LOGS}
+[ "x" = "x$RABBITMQ_LOGS" ] && RABBITMQ_LOGS="${RABBITMQ_LOG_BASE}/${RABBITMQ_NODENAME}.log"
+[ "x" = "x$RABBITMQ_SASL_LOGS" ] && RABBITMQ_SASL_LOGS=${SASL_LOGS}
+[ "x" = "x$RABBITMQ_SASL_LOGS" ] && RABBITMQ_SASL_LOGS="${RABBITMQ_LOG_BASE}/${RABBITMQ_NODENAME}-sasl.log"
+[ "x" = "x$RABBITMQ_BACKUP_EXTENSION" ] && RABBITMQ_BACKUP_EXTENSION=${BACKUP_EXTENSION}
+[ "x" = "x$RABBITMQ_BACKUP_EXTENSION" ] && RABBITMQ_BACKUP_EXTENSION=".1"
 
-[ -f  "${LOGS}" ] && cat "${LOGS}" >> "${LOGS}${BACKUP_EXTENSION}"
-[ -f  "${SASL_LOGS}" ] && cat "${SASL_LOGS}" >> "${SASL_LOGS}${BACKUP_EXTENSION}"
+[ -f  "${RABBITMQ_LOGS}" ] && cat "${RABBITMQ_LOGS}" >> "${RABBITMQ_LOGS}${RABBITMQ_BACKUP_EXTENSION}"
+[ -f  "${RABBITMQ_SASL_LOGS}" ] && cat "${RABBITMQ_SASL_LOGS}" >> "${RABBITMQ_SASL_LOGS}${RABBITMQ_BACKUP_EXTENSION}"
 
-if [ -f "$CLUSTER_CONFIG_FILE" ]; then
-    CLUSTER_CONFIG="-rabbit cluster_config \"$CLUSTER_CONFIG_FILE\""
+if [ -f "$RABBITMQ_CLUSTER_CONFIG_FILE" ]; then
+    RABBITMQ_CLUSTER_CONFIG_OPTION="-rabbit cluster_config \"$RABBITMQ_CLUSTER_CONFIG_FILE\""
 else
-    CLUSTER_CONFIG=""
+    RABBITMQ_CLUSTER_CONFIG_OPTION=""
 fi
 
+RABBITMQ_START_RABBIT=
+[ "x" = "x$RABBITMQ_NODE_ONLY" ] && RABBITMQ_START_RABBIT='-noinput -s rabbit'
+
 exec erl \
     -pa "`dirname $0`/../ebin" \
-    ${START_RABBIT} \
-    -sname ${NODENAME} \
+    ${RABBITMQ_START_RABBIT} \
+    -sname ${RABBITMQ_NODENAME} \
     -boot start_sasl \
     +W w \
-    ${ERL_ARGS} \
-    -rabbit tcp_listeners '[{"'${NODE_IP_ADDRESS}'", '${NODE_PORT}'}]' \
+    ${RABBITMQ_SERVER_ERL_ARGS} \
+    -rabbit tcp_listeners '[{"'${RABBITMQ_NODE_IP_ADDRESS}'", '${RABBITMQ_NODE_PORT}'}]' \
     -sasl errlog_type error \
-    -kernel error_logger '{file,"'${LOGS}'"}' \
-    -sasl sasl_error_logger '{file,"'${SASL_LOGS}'"}' \
+    -kernel error_logger '{file,"'${RABBITMQ_LOGS}'"}' \
+    -sasl sasl_error_logger '{file,"'${RABBITMQ_SASL_LOGS}'"}' \
     -os_mon start_cpu_sup true \
     -os_mon start_disksup false \
     -os_mon start_memsup false \
     -os_mon start_os_sup false \
     -os_mon memsup_system_only true \
     -os_mon system_memory_high_watermark 0.95 \
-    -mnesia dir "\"${MNESIA_DIR}\"" \
-    ${CLUSTER_CONFIG} \
-    ${RABBIT_ARGS} \
+    -mnesia dir "\"${RABBITMQ_MNESIA_DIR}\"" \
+    ${RABBITMQ_CLUSTER_CONFIG_OPTION} \
+    ${RABBITMQ_SERVER_START_ARGS} \
     "$@"
-
diff --git a/scripts/rabbitmq-server.bat b/scripts/rabbitmq-server.bat
index 41d75f81..5b20ef20 100755
--- a/scripts/rabbitmq-server.bat
+++ b/scripts/rabbitmq-server.bat
@@ -34,16 +34,16 @@ if "%RABBITMQ_BASE%"=="" (
     set RABBITMQ_BASE=%APPDATA%\RabbitMQ

 )

 

-if "%NODENAME%"=="" (

-    set NODENAME=rabbit

+if "%RABBITMQ_NODENAME%"=="" (

+    set RABBITMQ_NODENAME=rabbit

 )

 

-if "%NODE_IP_ADDRESS%"=="" (

-    set NODE_IP_ADDRESS=0.0.0.0

+if "%RABBITMQ_NODE_IP_ADDRESS%"=="" (

+    set RABBITMQ_NODE_IP_ADDRESS=0.0.0.0

 )

 

-if "%NODE_PORT%"=="" (

-    set NODE_PORT=5672

+if "%RABBITMQ_NODE_PORT%"=="" (

+    set RABBITMQ_NODE_PORT=5672

 )

 

 if "%ERLANG_HOME%"=="" (

@@ -64,8 +64,12 @@ if not exist "%ERLANG_HOME%\bin\erl.exe" (
 

 set RABBITMQ_BASE_UNIX=%RABBITMQ_BASE:\=/%

 

-set MNESIA_BASE=%RABBITMQ_BASE_UNIX%/db

-set LOG_BASE=%RABBITMQ_BASE_UNIX%/log

+if "%RABBITMQ_MNESIA_BASE%"=="" (

+    set RABBITMQ_MNESIA_BASE=%RABBITMQ_BASE_UNIX%/db

+)

+if "%RABBITMQ_LOG_BASE%"=="" (

+    set RABBITMQ_LOG_BASE=%RABBITMQ_BASE_UNIX%/log

+)

 

 

 rem We save the previous logs in their respective backup

@@ -73,11 +77,11 @@ rem Log management (rotation, filtering based of size...) is left as an exercice
 

 set BACKUP_EXTENSION=.1

 

-set LOGS="%RABBITMQ_BASE%\log\%NODENAME%.log"

-set SASL_LOGS="%RABBITMQ_BASE%\log\%NODENAME%-sasl.log"

+set LOGS="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%.log"

+set SASL_LOGS="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%-sasl.log"

 

-set LOGS_BACKUP="%RABBITMQ_BASE%\log\%NODENAME%.log%BACKUP_EXTENSION%"

-set SASL_LOGS_BAKCUP="%RABBITMQ_BASE%\log\%NODENAME%-sasl.log%BACKUP_EXTENSION%"

+set LOGS_BACKUP="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%.log%BACKUP_EXTENSION%"

+set SASL_LOGS_BAKCUP="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%-sasl.log%BACKUP_EXTENSION%"

 

 if exist %LOGS% (

 	type %LOGS% >> %LOGS_BACKUP%

@@ -89,36 +93,39 @@ if exist %SASL_LOGS% (
 rem End of log management

 

 

-set CLUSTER_CONFIG_FILE=%RABBITMQ_BASE%\rabbitmq_cluster.config

+if "%RABBITMQ_CLUSTER_CONFIG_FILE%"=="" (

+    set RABBITMQ_CLUSTER_CONFIG_FILE=%RABBITMQ_BASE%\rabbitmq_cluster.config

+)

 set CLUSTER_CONFIG=

-if not exist "%CLUSTER_CONFIG_FILE%" GOTO L1

-set CLUSTER_CONFIG=-rabbit cluster_config \""%CLUSTER_CONFIG_FILE:\=/%"\"

+if not exist "%RABBITMQ_CLUSTER_CONFIG_FILE%" GOTO L1

+set CLUSTER_CONFIG=-rabbit cluster_config \""%RABBITMQ_CLUSTER_CONFIG_FILE:\=/%"\"

 :L1

 

-set MNESIA_DIR=%MNESIA_BASE%/%NODENAME%-mnesia

+if "%RABBITMQ_MNESIA_DIR%"=="" (

+    set RABBITMQ_MNESIA_DIR=%RABBITMQ_MNESIA_BASE%/%RABBITMQ_NODENAME%-mnesia

+)

 

 "%ERLANG_HOME%\bin\erl.exe" ^

 -pa "%~dp0..\ebin" ^

 -noinput ^

 -boot start_sasl ^

--sname %NODENAME% ^

+-sname %RABBITMQ_NODENAME% ^

 -s rabbit ^

 +W w ^

 +A30 ^

 -kernel inet_default_listen_options "[{nodelay, true}, {sndbuf, 16384}, {recbuf, 4096}]" ^

 -kernel inet_default_connect_options "[{nodelay, true}]" ^

--rabbit tcp_listeners "[{\"%NODE_IP_ADDRESS%\", %NODE_PORT%}]" ^

--kernel error_logger {file,\""%LOG_BASE%/%NODENAME%.log"\"} ^

+-rabbit tcp_listeners "[{\"%RABBITMQ_NODE_IP_ADDRESS%\", %RABBITMQ_NODE_PORT%}]" ^

+-kernel error_logger {file,\""%RABBITMQ_LOG_BASE%/%RABBITMQ_NODENAME%.log"\"} ^

 -sasl errlog_type error ^

--sasl sasl_error_logger {file,\""%LOG_BASE%/%NODENAME%-sasl.log"\"} ^

+-sasl sasl_error_logger {file,\""%RABBITMQ_LOG_BASE%/%RABBITMQ_NODENAME%-sasl.log"\"} ^

 -os_mon start_cpu_sup true ^

 -os_mon start_disksup false ^

 -os_mon start_memsup false ^

 -os_mon start_os_sup false ^

 -os_mon memsup_system_only true ^

 -os_mon system_memory_high_watermark 0.95 ^

--mnesia dir \""%MNESIA_DIR%"\" ^

+-mnesia dir \""%RABBITMQ_MNESIA_DIR%"\" ^

 %CLUSTER_CONFIG% ^

-%RABBIT_ARGS% ^

+%RABBITMQ_SERVER_START_ARGS% ^

 %*

-

diff --git a/scripts/rabbitmq-service.bat b/scripts/rabbitmq-service.bat
index 6a1804f3..8051ff65 100755
--- a/scripts/rabbitmq-service.bat
+++ b/scripts/rabbitmq-service.bat
@@ -30,24 +30,24 @@ REM
 REM   Contributor(s): ______________________________________.

 REM

 

-if "%SERVICENAME%"=="" (

-    set SERVICENAME=RabbitMQ

+if "%RABBITMQ_SERVICENAME%"=="" (

+    set RABBITMQ_SERVICENAME=RabbitMQ

 )

 

 if "%RABBITMQ_BASE%"=="" (

-    set RABBITMQ_BASE=%APPDATA%\%SERVICENAME%

+    set RABBITMQ_BASE=%APPDATA%\%RABBITMQ_SERVICENAME%

 )

 

-if "%NODENAME%"=="" (

-    set NODENAME=rabbit

+if "%RABBITMQ_NODENAME%"=="" (

+    set RABBITMQ_NODENAME=rabbit

 )

 

-if "%NODE_IP_ADDRESS%"=="" (

-    set NODE_IP_ADDRESS=0.0.0.0

+if "%RABBITMQ_NODE_IP_ADDRESS%"=="" (

+    set RABBITMQ_NODE_IP_ADDRESS=0.0.0.0

 )

 

-if "%NODE_PORT%"=="" (

-    set NODE_PORT=5672

+if "%RABBITMQ_NODE_PORT%"=="" (

+    set RABBITMQ_NODE_PORT=5672

 )

 

 if "%ERLANG_SERVICE_MANAGER_PATH%"=="" (

@@ -56,9 +56,9 @@ if "%ERLANG_SERVICE_MANAGER_PATH%"=="" (
 

 set CONSOLE_FLAG=

 set CONSOLE_LOG_VALID=

-for %%i in (new reuse) do if "%%i" == "%CONSOLE_LOG%" set CONSOLE_LOG_VALID=TRUE

+for %%i in (new reuse) do if "%%i" == "%RABBITMQ_CONSOLE_LOG%" set CONSOLE_LOG_VALID=TRUE

 if "%CONSOLE_LOG_VALID%" == "TRUE" (

-    set CONSOLE_FLAG=-debugtype %CONSOLE_LOG%

+    set CONSOLE_FLAG=-debugtype %RABBITMQ_CONSOLE_LOG%

 )

 

 rem *** End of configuration ***

@@ -77,8 +77,13 @@ if not exist "%ERLANG_SERVICE_MANAGER_PATH%\erlsrv.exe" (
 

 rem erlang prefers forwardslash as separator in paths

 set RABBITMQ_BASE_UNIX=%RABBITMQ_BASE:\=/%

-set MNESIA_BASE=%RABBITMQ_BASE_UNIX%/db

-set LOG_BASE=%RABBITMQ_BASE_UNIX%/log

+

+if "%RABBITMQ_MNESIA_BASE%"=="" (

+    set RABBITMQ_MNESIA_BASE=%RABBITMQ_BASE_UNIX%/db

+)

+if "%RABBITMQ_LOG_BASE%"=="" (

+    set RABBITMQ_LOG_BASE=%RABBITMQ_BASE_UNIX%/log

+)

 

 

 rem We save the previous logs in their respective backup

@@ -86,11 +91,11 @@ rem Log management (rotation, filtering based on size...) is left as an exercise
 

 set BACKUP_EXTENSION=.1

 

-set LOGS="%RABBITMQ_BASE%\log\%NODENAME%.log"

-set SASL_LOGS="%RABBITMQ_BASE%\log\%NODENAME%-sasl.log"

+set LOGS="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%.log"

+set SASL_LOGS="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%-sasl.log"

 

-set LOGS_BACKUP="%RABBITMQ_BASE%\log\%NODENAME%.log%BACKUP_EXTENSION%"

-set SASL_LOGS_BACKUP="%RABBITMQ_BASE%\log\%NODENAME%-sasl.log%BACKUP_EXTENSION%"

+set LOGS_BACKUP="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%.log%BACKUP_EXTENSION%"

+set SASL_LOGS_BACKUP="%RABBITMQ_BASE%\log\%RABBITMQ_NODENAME%-sasl.log%BACKUP_EXTENSION%"

 

 if exist %LOGS% (

 	type %LOGS% >> %LOGS_BACKUP%

@@ -102,13 +107,17 @@ if exist %SASL_LOGS% (
 rem End of log management

 

 

-set CLUSTER_CONFIG_FILE=%RABBITMQ_BASE%\rabbitmq_cluster.config

+if "%RABBITMQ_CLUSTER_CONFIG_FILE%"=="" (

+    set RABBITMQ_CLUSTER_CONFIG_FILE=%RABBITMQ_BASE%\rabbitmq_cluster.config

+)

 set CLUSTER_CONFIG=

-if not exist "%CLUSTER_CONFIG_FILE%" GOTO L1

-set CLUSTER_CONFIG=-rabbit cluster_config \""%CLUSTER_CONFIG_FILE:\=/%"\"

+if not exist "%RABBITMQ_CLUSTER_CONFIG_FILE%" GOTO L1

+set CLUSTER_CONFIG=-rabbit cluster_config \""%RABBITMQ_CLUSTER_CONFIG_FILE:\=/%"\"

 :L1

 

-set MNESIA_DIR=%MNESIA_BASE%/%NODENAME%-mnesia

+if "%RABBITMQ_MNESIA_DIR%"=="" (

+    set RABBITMQ_MNESIA_DIR=%RABBITMQ_MNESIA_BASE%/%RABBITMQ_NODENAME%-mnesia

+)

 

 

 if "%1" == "install" goto INSTALL_SERVICE

@@ -120,16 +129,16 @@ echo Service control usage
 echo *********************

 echo.

 echo %~n0 help    - Display this help

-echo %~n0 install - Install the %SERVICENAME% service

-echo %~n0 remove  - Remove the %SERVICENAME% service

+echo %~n0 install - Install the %RABBITMQ_SERVICENAME% service

+echo %~n0 remove  - Remove the %RABBITMQ_SERVICENAME% service

 echo.

 echo The following actions can also be accomplished by using 

 echo Windows Services Management Console (services.msc):

 echo.

-echo %~n0 start   - Start the %SERVICENAME% service

-echo %~n0 stop    - Stop the %SERVICENAME% service

-echo %~n0 disable - Disable the %SERVICENAME% service

-echo %~n0 enable  - Enable the %SERVICENAME% service

+echo %~n0 start   - Start the %RABBITMQ_SERVICENAME% service

+echo %~n0 stop    - Stop the %RABBITMQ_SERVICENAME% service

+echo %~n0 disable - Disable the %RABBITMQ_SERVICENAME% service

+echo %~n0 enable  - Enable the %RABBITMQ_SERVICENAME% service

 echo.

 exit /B

 

@@ -140,11 +149,11 @@ if not exist "%RABBITMQ_BASE%" (
     echo Creating base directory %RABBITMQ_BASE% & md "%RABBITMQ_BASE%" 

 )

 

-"%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" list %SERVICENAME% 2>NUL 1>NUL

+"%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" list %RABBITMQ_SERVICENAME% 2>NUL 1>NUL

 if errorlevel 1 (

-    "%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" add %SERVICENAME%

+    "%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" add %RABBITMQ_SERVICENAME%

 ) else (

-    echo %SERVICENAME% service is already present - only updating service parameters

+    echo %RABBITMQ_SERVICENAME% service is already present - only updating service parameters

 )

 

 set RABBIT_EBIN=%~dp0..\ebin

@@ -157,30 +166,30 @@ set ERLANG_SERVICE_ARGUMENTS= ^
 +A30 ^

 -kernel inet_default_listen_options "[{nodelay,true},{sndbuf,16384},{recbuf,4096}]" ^

 -kernel inet_default_connect_options "[{nodelay,true}]" ^

--rabbit tcp_listeners "[{\"%NODE_IP_ADDRESS%\",%NODE_PORT%}]" ^

--kernel error_logger {file,\""%LOG_BASE%/%NODENAME%.log"\"} ^

+-rabbit tcp_listeners "[{\"%RABBITMQ_NODE_IP_ADDRESS%\",%RABBITMQ_NODE_PORT%}]" ^

+-kernel error_logger {file,\""%RABBITMQ_LOG_BASE%/%RABBITMQ_NODENAME%.log"\"} ^

 -sasl errlog_type error ^

--sasl sasl_error_logger {file,\""%LOG_BASE%/%NODENAME%-sasl.log"\"} ^

+-sasl sasl_error_logger {file,\""%RABBITMQ_LOG_BASE%/%RABBITMQ_NODENAME%-sasl.log"\"} ^

 -os_mon start_cpu_sup true ^

 -os_mon start_disksup false ^

 -os_mon start_memsup true ^

 -os_mon start_os_sup false ^

 -os_mon memsup_system_only true ^

 -os_mon system_memory_high_watermark 0.95 ^

--mnesia dir \""%MNESIA_DIR%"\" ^

+-mnesia dir \""%RABBITMQ_MNESIA_DIR%"\" ^

 %CLUSTER_CONFIG% ^

-%RABBIT_ARGS% ^

+%RABBITMQ_SERVER_START_ARGS% ^

 %*

 

 set ERLANG_SERVICE_ARGUMENTS=%ERLANG_SERVICE_ARGUMENTS:\=\\%

 set ERLANG_SERVICE_ARGUMENTS=%ERLANG_SERVICE_ARGUMENTS:"=\"%

 

-"%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" set %SERVICENAME% ^

+"%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" set %RABBITMQ_SERVICENAME% ^

 -machine "%ERLANG_SERVICE_MANAGER_PATH%\erl.exe" ^

 -env ERL_CRASH_DUMP="%RABBITMQ_BASE_UNIX%/log" ^

 -workdir "%RABBITMQ_BASE%" ^

 -stopaction "rabbit:stop_and_halt()." ^

--sname %NODENAME% ^

+-sname %RABBITMQ_NODENAME% ^

 %CONSOLE_FLAG% ^

 -args "%ERLANG_SERVICE_ARGUMENTS%" > NUL

 goto END

@@ -188,7 +197,7 @@ goto END
 

 :MODIFY_SERVICE

 

-"%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" %1 %SERVICENAME%

+"%ERLANG_SERVICE_MANAGER_PATH%\erlsrv" %1 %RABBITMQ_SERVICENAME%

 goto END