Skip to content

Commit b666516

Browse files
committed
Changed to the custom channel name validation
1 parent c0b2397 commit b666516

File tree

1 file changed

+10
-7
lines changed

1 file changed

+10
-7
lines changed

operator/src/main/resources/scripts/introspectDomain.py

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -246,6 +246,7 @@ def __init__(self, env):
246246
def validate(self):
247247
self.validateAdminServer()
248248
self.validateClusters()
249+
self.validateServerCustomChannelName()
249250
return self.isValid()
250251

251252
def generate(self):
@@ -290,7 +291,6 @@ def validateAdminServer(self):
290291
cluster = adminServer.getCluster()
291292
if cluster != None:
292293
self.addError("The admin server " + self.name(adminServer) + " belongs to the cluster " + self.name(cluster) + ".")
293-
self.validateServerCustomChannelName(self, adminServer)
294294

295295
def validateClusters(self):
296296
for cluster in self.env.getDomain().getClusters():
@@ -359,13 +359,16 @@ def validateDynamicClusterDynamicServersDoNotUseCalculatedListenPorts(self, clus
359359
if cluster.getDynamicServers().isCalculatedListenPorts() == True:
360360
self.addError("The dynamic cluster " + self.name(cluster) + "'s dynamic servers use calculated listen ports.")
361361

362-
def validateServerCustomChannelName(self, server):
362+
def validateServerCustomChannelName(self):
363363
reservedNames = ['default','defaultSecure','defaultAdmin']
364-
naps = server.getNetworkAccessPoints()
365-
for nap in naps:
366-
name=self.name(nap)
367-
if name in reservedNames:
368-
self.addError("The custom channel " + name + " is a reserved name."
364+
for server in self.env.getDomain().getServers():
365+
naps = server.getNetworkAccessPoints()
366+
for nap in naps:
367+
name=self.name(nap)
368+
if name in reservedNames:
369+
self.addError("The custom channel " + name + " is a reserved name."
370+
371+
def validateClusterServersHaveSameCustomChannels():
369372

370373
def isValid(self):
371374
return len(self.errors) == 0

0 commit comments

Comments
 (0)