@@ -124,7 +124,11 @@ cluster_was_formed(Config) ->
124
124
? assertEqual (lists :sort (N2Nodes ), lists :sort (N3Nodes )).
125
125
126
126
register_tagged_task (Config ) ->
127
+ RabbitmqDefaultUser = ? config (rabbitmq_default_user , Config ),
128
+ RabbitmqDefaultPass = ? config (rabbitmq_default_pass , Config ),
127
129
RabbitmqConf = string :join ([
130
+ " default_user = " ++ RabbitmqDefaultUser ,
131
+ " default_pass = " ++ RabbitmqDefaultPass ,
128
132
" cluster_formation.peer_discovery_backend = aws" ,
129
133
" cluster_formation.aws.instance_tags.service = rabbitmq" ,
130
134
" "
@@ -133,7 +137,11 @@ register_tagged_task(Config) ->
133
137
aws_ecs_util :register_task (Config , TaskJson ).
134
138
135
139
register_autoscaled_task (Config ) ->
140
+ RabbitmqDefaultUser = ? config (rabbitmq_default_user , Config ),
141
+ RabbitmqDefaultPass = ? config (rabbitmq_default_pass , Config ),
136
142
RabbitmqConf = string :join ([
143
+ " default_user = " ++ RabbitmqDefaultUser ,
144
+ " default_pass = " ++ RabbitmqDefaultPass ,
137
145
" cluster_formation.peer_discovery_backend = aws" ,
138
146
" cluster_formation.aws.use_autoscaling_group = true" ,
139
147
" "
@@ -156,11 +164,7 @@ task_json(Config, RabbitmqConf) ->
156
164
RabbitContainerDef1 =
157
165
RabbitContainerDef #{
158
166
<<" image" >> := list_to_binary (RabbitmqImage ),
159
- <<" environment" >> := [#{<<" name" >> => <<" RABBITMQ_DEFAULT_USER" >>,
160
- <<" value" >> => list_to_binary (RabbitmqDefaultUser )},
161
- #{<<" name" >> => <<" RABBITMQ_DEFAULT_PASS" >>,
162
- <<" value" >> => list_to_binary (RabbitmqDefaultPass )},
163
- #{<<" name" >> => <<" RABBITMQ_ERLANG_COOKIE" >>,
167
+ <<" environment" >> := [#{<<" name" >> => <<" RABBITMQ_ERLANG_COOKIE" >>,
164
168
<<" value" >> => list_to_binary (RabbitmqErlangCookie )}]
165
169
},
166
170
SidecarContainerDef1 =
0 commit comments