/* * Decompiled with CFR 0.152. * * Could not load the following classes: * com.l7tech.common.http.GenericHttpClientFactory * com.l7tech.common.http.SimpleHttpClient * com.l7tech.common.io.DocumentReferenceProcessor * com.l7tech.common.io.DocumentReferenceProcessor$ResourceResolver * com.l7tech.gateway.common.audit.AuditDetailMessage * com.l7tech.gateway.common.audit.Messages$M * com.l7tech.gateway.common.audit.SystemMessages * com.l7tech.gateway.common.service.PublishedService * com.l7tech.gateway.common.service.ServiceDocument * com.l7tech.gateway.common.service.ServiceDocumentWsdlStrategy * com.l7tech.gateway.common.uddi.UDDIRegistry * com.l7tech.gateway.common.uddi.UDDIServiceControl * com.l7tech.gateway.common.uddi.UDDIServiceControlRuntime * com.l7tech.objectmodel.FindException * com.l7tech.objectmodel.Goid * com.l7tech.objectmodel.ObjectModelException * com.l7tech.objectmodel.PersistentEntity * com.l7tech.objectmodel.UpdateException * com.l7tech.uddi.UDDIClient * com.l7tech.uddi.UDDIException * com.l7tech.uddi.UDDIOperationalInfo * com.l7tech.uddi.UDDIUtilities * com.l7tech.uddi.UDDIUtilities$UDDIBindingImplementionInfo * com.l7tech.util.Config * com.l7tech.util.ConfigFactory * com.l7tech.util.ExceptionUtils * com.l7tech.util.ResourceUtils * com.l7tech.util.TimeUnit * com.l7tech.wsdl.ResourceTrackingWSDLLocator * com.l7tech.wsdl.Wsdl * javax.wsdl.WSDLException */ package com.l7tech.server.uddi; import com.l7tech.common.http.GenericHttpClientFactory; import com.l7tech.common.http.SimpleHttpClient; import com.l7tech.common.io.DocumentReferenceProcessor; import com.l7tech.gateway.common.audit.AuditDetailMessage; import com.l7tech.gateway.common.audit.Messages; import com.l7tech.gateway.common.audit.SystemMessages; import com.l7tech.gateway.common.service.PublishedService; import com.l7tech.gateway.common.service.ServiceDocument; import com.l7tech.gateway.common.service.ServiceDocumentWsdlStrategy; import com.l7tech.gateway.common.uddi.UDDIRegistry; import com.l7tech.gateway.common.uddi.UDDIServiceControl; import com.l7tech.gateway.common.uddi.UDDIServiceControlRuntime; import com.l7tech.objectmodel.FindException; import com.l7tech.objectmodel.Goid; import com.l7tech.objectmodel.ObjectModelException; import com.l7tech.objectmodel.PersistentEntity; import com.l7tech.objectmodel.UpdateException; import com.l7tech.server.service.ServiceDocumentManager; import com.l7tech.server.service.ServiceManager; import com.l7tech.server.uddi.NotificationUDDIEvent; import com.l7tech.server.uddi.PollUDDIEvent; import com.l7tech.server.uddi.SubscribeUDDIEvent; import com.l7tech.server.uddi.TimerUDDIEvent; import com.l7tech.server.uddi.UDDIHelper; import com.l7tech.server.uddi.UDDIRegistryManager; import com.l7tech.server.uddi.UDDIRegistrySubscriptionManager; import com.l7tech.server.uddi.UDDIServiceControlManager; import com.l7tech.server.uddi.UDDIServiceControlRuntimeManager; import com.l7tech.server.uddi.UDDITaskFactory; import com.l7tech.server.uddi.UpdateAllMonitoredServicesUDDIEvent; import com.l7tech.server.uddi.ae; import com.l7tech.server.uddi.af; import com.l7tech.server.uddi.ag; import com.l7tech.server.uddi.ah; import com.l7tech.server.uddi.ai; import com.l7tech.server.uddi.c; import com.l7tech.server.uddi.d; import com.l7tech.server.uddi.e; import com.l7tech.server.uddi.o; import com.l7tech.server.uddi.p; import com.l7tech.uddi.UDDIClient; import com.l7tech.uddi.UDDIException; import com.l7tech.uddi.UDDIOperationalInfo; import com.l7tech.uddi.UDDIUtilities; import com.l7tech.util.Config; import com.l7tech.util.ConfigFactory; import com.l7tech.util.ExceptionUtils; import com.l7tech.util.ResourceUtils; import com.l7tech.util.TimeUnit; import com.l7tech.wsdl.ResourceTrackingWSDLLocator; import com.l7tech.wsdl.Wsdl; import java.io.Closeable; import java.io.IOException; import java.net.MalformedURLException; import java.net.URL; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.Map; import java.util.logging.Level; import java.util.logging.Logger; import javax.wsdl.WSDLException; public class SubscriptionUDDITaskFactory extends UDDITaskFactory { private static final long a; private static final long b; private final UDDIRegistryManager c; private final UDDIHelper d; private final UDDIRegistrySubscriptionManager e; private final UDDIServiceControlManager f; private final UDDIServiceControlRuntimeManager g; private final ServiceManager h; private final ServiceDocumentManager i; private final GenericHttpClientFactory j; private final Config k; private static final String[] l; public SubscriptionUDDITaskFactory(UDDIRegistryManager uDDIRegistryManager, UDDIHelper uDDIHelper, UDDIRegistrySubscriptionManager uDDIRegistrySubscriptionManager, UDDIServiceControlManager uDDIServiceControlManager, UDDIServiceControlRuntimeManager uDDIServiceControlRuntimeManager, ServiceManager serviceManager, ServiceDocumentManager serviceDocumentManager, GenericHttpClientFactory genericHttpClientFactory) { this.c = uDDIRegistryManager; this.d = uDDIHelper; this.e = uDDIRegistrySubscriptionManager; this.f = uDDIServiceControlManager; this.g = uDDIServiceControlRuntimeManager; this.h = serviceManager; this.i = serviceDocumentManager; this.j = genericHttpClientFactory; this.k = ConfigFactory.getCachedConfig(); } @Override public UDDITaskFactory.UDDITask buildUDDITask(o o2) { UDDITaskFactory.UDDITask uDDITask = null; if (o2 instanceof TimerUDDIEvent) { TimerUDDIEvent timerUDDIEvent = (TimerUDDIEvent)o2; if (timerUDDIEvent.b() == TimerUDDIEvent.Type.SUBSCRIPTION_POLL) { uDDITask = new ag(this, timerUDDIEvent.a(), -1L, -1L); } } else if (o2 instanceof PollUDDIEvent) { PollUDDIEvent pollUDDIEvent = (PollUDDIEvent)o2; uDDITask = new ag(this, pollUDDIEvent.getRegistryGoid(), pollUDDIEvent.getStartTime(), pollUDDIEvent.getEndTime()); } else if (o2 instanceof SubscribeUDDIEvent) { SubscribeUDDIEvent subscribeUDDIEvent = (SubscribeUDDIEvent)o2; switch (com.l7tech.server.uddi.c.a[subscribeUDDIEvent.b().ordinal()]) { case 1: { uDDITask = new ae(this, subscribeUDDIEvent.a(), subscribeUDDIEvent.c()); break; } case 2: { uDDITask = new ah(this, subscribeUDDIEvent.a()); } } } else if (o2 instanceof NotificationUDDIEvent) { NotificationUDDIEvent notificationUDDIEvent = (NotificationUDDIEvent)o2; uDDITask = new af(this, notificationUDDIEvent.getMessage()); } else if (o2 instanceof p) { p p2 = (p)o2; uDDITask = new BusinessServiceUpdateUDDITask(this, p2.b(), p2.a(), p2.c(), p2.isForceUpdate()); } else if (o2 instanceof UpdateAllMonitoredServicesUDDIEvent) { UpdateAllMonitoredServicesUDDIEvent updateAllMonitoredServicesUDDIEvent = (UpdateAllMonitoredServicesUDDIEvent)o2; uDDITask = new ai(this, updateAllMonitoredServicesUDDIEvent.a()); } return uDDITask; } private static String a(UDDIRegistry uDDIRegistry) { return uDDIRegistry.getName() + l[2] + String.valueOf(uDDIRegistry.getGoid()) + ")"; } /* * Enabled aggressive block sorting */ static { String[] stringArray = new String[3]; int n2 = 0; String string = "\u0004\u000f#WSIM\u0002\u0003&WL\u001bK\u0011\u0005\rV\u0011W\"\u0018>\u0010M\u0007p\t\u0014+\u000bI\u001fU1\u0004\u000f#WSIM\u0002\u0003&WL\u001bK\u0011\u0005\rV\u0011W5\u0005 \u001cH*Q\u0015\u0005=\u0011P\u0012]\u0003GHm"; int n3 = "\u0004\u000f#WSIM\u0002\u0003&WL\u001bK\u0011\u0005\rV\u0011W\"\u0018>\u0010M\u0007p\t\u0014+\u000bI\u001fU1\u0004\u000f#WSIM\u0002\u0003&WL\u001bK\u0011\u0005\rV\u0011W5\u0005 \u001cH*Q\u0015\u0005=\u0011P\u0012]\u0003GHm".length(); int n4 = 49; int n5 = -1; while (true) { int n6 = ++n5; stringArray[n2++] = SubscriptionUDDITaskFactory.a(55, SubscriptionUDDITaskFactory.a(string.substring(n6, n6 + n4))); if ((n5 += n4) >= n3) { l = stringArray; String[] stringArray2 = l; a = ConfigFactory.getLongProperty((String)stringArray2[0], (long)TimeUnit.DAYS.toMillis(5L)); b = ConfigFactory.getLongProperty((String)stringArray2[1], (long)TimeUnit.DAYS.toMillis(2L)); return; } n4 = string.charAt(n5); } } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0xE); } return cArray; } /* * Handled impossible loop by duplicating code * Enabled aggressive block sorting */ private static String a(int n2, char[] cArray) { char[] cArray2; block11: { int n3; int n4; int n5; block10: { n5 = n2; cArray2 = cArray; n4 = cArray.length; n3 = 0; if (!true) break block10; n4 = n4; if (n4 <= n3) break block11; } do { n5 = n5; cArray2 = cArray2; int n6 = n3; cArray2[n6] = (char)(cArray2[n6] ^ (n5 ^ (switch (n3 % 7) { case 0 -> 80; case 1 -> 87; case 2 -> 121; case 3 -> 78; case 4 -> 8; case 5 -> 73; default -> 14; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } private static final class BusinessServiceUpdateUDDITask extends UDDITaskFactory.UDDITask { private static final Logger a; private final SubscriptionUDDITaskFactory b; private final String c; private final Goid d; private final boolean e; private final boolean f; private static final String[] g; private BusinessServiceUpdateUDDITask(SubscriptionUDDITaskFactory subscriptionUDDITaskFactory, String string, Goid goid, boolean bl2, boolean bl3) { this.b = subscriptionUDDITaskFactory; this.c = string; this.d = goid; this.e = bl2; this.f = bl3; } /* * WARNING - Removed try catching itself - possible behaviour change. * Loose catch block */ @Override public void apply(UDDITaskFactory.UDDITaskContext uDDITaskContext) throws UDDITaskFactory.UDDITaskException { block75: { try { Collection collection = this.b.f.findByUDDIRegistryAndServiceKey(this.d, this.c, null); boolean bl2 = this.e; String string = this.c; String string2 = String.valueOf(this.d); String[] stringArray = g; a.log(Level.FINE, stringArray[25] + string2 + stringArray[9] + string + stringArray[10] + bl2); if (this.e) { a.log(Level.INFO, stringArray[16] + this.c + stringArray[2] + String.valueOf(this.d) + stringArray[30]); boolean bl3 = false; for (UDDIServiceControl uDDIServiceControl : collection) { bl3 = true; this.b.f.delete((PersistentEntity)uDDIServiceControl); if (!uDDIServiceControl.isUnderUddiControl()) continue; try { if (!uDDIServiceControl.isMonitoringEnabled()) { continue; } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } try { if (!uDDIServiceControl.isDisableServiceOnChange()) continue; this.a(uDDITaskContext, uDDIServiceControl); } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } try { if (bl3) { uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_SERVICE_DELETED, this.c); } break block75; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } UDDIRegistry uDDIRegistry = (UDDIRegistry)this.b.c.findByPrimaryKey(this.d); try { if (uDDIRegistry == null || !uDDIRegistry.isEnabled()) break block75; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } final ArrayList arrayList = new ArrayList(); UDDIClient uDDIClient = null; try { long l2; uDDIClient = this.b.d.newUDDIClient(uDDIRegistry); try { UDDIOperationalInfo uDDIOperationalInfo = uDDIClient.getOperationalInfo(this.c); l2 = uDDIOperationalInfo.getModifiedIncludingChildrenTime(); } catch (UDDIException uDDIException) { String[] stringArray2 = new String[1]; stringArray = g; stringArray2[0] = stringArray[24] + this.c; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_PROCESSING_FAILED, ExceptionUtils.getDebugException((Throwable)uDDIException), stringArray2); throw new UDDITaskFactory.UDDITaskException(stringArray[26] + this.c + stringArray[3] + String.valueOf(uDDIRegistry.getGoid()) + ")"); } for (UDDIServiceControl uDDIServiceControl : collection) { boolean bl4; UDDIServiceControlRuntime uDDIServiceControlRuntime; PublishedService publishedService; block86: { Object object; UDDIUtilities.UDDIBindingImplementionInfo uDDIBindingImplementionInfo; block85: { block83: { String string3; block84: { block80: { Object object2; String[] stringArray3; Messages.M m2; UDDITaskFactory.UDDITaskContext uDDITaskContext2; block82: { block81: { block78: { block79: { block77: { block76: { if (!this.f) break block76; try { if (!uDDIServiceControl.isUnderUddiControl()) { continue; } break block76; catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } try { if (this.f) break block77; if (!uDDIServiceControl.isUnderUddiControl()) continue; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } try { if (!uDDIServiceControl.isMonitoringEnabled()) { continue; } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } publishedService = (PublishedService)this.b.h.findByPrimaryKey(uDDIServiceControl.getPublishedServiceGoid()); uDDIServiceControlRuntime = this.b.g.findByServiceControlGoid(uDDIServiceControl.getGoid()); try { if (this.f) break block78; if (uDDIServiceControlRuntime == null) break block79; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } long l3 = uDDIServiceControlRuntime.getLastUDDIModifiedTimeStamp(); try { if (l2 <= l3) { a.log(Level.FINE, g[39] + uDDIServiceControl.getUddiServiceKey() + g[13] + SubscriptionUDDITaskFactory.a(uDDIRegistry) + "."); continue; } break block78; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } String string4 = String.valueOf(uDDIServiceControl.getPublishedServiceGoid()); String string5 = SubscriptionUDDITaskFactory.a(uDDIRegistry); String string6 = uDDIServiceControl.getUddiServiceKey(); stringArray = g; a.log(Level.WARNING, stringArray[36] + string6 + stringArray[23] + string5 + stringArray[35] + string4 + stringArray[11]); continue; } uDDIBindingImplementionInfo = null; try { uDDIBindingImplementionInfo = UDDIUtilities.getUDDIBindingImplInfo((UDDIClient)uDDIClient, (String)uDDIServiceControl.getUddiServiceKey(), (String)uDDIServiceControl.getWsdlPortName(), (String)uDDIServiceControl.getWsdlPortBinding(), (String)uDDIServiceControl.getWsdlPortBindingNamespace()); } catch (UDDIException uDDIException) { String[] stringArray4 = new String[1]; String string7 = ExceptionUtils.getMessage((Throwable)uDDIException); String string8 = uDDIServiceControl.getUddiServiceKey(); String string9 = uDDIServiceControl.getWsdlPortBinding(); stringArray = g; stringArray4[0] = stringArray[22] + string9 + stringArray[21] + string8 + stringArray[14] + string7; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_PROCESSING_FAILED, ExceptionUtils.getDebugException((Throwable)uDDIException), stringArray4); } if (uDDIBindingImplementionInfo != null) break block80; try { block87: { uDDITaskContext2 = uDDITaskContext; m2 = SystemMessages.UDDI_NOTIFICATION_ENDPOINT_NOT_FOUND; String[] stringArray5 = new String[5]; stringArray5[0] = this.c; stringArray5[1] = uDDIServiceControl.getWsdlPortName(); stringArray5[2] = uDDIServiceControl.getWsdlPortBinding(); String[] stringArray6 = stringArray5; stringArray3 = stringArray5; int n2 = 3; if (uDDIServiceControl.getWsdlPortBindingNamespace() == null) break block81; break block87; catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } object2 = g[34] + uDDIServiceControl.getWsdlPortBindingNamespace() + "'"; break block82; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } object2 = ""; } stringArray6[n2] = object2; stringArray3[4] = SubscriptionUDDITaskFactory.a(uDDIRegistry); uDDITaskContext2.logAndAudit((AuditDetailMessage)m2, stringArray3); this.a(this.b, uDDITaskContext, uDDIRegistry, uDDIServiceControl.getGoid(), publishedService.getGoid()); continue; } bl4 = false; uDDIServiceControl = this.b.f.findByPublishedServiceGoid(uDDIServiceControl.getPublishedServiceGoid()); try { if (uDDIServiceControl == null) { continue; } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } try { string3 = this.a(this.b, uDDIBindingImplementionInfo, uDDIServiceControl, uDDIServiceControlRuntime.getAccessPointURL(), uDDITaskContext, uDDIRegistry, publishedService, this.f); } catch (UDDITaskFactory.UDDIHandledTaskException uDDIHandledTaskException) { arrayList.add(uDDIHandledTaskException); continue; } if (string3 == null) break block83; try { block88: { if (uDDIServiceControlRuntime.getAccessPointURL() == null) break block84; break block88; catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } if (uDDIServiceControlRuntime.getAccessPointURL().equals(string3)) break block83; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } bl4 = true; publishedService.setDefaultRoutingUrl(string3); uDDIServiceControlRuntime.setAccessPointURL(string3); this.b.g.update((PersistentEntity)uDDIServiceControlRuntime); uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_ENDPOINT_UPDATED, String.valueOf(publishedService.getGoid()), string3, this.c, uDDIServiceControl.getWsdlPortName(), SubscriptionUDDITaskFactory.a(uDDIRegistry)); } try { if (!uDDIBindingImplementionInfo.getImplementingWsdlPort().equals(uDDIServiceControl.getWsdlPortName())) { this.b.f.update((PersistentEntity)uDDIServiceControl); uDDIServiceControl.setWsdlPortName(uDDIBindingImplementionInfo.getImplementingWsdlPort()); } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } if (uDDIServiceControl.isUpdateWsdlOnChange()) break block85; try { block89: { if (uDDIServiceControl.isDisableServiceOnChange()) break block85; break block89; catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } if (!this.f) break block86; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } String string10 = uDDIBindingImplementionInfo.getImplementingWsdlUrl(); try { new URL(string10); } catch (MalformedURLException malformedURLException) { String string11 = SubscriptionUDDITaskFactory.a(uDDIRegistry); String string12 = uDDIServiceControl.getUddiServiceKey(); String string13 = uDDIBindingImplementionInfo.getImplementingWsdlUrl(); stringArray = g; object = stringArray[33] + string13 + stringArray[12] + string12 + stringArray[23] + string11 + "."; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_PROCESSING_FAILED, ExceptionUtils.getDebugException((Throwable)malformedURLException), new String[]{object}); throw new UDDITaskFactory.UDDITaskException((String)object); } stringArray = g; int n3 = this.b.k.getIntProperty(stringArray[29], 0xA00000); object = new SimpleHttpClient(this.b.j.createHttpClient(), n3); try { e e10 = new e((SimpleHttpClient)object, publishedService.getWsdlUrl()); DocumentReferenceProcessor documentReferenceProcessor = new DocumentReferenceProcessor(); Map map = documentReferenceProcessor.processDocument(string10, (DocumentReferenceProcessor.ResourceResolver)new d(this, e10)); Collection collection2 = ResourceTrackingWSDLLocator.toWSDLResources((String)string10, (Map)map, (boolean)false, (boolean)false, (boolean)false); List list = ServiceDocumentWsdlStrategy.fromWsdlResources((Collection)collection2); Collection collection3 = this.b.i.findByServiceId(publishedService.getGoid()); Wsdl wsdl = ServiceDocumentWsdlStrategy.parseWsdl((PublishedService)publishedService, collection3); Wsdl wsdl2 = ServiceDocumentWsdlStrategy.parseWsdl((String)string10, (String)((String)map.get(string10)), collection3); if (!wsdl.getHash().equals(wsdl2.getHash())) { bl4 = true; try { if (uDDIServiceControl.isDisableServiceOnChange()) { publishedService.setDisabled(true); uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_SERVICE_DISABLED, publishedService.getId()); } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } try { if (!uDDIServiceControl.isUpdateWsdlOnChange() && !this.f) break block86; } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } publishedService.setWsdlUrl(e10.addAuthentication(string10)); publishedService.setWsdlXml((String)map.get(string10)); for (ServiceDocument serviceDocument : collection3) { this.b.i.delete((PersistentEntity)serviceDocument); } for (ServiceDocument serviceDocument : list) { serviceDocument.setServiceId(publishedService.getGoid()); this.b.i.save((PersistentEntity)serviceDocument); } String[] stringArray7 = new String[1]; stringArray = g; stringArray7[0] = publishedService.displayName() + stringArray[1] + String.valueOf(publishedService.getGoid()) + ")"; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_SERVICE_WSDL_UPDATE, stringArray7); break block86; } String string14 = SubscriptionUDDITaskFactory.a(uDDIRegistry); String string15 = this.c; String string16 = String.valueOf(publishedService.getGoid()); stringArray = g; a.info(stringArray[31] + string16 + stringArray[28] + string15 + stringArray[15] + string14 + "."); } catch (IOException iOException) { String[] stringArray8 = new String[2]; stringArray = g; stringArray8[0] = stringArray[17] + ExceptionUtils.getMessage((Throwable)iOException) + "'"; stringArray8[1] = publishedService.displayName() + stringArray[19] + String.valueOf(publishedService.getGoid()) + ")"; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_SERVICE_WSDL_ERROR, ExceptionUtils.getDebugException((Throwable)iOException), stringArray8); } catch (WSDLException wSDLException) { String[] stringArray9 = new String[2]; stringArray = g; stringArray9[0] = stringArray[37] + ExceptionUtils.getMessage((Throwable)wSDLException) + "'"; stringArray9[1] = publishedService.displayName() + stringArray[19] + String.valueOf(publishedService.getGoid()) + ")"; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_SERVICE_WSDL_ERROR, ExceptionUtils.getDebugException((Throwable)wSDLException), stringArray9); } } try { if (bl4) { this.b.h.update((PersistentEntity)publishedService); } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } uDDIServiceControlRuntime.setLastUDDIModifiedTimeStamp(l2); this.b.g.update((PersistentEntity)uDDIServiceControlRuntime); } } catch (Throwable throwable) { ResourceUtils.closeQuietly(uDDIClient); throw throwable; } ResourceUtils.closeQuietly((Closeable)uDDIClient); try { if (!arrayList.isEmpty()) { throw new UDDITaskFactory.UDDIHandledTaskException(){ static final long serialVersionUID = 96964988311324664L; @Override public void handleTaskError() { for (UDDITaskFactory.UDDIHandledTaskException uDDIHandledTaskException : arrayList) { uDDIHandledTaskException.handleTaskError(); } } }; } } catch (UDDIException uDDIException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)uDDIException)); } } catch (ObjectModelException objectModelException) { String[] stringArray = new String[1]; String[] stringArray10 = g; stringArray[0] = stringArray10[32] + String.valueOf(this.d) + stringArray10[0] + this.c + "."; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_PROCESSING_FAILED, objectModelException, stringArray); } } } private void a(SubscriptionUDDITaskFactory subscriptionUDDITaskFactory, UDDITaskFactory.UDDITaskContext uDDITaskContext, UDDIRegistry uDDIRegistry, Goid goid, Goid goid2) throws UpdateException, FindException { PublishedService publishedService = (PublishedService)subscriptionUDDITaskFactory.h.findByPrimaryKey(goid2); try { if (publishedService == null) { return; } } catch (UpdateException updateException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)updateException)); } publishedService.setDefaultRoutingUrl(null); subscriptionUDDITaskFactory.h.update((PersistentEntity)publishedService); String[] stringArray = g; a.log(Level.INFO, stringArray[7] + String.valueOf(publishedService.getGoid()) + stringArray[20]); UDDIServiceControl uDDIServiceControl = (UDDIServiceControl)subscriptionUDDITaskFactory.f.findByPrimaryKey(goid); try { if (uDDIServiceControl != null) { uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_ORIGINAL_SERVICE_INVALIDATED, this.c, SubscriptionUDDITaskFactory.a(uDDIRegistry), String.valueOf(publishedService.getGoid())); uDDIServiceControl.setUnderUddiControl(false); uDDIServiceControl.setMonitoringEnabled(false); subscriptionUDDITaskFactory.f.update((PersistentEntity)uDDIServiceControl); } } catch (UpdateException updateException) { throw BusinessServiceUpdateUDDITask.a((Exception)((Object)updateException)); } } private void a(UDDITaskFactory.UDDITaskContext uDDITaskContext, UDDIServiceControl uDDIServiceControl) throws FindException, UpdateException { PublishedService publishedService = (PublishedService)this.b.h.findByPrimaryKey(uDDIServiceControl.getPublishedServiceGoid()); publishedService.setDisabled(true); this.b.h.update((PersistentEntity)publishedService); uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_SERVICE_DISABLED, publishedService.getGoid().toString()); } private String a(final SubscriptionUDDITaskFactory subscriptionUDDITaskFactory, UDDIUtilities.UDDIBindingImplementionInfo uDDIBindingImplementionInfo, final UDDIServiceControl uDDIServiceControl, String string, final UDDITaskFactory.UDDITaskContext uDDITaskContext, final UDDIRegistry uDDIRegistry, final PublishedService publishedService, boolean bl2) throws UDDITaskFactory.UDDIHandledTaskException { String string2; block12: { block14: { String string3; block13: { boolean bl3; block15: { block11: { string2 = uDDIBindingImplementionInfo.getEndPoint(); bl3 = true; try { if (string2 != null && !string2.trim().isEmpty()) break block11; } catch (MalformedURLException malformedURLException) { throw BusinessServiceUpdateUDDITask.a(malformedURLException); } bl3 = false; break block15; } try { new URL(string2); } catch (MalformedURLException malformedURLException) { bl3 = false; } } try { if (!bl3) { a.log(Level.INFO, g[4]); return null; } } catch (MalformedURLException malformedURLException) { throw BusinessServiceUpdateUDDITask.a(malformedURLException); } try { if (string.equals(string2) || !subscriptionUDDITaskFactory.d.isGatewayUrl(string2)) break block12; } catch (MalformedURLException malformedURLException) { throw BusinessServiceUpdateUDDITask.a(malformedURLException); } String string4 = string2; String string5 = String.valueOf(publishedService.getGoid()); String string6 = SubscriptionUDDITaskFactory.a(uDDIRegistry); String string7 = uDDIServiceControl.getUddiServiceKey(); String string8 = uDDIServiceControl.getWsdlPortName(); String[] stringArray = g; string3 = stringArray[5] + string8 + stringArray[27] + string7 + stringArray[6] + string6 + stringArray[18] + string5 + stringArray[38] + string4 + stringArray[8]; try { if (bl2) break block13; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.UDDI_NOTIFICATION_PROCESSING_FAILED, string3); break block14; } catch (MalformedURLException malformedURLException) { throw BusinessServiceUpdateUDDITask.a(malformedURLException); } } a.log(Level.WARNING, string3); } throw new UDDITaskFactory.UDDIHandledTaskException(){ static final long serialVersionUID = -2211730700538179762L; private static final String[] a; @Override public void handleTaskError() { try { this.a(subscriptionUDDITaskFactory, uDDITaskContext, uDDIRegistry, uDDIServiceControl.getGoid(), publishedService.getGoid()); } catch (UpdateException updateException) { String[] stringArray = new String[1]; String[] stringArray2 = a; stringArray[0] = stringArray2[0]; uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.DATABASE_ERROR, updateException, stringArray); } catch (FindException findException) { uDDITaskContext.logAndAudit((AuditDetailMessage)SystemMessages.DATABASE_ERROR, findException, a[1]); } } /* * Enabled aggressive block sorting */ static { String[] stringArray = new String[2]; int n2 = 0; String string = "Ir4\u0005Q)[h3%\u0016A'Z-f0\u0000RIr4\u0005Q)[h3%\u0016A'Z-u)\nW!Fj3\u0010\u0011Q$A~{%\u0000\u0013\u001bM\u007fe)\u0007Vh\u0007-F\u0004 z\u001bM\u007fe)\u0007V\u000bGcg2\u000b_f"; int n3 = "Ir4\u0005Q)[h3%\u0016A'Z-f0\u0000RIr4\u0005Q)[h3%\u0016A'Z-u)\nW!Fj3\u0010\u0011Q$A~{%\u0000\u0013\u001bM\u007fe)\u0007Vh\u0007-F\u0004 z\u001bM\u007fe)\u0007V\u000bGcg2\u000b_f".length(); int n4 = 63; int n5 = -1; while (true) { int n6 = ++n5; stringArray[n2++] = 3.a(47, 3.a(string.substring(n6, n6 + n4))); if ((n5 += n4) >= n3) { a = stringArray; return; } n4 = string.charAt(n5); } } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 7); } return cArray; } /* * Handled impossible loop by duplicating code * Enabled aggressive block sorting */ private static String a(int n2, char[] cArray) { char[] cArray2; block11: { int n3; int n4; int n5; block10: { n5 = n2; cArray2 = cArray; n4 = cArray.length; n3 = 0; if (!true) break block10; n4 = n4; if (n4 <= n3) break block11; } do { n5 = n5; cArray2 = cArray2; int n6 = n3; cArray2[n6] = (char)(cArray2[n6] ^ (n5 ^ (switch (n3 % 7) { case 0 -> 34; case 1 -> 60; case 2 -> 111; case 3 -> 75; case 4 -> 28; case 5 -> 103; default -> 7; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } }; } return string2; } /* * Unable to fully structure code */ static { block10: { block9: { var5 = new String[40]; var3_1 = 0; var2_2 = "*$\u001eqj5dx3\u0019v/\rds\u007fP\u0003*mS'*-\u0011fj$do+Pq/*d~ \u00145,4nge%Q\u000e\u000f!X \u0017|92sseS=\u0015*#\u0002z'fTN\u00019G/!hy1\u0002lje)_k&\u0013p95Qe,\u001eaj#mo(\u0015{>fhde\u001dz$/ue7\u0015qj$hd!\u0019{-\u0012dg5\u001ct>#!n,\u00145$)u*&\u001f{>'hde\u0011{3fwk)\u0005pj nxe\u0011{j#on5\u001f|$2!_\u0017<;[Z7\u001fw&#l*2\u0019}j n\u007f+\u00145/(ez*\u0019{>fgx*\u001d5\u00054hm,\u001et&fC\u007f6\u0019{/5r*\u0016\u0015gf&\u0012-e\u0019{j\u0013EN\f\"p-/r~7\t5eI)\u0015t8#e*&\u001f{>#y~e\u0006t8/`h)\u00155n=ro7\u0006|)#/n \u0016t?*uX*\u0005a#(f_\u00174x*\u0003#kP\u000f-e\u0016z8fso\"\u0019f>4x*\u0012Y \u0002c#%d*2\u0019a\"fjo4x*4I*\u0005y.foe1Pr/2!e5\u0015g+2he+P|$ nx(\u0011a#)o*#\u001fgj5dx3\u0019v/\rds\u007fP5Z7\u001fv/5rc+\u00175(3rc+\u0015f9fro7\u0006|)#!\u007f5\u0014t>#/*\u00104Q\u0003\u0014dm,\u0003a8?!),\u0014=4I$\u001e{%2!l,\u001eqj\tqo7\u0011a#)ok)P\\$ nx(\u0011a#)o*#\u001fgj5dx3\u0019v/\rds\u007fP\u0017-e\u0019{j\u0013EN\fPs%4!y \u0002c#%d*bH#e'F\u000e\n!c6P{%2!\u007f5\u0014t>#e*$\u00035#2!c6Pt&4dk!\t5?6!~*Pq+2d*#\u001fgj$ty,\u001ep95!y \u0002c#%d*b\u0018n*\u0013`'#o~\u0001\u001fb$*nk!^x+>Rc?\u0015+#kPG/+n|,\u001erj4di*\u0002qj)g*\u00104Q\u0003fC\u007f6\u0019{/5rY \u0002c#%d$\u0014Z0\u0012y#5io!PF/4wc&\u00155in:N$\u0004t('roe\u0015g8)s*2\u0018p$fqx*\u0013p95hd\"P{%2hl,\u0013t>/nde\u0016z8fso\"\u0019f>4x*f0]\u00164Yj\u0013SFe\u001fw>'hd \u00145,4nge%Q\u000e\u000f!c6P{%2!ke\u0006t&/e*\u0010\"Yjn\u000bd$\u001dp96`i P2\u001d$e\"p&'uo!PE?$mc6\u0018p.\u0015dx3\u0019v/f\"\"fX \u0013p#0dne\u001ez>/gc&\u0011a#)o*#\u001fgj5dx3\u0019v/fge7Pb\"/bbe\u0007pj.`ne\u001ezj6dx6\u0019f>#e*7\u0005{>/loe\u0019{,)sg$\u0004|%(/*\u0007\u0005f#(dy6#p80hi J5\u0007I$\u0005f/f&"; var4_3 = "*$\u001eqj5dx3\u0019v/\rds\u007fP\u0003*mS'*-\u0011fj$do+Pq/*d~ \u00145,4nge%Q\u000e\u000f!X \u0017|92sseS=\u0015*#\u0002z'fTN\u00019G/!hy1\u0002lje)_k&\u0013p95Qe,\u001eaj#mo(\u0015{>fhde\u001dz$/ue7\u0015qj$hd!\u0019{-\u0012dg5\u001ct>#!n,\u00145$)u*&\u001f{>'hde\u0011{3fwk)\u0005pj nxe\u0011{j#on5\u001f|$2!_\u0017<;[Z7\u001fw&#l*2\u0019}j n\u007f+\u00145/(ez*\u0019{>fgx*\u001d5\u00054hm,\u001et&fC\u007f6\u0019{/5r*\u0016\u0015gf&\u0012-e\u0019{j\u0013EN\f\"p-/r~7\t5eI)\u0015t8#e*&\u001f{>#y~e\u0006t8/`h)\u00155n=ro7\u0006|)#/n \u0016t?*uX*\u0005a#(f_\u00174x*\u0003#kP\u000f-e\u0016z8fso\"\u0019f>4x*\u0012Y \u0002c#%d*2\u0019a\"fjo4x*4I*\u0005y.foe1Pr/2!e5\u0015g+2he+P|$ nx(\u0011a#)o*#\u001fgj5dx3\u0019v/\rds\u007fP5Z7\u001fv/5rc+\u00175(3rc+\u0015f9fro7\u0006|)#!\u007f5\u0014t>#/*\u00104Q\u0003\u0014dm,\u0003a8?!),\u0014=4I$\u001e{%2!l,\u001eqj\tqo7\u0011a#)ok)P\\$ nx(\u0011a#)o*#\u001fgj5dx3\u0019v/\rds\u007fP\u0017-e\u0019{j\u0013EN\fPs%4!y \u0002c#%d*bH#e'F\u000e\n!c6P{%2!\u007f5\u0014t>#e*$\u00035#2!c6Pt&4dk!\t5?6!~*Pq+2d*#\u001fgj$ty,\u001ep95!y \u0002c#%d*b\u0018n*\u0013`'#o~\u0001\u001fb$*nk!^x+>Rc?\u0015+#kPG/+n|,\u001erj4di*\u0002qj)g*\u00104Q\u0003fC\u007f6\u0019{/5rY \u0002c#%d$\u0014Z0\u0012y#5io!PF/4wc&\u00155in:N$\u0004t('roe\u0015g8)s*2\u0018p$fqx*\u0013p95hd\"P{%2hl,\u0013t>/nde\u0016z8fso\"\u0019f>4x*f0]\u00164Yj\u0013SFe\u001fw>'hd \u00145,4nge%Q\u000e\u000f!c6P{%2!ke\u0006t&/e*\u0010\"Yjn\u000bd$\u001dp96`i P2\u001d$e\"p&'uo!PE?$mc6\u0018p.\u0015dx3\u0019v/f\"\"fX \u0013p#0dne\u001ez>/gc&\u0011a#)o*#\u001fgj5dx3\u0019v/fge7Pb\"/bbe\u0007pj.`ne\u001ezj6dx6\u0019f>#e*7\u0005{>/loe\u0019{,)sg$\u0004|%(/*\u0007\u0005f#(dy6#p80hi J5\u0007I$\u0005f/f&".length(); var1_4 = 17; var0_5 = -1; lbl7: // 2 sources while (true) { v0 = 88; v1 = ++var0_5; v2 = var2_2.substring(v1, v1 + var1_4); v3 = -1; break block9; break; } lbl13: // 1 sources while (true) { var5[var3_1++] = BusinessServiceUpdateUDDITask.a(v0, BusinessServiceUpdateUDDITask.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } var2_2 = "=wNb xm{.\u001an'x}u8\u0005+ 7?`3\u000b+\u00139kq,\u000frnx80F>\rn=.zp{\n~$4vw:\u001ant6p`2\bb79k}4\u0000+27m4(\u000by\"1|q\u0010\u000brnx"; var4_3 = "=wNb xm{.\u001an'x}u8\u0005+ 7?`3\u000b+\u00139kq,\u000frnx80F>\rn=.zp{\n~$4vw:\u001ant6p`2\bb79k}4\u0000+27m4(\u000by\"1|q\u0010\u000brnx".length(); var1_4 = 35; var0_5 = -1; lbl22: // 2 sources while (true) { v0 = 70; v4 = ++var0_5; v2 = var2_2.substring(v4, v4 + var1_4); v3 = 0; break block9; break; } break; } lbl28: // 1 sources while (true) { var5[var3_1++] = BusinessServiceUpdateUDDITask.a(v0, BusinessServiceUpdateUDDITask.a(v2)); if ((var0_5 += var1_4) < var4_3) { var1_4 = var2_2.charAt(var0_5); ** continue; } break block10; break; } } switch (v3) { default: { ** continue; } ** case 0: lbl39: // 1 sources ** continue; } } BusinessServiceUpdateUDDITask.g = var5; BusinessServiceUpdateUDDITask.a = Logger.getLogger(BusinessServiceUpdateUDDITask.class.getName()); } private static Exception a(Exception exception) { return exception; } private static char[] a(String string) { char[] cArray = string.toCharArray(); if (cArray.length < 2) { cArray = cArray; cArray[0] = (char)(cArray[0] ^ 0x59); } return cArray; } /* * Handled impossible loop by duplicating code * Enabled aggressive block sorting */ private static String a(int n2, char[] cArray) { char[] cArray2; block11: { int n3; int n4; int n5; block10: { n5 = n2; cArray2 = cArray; n4 = cArray.length; n3 = 0; if (!true) break block10; n4 = n4; if (n4 <= n3) break block11; } do { n5 = n5; cArray2 = cArray2; int n6 = n3; cArray2[n6] = (char)(cArray2[n6] ^ (n5 ^ (switch (n3 % 7) { case 0 -> 82; case 1 -> 29; case 2 -> 40; case 3 -> 77; case 4 -> 18; case 5 -> 30; default -> 89; }))); ++n3; n4 = n4; } while (n4 > n3); } return new String(cArray2).intern(); } } }