public class org.apache.camel.management.DefaultManagementLifecycleStrategy extends org.apache.camel.support.ServiceSupport implements org.apache.camel.spi.LifecycleStrategy, org.apache.camel.CamelContextAware { private static final org.slf4j.Logger LOG; private final java.util.Map wrappedProcessors; private final java.util.List preServices; private final org.apache.camel.support.TimerListenerManager loadTimer; private final org.apache.camel.management.DefaultManagementLifecycleStrategy$TimerListenerManagerStartupListener loadTimerStartupListener; private volatile org.apache.camel.CamelContext camelContext; private volatile org.apache.camel.management.mbean.ManagedCamelContext camelContextMBean; private volatile boolean initialized; private final java.util.Set knowRouteIds; private final java.util.Map managedTracers; private final java.util.Map managedBacklogTracers; private final java.util.Map managedBacklogDebuggers; private final java.util.Map managedThreadPools; public void () { org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.util.HashMap v, v, v, v, v; org.apache.camel.management.ManagedLoadTimer v; java.util.ArrayList v; java.util.HashSet v; org.apache.camel.management.DefaultManagementLifecycleStrategy$TimerListenerManagerStartupListener v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new org.apache.camel.management.ManagedLoadTimer; specialinvoke v.()>(); v. = v; v = new org.apache.camel.management.DefaultManagementLifecycleStrategy$TimerListenerManagerStartupListener; specialinvoke v.(org.apache.camel.management.DefaultManagementLifecycleStrategy)>(v); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; return; } public void (org.apache.camel.CamelContext) { org.apache.camel.CamelContext v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.util.HashMap v, v, v, v, v; org.apache.camel.management.ManagedLoadTimer v; java.util.ArrayList v; java.util.HashSet v; org.apache.camel.management.DefaultManagementLifecycleStrategy$TimerListenerManagerStartupListener v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new org.apache.camel.management.ManagedLoadTimer; specialinvoke v.()>(); v. = v; v = new org.apache.camel.management.DefaultManagementLifecycleStrategy$TimerListenerManagerStartupListener; specialinvoke v.(org.apache.camel.management.DefaultManagementLifecycleStrategy)>(v); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v. = v; return; } public org.apache.camel.CamelContext getCamelContext() { org.apache.camel.CamelContext v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v = v.; return v; } public void setCamelContext(org.apache.camel.CamelContext) { org.apache.camel.CamelContext v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v. = v; return; } public void onContextStart(org.apache.camel.CamelContext) throws org.apache.camel.VetoCamelContextStartException { org.apache.camel.spi.ManagementObjectStrategy v, v, v; org.apache.camel.spi.ManagementNameStrategy v, v; boolean v, v, v, v, v; org.apache.camel.RuntimeCamelException v, v; javax.management.ObjectName v; java.lang.Exception v, v, v, v; org.apache.camel.VetoCamelContextStartException v, v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.String v, v, v, v, v, v, v; org.apache.camel.spi.ManagementStrategy v, v; org.apache.camel.CamelContext v, v, v; org.slf4j.Logger v, v, v; org.apache.camel.spi.ManagementNamingStrategy v; java.lang.Object v, v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v = specialinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = 0; label: if v != 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v, v); v = specialinvoke v.(); v = interfaceinvoke v.(v, v); if v != 0 goto label; v = 1; goto label; label: v = 0; v = interfaceinvoke v.(); v = specialinvoke v.(v, v, v); if v == null goto label; v = 1; v = 1; v = v; label: if v != 0 goto label; v = new org.apache.camel.VetoCamelContextStartException; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("CamelContext (\u) with ObjectName[\u] is already registered. Make sure to use unique names on CamelContext when using multiple CamelContexts in the same MBeanServer."); specialinvoke v.(java.lang.String,org.apache.camel.CamelContext)>(v, v); throw v; label: v = ; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("This CamelContext(\u) will be registered using the name: \u due to clash with an existing name already registered in MBeanServer."); interfaceinvoke v.(v); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); throw v; label: v = v instanceof org.apache.camel.impl.DefaultCamelContext; if v == 0 goto label; virtualinvoke v.(v); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = staticinvoke (v); throw v; label: v. = 1; v = v instanceof org.apache.camel.management.mbean.ManagedCamelContext; if v == 0 goto label; v. = v; label: specialinvoke v.(); label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != null goto label; label: return; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not register CamelHealth MBean. This exception will be ignored.", v); label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v); if v != null goto label; label: return; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not register RouteController MBean. This exception will be ignored.", v); label: return; catch org.apache.camel.VetoCamelContextStartException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } private java.lang.String findFreeName(java.lang.Object, org.apache.camel.spi.ManagementNameStrategy, java.lang.String) throws javax.management.MalformedObjectNameException { java.lang.Object[] v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.Boolean v; java.lang.String v, v; org.apache.camel.spi.ManagementNameStrategy v; org.apache.camel.spi.ManagementStrategy v, v; boolean v, v, v, v, v; org.slf4j.Logger v, v; javax.management.ObjectName v; org.apache.camel.spi.ManagementNamingStrategy v; java.lang.Object v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: java.lang.Object; v := @parameter: org.apache.camel.spi.ManagementNameStrategy; v := @parameter: java.lang.String; v = interfaceinvoke v.(); if v == 0 goto label; return null; label: v = 0; v = null; label: if v != 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v, v); v = specialinvoke v.(); v = interfaceinvoke v.(v, v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Using name: {} in ObjectName[{}] exists? {}", v); goto label; label: return v; } private void enlistPreRegisteredServices() { org.apache.camel.Route v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.Component v, v; org.apache.camel.Endpoint v, v; java.lang.Integer v; int v; java.lang.String v; boolean v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v; java.util.Iterator v; java.util.List v, v, v, v; org.apache.camel.Service v, v; java.lang.Object v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; return; label: v = ; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Registering {} pre registered services", v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; interfaceinvoke v.(); return; } public void onContextStop(org.apache.camel.CamelContext) { org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.spi.ManagementObjectStrategy v, v, v; org.apache.camel.spi.ManagementStrategy v, v, v; boolean v, v, v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v, v, v; java.lang.Exception v, v, v; java.lang.Object v, v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v = v.; if v != 0 goto label; return; label: v = specialinvoke v.(); v = interfaceinvoke v.(v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not unregister RouteController MBean", v); label: v = specialinvoke v.(); v = interfaceinvoke v.(v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not unregister CamelHealth MBean", v); label: v = specialinvoke v.(); v = interfaceinvoke v.(v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not unregister CamelContext MBean", v); label: v. = null; return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } public void onComponentAdd(java.lang.String, org.apache.camel.Component) { org.apache.camel.CamelContext v; org.slf4j.Logger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.Component v; java.lang.Exception v; org.apache.camel.spi.ManagementObjectStrategy v; java.util.List v; org.apache.camel.management.DefaultManagementLifecycleStrategy$PreRegisterService v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: java.lang.String; v := @parameter: org.apache.camel.Component; v = v.; if v != 0 goto label; v = new org.apache.camel.management.DefaultManagementLifecycleStrategy$PreRegisterService; specialinvoke v.()>(); virtualinvoke v.(v, v); v = v.; interfaceinvoke v.(v); return; label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not register Component MBean", v); label: return; catch java.lang.Exception from label to label with label; } public void onComponentRemove(java.lang.String, org.apache.camel.Component) { org.apache.camel.CamelContext v; org.slf4j.Logger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.Component v; java.lang.Exception v; org.apache.camel.spi.ManagementObjectStrategy v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: java.lang.String; v := @parameter: org.apache.camel.Component; v = v.; if v != 0 goto label; return; label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not unregister Component MBean", v); label: return; catch java.lang.Exception from label to label with label; } public void onEndpointAdd(org.apache.camel.Endpoint) { org.apache.camel.CamelContext v; org.slf4j.Logger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.Endpoint v; java.lang.Exception v; org.apache.camel.spi.ManagementObjectStrategy v; java.util.List v; org.apache.camel.management.DefaultManagementLifecycleStrategy$PreRegisterService v; java.lang.Object v; java.lang.String v; boolean v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.Endpoint; v = v.; if v != 0 goto label; v = new org.apache.camel.management.DefaultManagementLifecycleStrategy$PreRegisterService; specialinvoke v.()>(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); return; label: v = virtualinvoke v.(v, null); if v != 0 goto label; return; label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); if v != null goto label; label: return; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not register Endpoint MBean for endpoint: \u. This exception will be ignored."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; } public void onEndpointRemove(org.apache.camel.Endpoint) { org.apache.camel.CamelContext v; org.slf4j.Logger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.Endpoint v; java.lang.Exception v; org.apache.camel.spi.ManagementObjectStrategy v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.Endpoint; v = v.; if v != 0 goto label; return; label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not unregister Endpoint MBean for endpoint: \u. This exception will be ignored."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public void onServiceAdd(org.apache.camel.CamelContext, org.apache.camel.Service, org.apache.camel.Route) { org.apache.camel.CamelContext v; org.apache.camel.Route v; org.slf4j.Logger v, v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.Exception v; java.util.List v; org.apache.camel.Service v; org.apache.camel.management.DefaultManagementLifecycleStrategy$PreRegisterService v; java.lang.Object v; java.lang.String v; org.apache.camel.spi.ManagementStrategy v; boolean v, v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v := @parameter: org.apache.camel.Service; v := @parameter: org.apache.camel.Route; v = v.; if v != 0 goto label; v = new org.apache.camel.management.DefaultManagementLifecycleStrategy$PreRegisterService; specialinvoke v.()>(); virtualinvoke v.(v, v, v); v = v.; interfaceinvoke v.(v); return; label: v = virtualinvoke v.(v, v); if v != 0 goto label; return; label: v = specialinvoke v.(v, v, v); if v != null goto label; return; label: v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; v = ; interfaceinvoke v.("The service is already managed: {}", v); return; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not register service: \u as Service MBean."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public void onServiceRemove(org.apache.camel.CamelContext, org.apache.camel.Service, org.apache.camel.Route) { org.apache.camel.CamelContext v; org.apache.camel.Route v; org.slf4j.Logger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.Exception v; org.apache.camel.Service v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v := @parameter: org.apache.camel.Service; v := @parameter: org.apache.camel.Route; v = v.; if v != 0 goto label; return; label: v = specialinvoke v.(v, v, v); if v == null goto label; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not unregister service: \u as Service MBean."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } private java.lang.Object getManagedObjectForService(org.apache.camel.CamelContext, org.apache.camel.Service, org.apache.camel.Route) { java.util.Map v, v, v, v, v, v; org.apache.camel.management.mbean.ManagedProducerCache v; org.apache.camel.management.mbean.ManagedRuntimeEndpointRegistry v; org.apache.camel.Service v; org.apache.camel.management.mbean.ManagedValidatorRegistry v; org.apache.camel.management.mbean.ManagedThrottlingInflightRoutePolicy v; org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy v; org.apache.camel.Route v; org.apache.camel.management.mbean.ManagedConsumerCache v; org.apache.camel.spi.ManagementStrategy v, v, v, v; org.apache.camel.management.mbean.ManagedEndpointRegistry v; org.apache.camel.management.mbean.ManagedBacklogTracer v; org.apache.camel.spi.ManagementObjectStrategy v, v, v, v, v, v; org.apache.camel.management.mbean.ManagedRuntimeCamelCatalog v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.camel.management.mbean.ManagedTypeConverterRegistry v; org.apache.camel.management.mbean.ManagedAsyncProcessorAwaitManager v; org.apache.camel.management.mbean.ManagedBacklogDebugger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.CamelContext v; org.apache.camel.management.mbean.ManagedTracer v; org.apache.camel.management.mbean.ManagedTransformerRegistry v; org.apache.camel.management.mbean.ManagedStreamCachingStrategy v; java.lang.Object v, v, v, v, v, v; org.apache.camel.management.mbean.ManagedInflightRepository v; org.apache.camel.management.mbean.ManagedRestRegistry v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v := @parameter: org.apache.camel.Service; v := @parameter: org.apache.camel.Route; v = v instanceof org.apache.camel.Channel; if v != 0 goto label; v = v instanceof org.apache.camel.spi.UnitOfWork; if v != 0 goto label; v = v instanceof org.apache.camel.management.InstrumentationProcessor; if v == 0 goto label; label: return null; label: v = v instanceof org.apache.camel.NonManagedService; if v == 0 goto label; return null; label: v = null; v = v instanceof org.apache.camel.spi.ManagementAware; if v == 0 goto label; v = interfaceinvoke v.(v); return v; label: v = v instanceof org.apache.camel.processor.interceptor.Tracer; if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.camel.management.mbean.ManagedTracer; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.processor.interceptor.Tracer)>(v, v); v = v; v = specialinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); label: return v; label: v = v instanceof org.apache.camel.processor.interceptor.BacklogTracer; if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.camel.management.mbean.ManagedBacklogTracer; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.processor.interceptor.BacklogTracer)>(v, v); v = v; v = specialinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); label: return v; label: v = v instanceof org.apache.camel.processor.interceptor.BacklogDebugger; if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.camel.management.mbean.ManagedBacklogDebugger; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.processor.interceptor.BacklogDebugger)>(v, v); v = v; v = specialinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); label: return v; label: v = v instanceof org.apache.camel.spi.DataFormat; if v == 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, v); goto label; label: v = v instanceof org.apache.camel.Producer; if v == 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, v); goto label; label: v = v instanceof org.apache.camel.Consumer; if v == 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, v); goto label; label: v = v instanceof org.apache.camel.Processor; if v == 0 goto label; v = specialinvoke v.(v, v, v); return v; label: v = v instanceof org.apache.camel.impl.ThrottlingInflightRoutePolicy; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedThrottlingInflightRoutePolicy; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.impl.ThrottlingInflightRoutePolicy)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.impl.ThrottlingExceptionRoutePolicy; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedThrottlingExceptionRoutePolicy; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.impl.ThrottlingExceptionRoutePolicy)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.impl.ConsumerCache; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedConsumerCache; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.impl.ConsumerCache)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.impl.ProducerCache; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedProducerCache; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.impl.ProducerCache)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.impl.DefaultEndpointRegistry; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedEndpointRegistry; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.EndpointRegistry)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.TypeConverterRegistry; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedTypeConverterRegistry; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.TypeConverterRegistry)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.RestRegistry; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedRestRegistry; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.RestRegistry)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.InflightRepository; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedInflightRepository; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.InflightRepository)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.AsyncProcessorAwaitManager; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedAsyncProcessorAwaitManager; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.AsyncProcessorAwaitManager)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.RuntimeEndpointRegistry; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedRuntimeEndpointRegistry; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.RuntimeEndpointRegistry)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.StreamCachingStrategy; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedStreamCachingStrategy; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.StreamCachingStrategy)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.EventNotifier; if v == 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, v); goto label; label: v = v instanceof org.apache.camel.spi.TransformerRegistry; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedTransformerRegistry; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.TransformerRegistry)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.spi.ValidatorRegistry; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedValidatorRegistry; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.spi.ValidatorRegistry)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.runtimecatalog.RuntimeCamelCatalog; if v == 0 goto label; v = new org.apache.camel.management.mbean.ManagedRuntimeCamelCatalog; specialinvoke v.(org.apache.camel.CamelContext,org.apache.camel.runtimecatalog.RuntimeCamelCatalog)>(v, v); v = v; goto label; label: v = v instanceof org.apache.camel.cluster.CamelClusterService; if v == 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, v); goto label; label: if v == null goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, v); label: v = v instanceof org.apache.camel.management.mbean.ManagedService; if v == 0 goto label; virtualinvoke v.(v); v = specialinvoke v.(); virtualinvoke v.(v); label: return v; } private java.lang.Object getManagedObjectForProcessor(org.apache.camel.CamelContext, org.apache.camel.Processor, org.apache.camel.Route) { org.apache.camel.CamelContext v; org.apache.camel.Route v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.spi.ManagementObjectStrategy v; org.apache.camel.Processor v; java.util.Map v; java.lang.Object v, v, v, v; boolean v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v := @parameter: org.apache.camel.Processor; v := @parameter: org.apache.camel.Route; v = v.; v = interfaceinvoke v.(v); if v != null goto label; return null; label: v = specialinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v, v); if v == null goto label; v = v instanceof org.apache.camel.api.management.PerformanceCounter; if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(v); label: return v; } public void onRoutesAdd(java.util.Collection) { org.apache.camel.management.CompositePerformanceCounter v; org.apache.camel.spi.ManagementObjectStrategy v; boolean v, v, v, v, v, v, v, v, v; java.util.Collection v; java.util.Set v; java.lang.Exception v; org.apache.camel.spi.ManagementAgent v, v; javax.management.JMException v; org.apache.camel.Route v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.Processor v; org.apache.camel.management.mbean.ManagedCamelContext v, v; java.lang.Boolean v, v; java.lang.String v; org.apache.camel.ServiceStatus v; org.apache.camel.spi.ManagementStrategy v, v, v; org.apache.camel.CamelContext v, v; org.slf4j.Logger v, v, v; java.util.Iterator v; java.lang.Object v, v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: java.util.Collection; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); label: v = virtualinvoke v.(v, v); if v == 0 goto label; v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; v = ; interfaceinvoke v.("The route is already managed: {}", v); goto label; label: v = v instanceof org.apache.camel.impl.EventDrivenConsumerRoute; if v == 0 goto label; v = virtualinvoke v.(); v = v instanceof org.apache.camel.processor.CamelInternalProcessor; if v == 0 goto label; v = v instanceof org.apache.camel.management.mbean.ManagedRoute; if v == 0 goto label; v = virtualinvoke v.(class "Lorg/apache/camel/processor/CamelInternalProcessor$InstrumentationAdvice;"); if v == null goto label; v = v.; if v == null goto label; v = new org.apache.camel.management.CompositePerformanceCounter; v = v.; specialinvoke v.(org.apache.camel.api.management.PerformanceCounter,org.apache.camel.api.management.PerformanceCounter)>(v, v); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not register Route MBean", v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not create Route MBean", v); goto label; label: return; catch javax.management.JMException from label to label with label; catch java.lang.Exception from label to label with label; } public void onRoutesRemove(java.util.Collection) { org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.spi.ManagementObjectStrategy v; java.lang.String v; org.apache.camel.spi.ManagementStrategy v; boolean v, v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v, v; java.util.Iterator v; java.util.Collection v; java.util.Set v; java.lang.Exception v; java.lang.Object v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: java.util.Collection; v = v.; if v != 0 goto label; return; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v != 0 goto label; v = ; interfaceinvoke v.("The route is not managed: {}", v); goto label; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not unregister Route MBean", v); label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: specialinvoke v.(v); return; catch java.lang.Exception from label to label with label; } public void onErrorHandlerAdd(org.apache.camel.spi.RouteContext, org.apache.camel.Processor, org.apache.camel.ErrorHandlerFactory) { org.apache.camel.CamelContext v; org.slf4j.Logger v, v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.Exception v; org.apache.camel.ErrorHandlerFactory v; org.apache.camel.spi.ManagementObjectStrategy v; org.apache.camel.Processor v; java.lang.Object v; java.lang.String v; org.apache.camel.spi.ManagementStrategy v; org.apache.camel.spi.RouteContext v; boolean v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.spi.RouteContext; v := @parameter: org.apache.camel.Processor; v := @parameter: org.apache.camel.ErrorHandlerFactory; v = virtualinvoke v.(v, null); if v != 0 goto label; return; label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v, v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; v = ; interfaceinvoke v.("The error handler builder is already managed: {}", v); return; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not register error handler builder: \u as ErrorHandler MBean."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public void onErrorHandlerRemove(org.apache.camel.spi.RouteContext, org.apache.camel.Processor, org.apache.camel.ErrorHandlerFactory) { org.apache.camel.CamelContext v; org.slf4j.Logger v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.Exception v; org.apache.camel.ErrorHandlerFactory v; org.apache.camel.spi.ManagementObjectStrategy v; org.apache.camel.Processor v; java.lang.Object v; java.lang.String v; org.apache.camel.spi.RouteContext v; boolean v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.spi.RouteContext; v := @parameter: org.apache.camel.Processor; v := @parameter: org.apache.camel.ErrorHandlerFactory; v = v.; if v != 0 goto label; return; label: v = specialinvoke v.(); v = v.; v = interfaceinvoke v.(v, v, v, v); if v == null goto label; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not unregister error handler: \u as ErrorHandler MBean."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public void onThreadPoolAdd(org.apache.camel.CamelContext, java.util.concurrent.ThreadPoolExecutor, java.lang.String, java.lang.String, java.lang.String, java.lang.String) { java.util.concurrent.ThreadPoolExecutor v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.spi.ManagementObjectStrategy v; java.util.Map v; java.lang.String v, v, v, v, v; org.apache.camel.spi.ManagementStrategy v; boolean v, v; org.apache.camel.CamelContext v; org.slf4j.Logger v, v; java.lang.Exception v; java.lang.Object v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v := @parameter: java.util.concurrent.ThreadPoolExecutor; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(v, null); if v != 0 goto label; return; label: v = specialinvoke v.(); v = interfaceinvoke v.(v, v, v, v, v, v); v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v == 0 goto label; v = ; interfaceinvoke v.("The thread pool is already managed: {}", v); return; label: virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not register thread pool: \u as ThreadPool MBean."); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; } public void onThreadPoolRemove(org.apache.camel.CamelContext, java.util.concurrent.ThreadPoolExecutor) { org.apache.camel.CamelContext v; org.slf4j.Logger v, v; java.util.concurrent.ThreadPoolExecutor v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.lang.Exception v; java.util.Map v; java.lang.Object v; org.apache.camel.spi.ManagementStrategy v; boolean v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.CamelContext; v := @parameter: java.util.concurrent.ThreadPoolExecutor; v = v.; if v != 0 goto label; return; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = specialinvoke v.(); v = interfaceinvoke v.(v, null); if v != 0 goto label; v = ; interfaceinvoke v.("The thread pool is not managed: {}", v); return; label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not unregister ThreadPool MBean", v); label: return; catch java.lang.Exception from label to label with label; } public void onRouteContextCreate(org.apache.camel.spi.RouteContext) { org.apache.camel.model.RouteDefinition v; org.apache.camel.management.InstrumentationInterceptStrategy v; java.util.Iterator v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.util.HashMap v; java.util.List v; java.util.Map v; java.lang.Object v; org.apache.camel.spi.RouteContext v; boolean v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.spi.RouteContext; v = v.; if v != 0 goto label; return; label: v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, v, v); goto label; label: v = new org.apache.camel.management.InstrumentationInterceptStrategy; v = v.; specialinvoke v.(java.util.Map,java.util.Map)>(v, v); interfaceinvoke v.(v); return; } private void removeWrappedProcessorsForRoutes(java.util.Collection) { org.apache.camel.model.RouteDefinition v; java.util.Iterator v, v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; java.util.Collection v, v; java.util.Map v; java.lang.Object v, v, v; java.lang.String v, v; boolean v, v, v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: java.util.Collection; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; interfaceinvoke v.(); goto label; label: return; } private void registerPerformanceCounters(org.apache.camel.spi.RouteContext, org.apache.camel.model.ProcessorDefinition, java.util.Map) { org.apache.camel.CamelContext v; java.util.Iterator v; org.apache.camel.model.ProcessorDefinition v; org.apache.camel.management.DefaultManagementLifecycleStrategy v; org.apache.camel.management.DelegatePerformanceCounter v; java.util.List v; org.apache.camel.spi.ManagementAgent v; java.util.Map v; java.lang.Object v; org.apache.camel.spi.ManagementStrategy v; org.apache.camel.spi.RouteContext v; boolean v, v, v; org.apache.camel.ManagementStatisticsLevel v; v := @this: org.apache.camel.management.DefaultManagementLifecycleStrategy; v := @parameter: org.apache.camel.spi.RouteContext; v := @parameter: org.apache.camel.model.ProcessorDefinition; v := @parameter: java.util.Map; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(v); if v != 0 goto label; return; label: v = new org.apache.camel.management.DelegatePerformanceCounter; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.