Skip to content

Commit 9ac497a

Browse files
authored
Merge pull request #1735 from rabbitmq/fix/cluster-operator-1677
Update condition to enable Web MQTT/STOMP TLS ports
2 parents d41c06d + 376cecf commit 9ac497a

File tree

1 file changed

+11
-13
lines changed

1 file changed

+11
-13
lines changed

internal/resource/statefulset.go

Lines changed: 11 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -997,20 +997,18 @@ func (builder *StatefulSetBuilder) updateContainerPorts() []corev1.ContainerPort
997997
})
998998
}
999999

1000-
if builder.Instance.MutualTLSEnabled() {
1001-
if builder.Instance.AdditionalPluginEnabled("rabbitmq_web_mqtt") {
1002-
ports = append(ports, corev1.ContainerPort{
1003-
Name: "web-mqtt-tls",
1004-
ContainerPort: 15676,
1005-
})
1006-
}
1000+
if builder.Instance.AdditionalPluginEnabled("rabbitmq_web_mqtt") {
1001+
ports = append(ports, corev1.ContainerPort{
1002+
Name: "web-mqtt-tls",
1003+
ContainerPort: 15676,
1004+
})
1005+
}
10071006

1008-
if builder.Instance.AdditionalPluginEnabled("rabbitmq_web_stomp") {
1009-
ports = append(ports, corev1.ContainerPort{
1010-
Name: "web-stomp-tls",
1011-
ContainerPort: 15673,
1012-
})
1013-
}
1007+
if builder.Instance.AdditionalPluginEnabled("rabbitmq_web_stomp") {
1008+
ports = append(ports, corev1.ContainerPort{
1009+
Name: "web-stomp-tls",
1010+
ContainerPort: 15673,
1011+
})
10141012
}
10151013
}
10161014

0 commit comments

Comments
 (0)