File tree Expand file tree Collapse file tree 1 file changed +7
-1
lines changed
operator/src/main/java/oracle/kubernetes/operator Expand file tree Collapse file tree 1 file changed +7
-1
lines changed Original file line number Diff line number Diff line change 3333import oracle .kubernetes .operator .helpers .ServiceHelper ;
3434import oracle .kubernetes .operator .logging .LoggingFacade ;
3535import oracle .kubernetes .operator .logging .LoggingFactory ;
36+ import oracle .kubernetes .operator .work .FiberGate ;
3637import oracle .kubernetes .operator .work .Packet ;
3738import oracle .kubernetes .weblogic .domain .model .ClusterList ;
3839import oracle .kubernetes .weblogic .domain .model .ClusterResource ;
@@ -225,7 +226,12 @@ private void updateDeletedDomainsInDPI(DomainList list) {
225226 }
226227
227228 private boolean isNotBeingProcessed (String namespace , String domainUid ) {
228- return processor .getMakeRightFiberGateMap ().get (namespace ).getCurrentFibers ().get (domainUid ) == null ;
229+ return Optional .ofNullable (processor )
230+ .map (DomainProcessor ::getMakeRightFiberGateMap )
231+ .map (m -> m .get (namespace ))
232+ .map (FiberGate ::getCurrentFibers )
233+ .map (f -> f .get (domainUid ))
234+ .isEmpty ();
229235 }
230236
231237 private void addDomain (DomainResource domain ) {
You can’t perform that action at this time.
0 commit comments