@@ -49,10 +49,9 @@ public NextAction apply(Packet packet) {
49
49
String serverName = (String ) packet .get (ProcessingConstants .SERVER_NAME );
50
50
Integer port = (Integer ) packet .get (ProcessingConstants .PORT );
51
51
Integer nodePort = (Integer ) packet .get (ProcessingConstants .NODE_PORT );
52
-
52
+
53
53
Domain dom = info .getDomain ();
54
54
V1ObjectMeta meta = dom .getMetadata ();
55
-
56
55
DomainSpec spec = dom .getSpec ();
57
56
String namespace = meta .getNamespace ();
58
57
@@ -74,19 +73,19 @@ public NextAction apply(Packet packet) {
74
73
75
74
AnnotationHelper .annotateWithDomain (metadata , dom );
76
75
metadata .putAnnotationsItem ("service.alpha.kubernetes.io/tolerate-unready-endpoints" , "true" );
77
-
76
+
78
77
V1ServiceSpec serviceSpec = new V1ServiceSpec ();
79
78
serviceSpec .setType (nodePort == null ? "ClusterIP" : "NodePort" );
80
-
79
+
81
80
Map <String , String > selector = new HashMap <>();
82
81
selector .put (LabelConstants .DOMAINUID_LABEL , weblogicDomainUID );
83
82
selector .put (LabelConstants .SERVERNAME_LABEL , serverName );
84
83
serviceSpec .setSelector (selector );
85
-
84
+
86
85
if (version != null && (version .major > 1 || (version .major == 1 && version .minor >= 8 ))) {
87
86
serviceSpec .setPublishNotReadyAddresses (Boolean .TRUE );
88
87
}
89
-
88
+
90
89
List <V1ServicePort > ports = new ArrayList <>();
91
90
V1ServicePort servicePort = new V1ServicePort ();
92
91
servicePort .setPort (port );
0 commit comments