@@ -881,6 +881,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
881881 if r .Spec .Cinder .Template .MessagingBus .Cluster == "" {
882882 r .Spec .Cinder .Template .MessagingBus .Cluster = "rabbitmq"
883883 }
884+ // Propagate top-level NotificationsBus to template if not already set
885+ // This prevents the service operator's Default() from using the deprecated field
886+ if r .Spec .Cinder .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
887+ r .Spec .Cinder .Template .NotificationsBus = r .Spec .NotificationsBus
888+ }
884889 r .Spec .Cinder .Template .Default ()
885890 initializeOverrideSpec (& r .Spec .Cinder .APIOverride .Route , true )
886891 r .Spec .Cinder .Template .SetDefaultRouteAnnotations (r .Spec .Cinder .APIOverride .Route .Annotations )
@@ -910,7 +915,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
910915 if r .Spec .Glance .Template == nil {
911916 r .Spec .Glance .Template = & glancev1.GlanceSpecCore {}
912917 }
913- // Glance only uses NotificationsBus (optional) - don't default it
918+ // Propagate top-level NotificationsBus to template if not already set
919+ // This prevents the service operator's Default() from using the deprecated field
920+ if r .Spec .Glance .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
921+ r .Spec .Glance .Template .NotificationsBus = r .Spec .NotificationsBus
922+ }
914923 r .Spec .Glance .Template .Default ()
915924 // initialize the main APIOverride struct
916925 if r .Spec .Glance .APIOverride == nil {
@@ -975,7 +984,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
975984 if r .Spec .Keystone .Template == nil {
976985 r .Spec .Keystone .Template = & keystonev1.KeystoneAPISpecCore {}
977986 }
978- // Keystone only uses NotificationsBus (optional) - don't default it
987+ // Propagate top-level NotificationsBus to template if not already set
988+ // This prevents the service operator's Default() from using the deprecated field
989+ if r .Spec .Keystone .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
990+ r .Spec .Keystone .Template .NotificationsBus = r .Spec .NotificationsBus
991+ }
979992 r .Spec .Keystone .Template .Default ()
980993 initializeOverrideSpec (& r .Spec .Keystone .APIOverride .Route , true )
981994 r .Spec .Keystone .Template .SetDefaultRouteAnnotations (r .Spec .Keystone .APIOverride .Route .Annotations )
@@ -990,6 +1003,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
9901003 if r .Spec .Manila .Template .MessagingBus .Cluster == "" {
9911004 r .Spec .Manila .Template .MessagingBus .Cluster = "rabbitmq"
9921005 }
1006+ // Propagate top-level NotificationsBus to template if not already set
1007+ // This prevents the service operator's Default() from using the deprecated field
1008+ if r .Spec .Manila .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
1009+ r .Spec .Manila .Template .NotificationsBus = r .Spec .NotificationsBus
1010+ }
9931011 r .Spec .Manila .Template .Default ()
9941012 initializeOverrideSpec (& r .Spec .Manila .APIOverride .Route , true )
9951013 r .Spec .Manila .Template .SetDefaultRouteAnnotations (r .Spec .Manila .APIOverride .Route .Annotations )
@@ -1017,6 +1035,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
10171035 if r .Spec .Neutron .Template .MessagingBus .Cluster == "" {
10181036 r .Spec .Neutron .Template .MessagingBus .Cluster = "rabbitmq"
10191037 }
1038+ // Propagate top-level NotificationsBus to template if not already set
1039+ // This prevents the service operator's Default() from using the deprecated field
1040+ if r .Spec .Neutron .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
1041+ r .Spec .Neutron .Template .NotificationsBus = r .Spec .NotificationsBus
1042+ }
10201043 r .Spec .Neutron .Template .Default ()
10211044 initializeOverrideSpec (& r .Spec .Neutron .APIOverride .Route , true )
10221045 r .Spec .Neutron .Template .SetDefaultRouteAnnotations (r .Spec .Neutron .APIOverride .Route .Annotations )
@@ -1032,6 +1055,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
10321055 if r .Spec .Nova .Template .MessagingBus .Cluster == "" {
10331056 r .Spec .Nova .Template .MessagingBus .Cluster = "rabbitmq"
10341057 }
1058+ // Propagate top-level NotificationsBus to template if not already set
1059+ // This prevents the service operator's Default() from using the deprecated field
1060+ if r .Spec .Nova .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
1061+ r .Spec .Nova .Template .NotificationsBus = r .Spec .NotificationsBus
1062+ }
10351063 r .Spec .Nova .Template .Default ()
10361064 initializeOverrideSpec (& r .Spec .Nova .APIOverride .Route , true )
10371065 r .Spec .Nova .Template .SetDefaultRouteAnnotations (r .Spec .Nova .APIOverride .Route .Annotations )
@@ -1183,6 +1211,11 @@ func (r *OpenStackControlPlane) DefaultServices() {
11831211 if r .Spec .Watcher .Template .MessagingBus .Cluster == "" {
11841212 r .Spec .Watcher .Template .MessagingBus .Cluster = "rabbitmq"
11851213 }
1214+ // Propagate top-level NotificationsBus to template if not already set
1215+ // This prevents the service operator's Default() from using the deprecated field
1216+ if r .Spec .Watcher .Template .NotificationsBus == nil && r .Spec .NotificationsBus != nil {
1217+ r .Spec .Watcher .Template .NotificationsBus = r .Spec .NotificationsBus
1218+ }
11861219 r .Spec .Watcher .Template .Default ()
11871220
11881221 if r .Spec .Watcher .Enabled {
0 commit comments