public class org.apache.activemq.broker.BrokerService extends java.lang.Object implements org.apache.activemq.Service
{
public static final java.lang.String DEFAULT_PORT;
public static final java.lang.String LOCAL_HOST_NAME;
public static final java.lang.String BROKER_VERSION;
public static final java.lang.String DEFAULT_BROKER_NAME;
public static final int DEFAULT_MAX_FILE_LENGTH;
public static final long DEFAULT_START_TIMEOUT;
public static final int MAX_SCHEDULER_REPEAT_ALLOWED;
private static final org.slf4j.Logger LOG;
private static final long serialVersionUID;
private boolean useJmx;
private boolean enableStatistics;
private boolean persistent;
private boolean populateJMSXUserID;
private boolean useAuthenticatedPrincipalForJMSXUserID;
private boolean populateUserNameInMBeans;
private long mbeanInvocationTimeout;
private boolean useShutdownHook;
private boolean useLoggingForShutdownErrors;
private boolean shutdownOnMasterFailure;
private boolean shutdownOnSlaveFailure;
private boolean waitForSlave;
private long waitForSlaveTimeout;
private boolean passiveSlave;
private java.lang.String brokerName;
private java.io.File dataDirectoryFile;
private java.io.File tmpDataDirectory;
private org.apache.activemq.broker.Broker broker;
private org.apache.activemq.broker.jmx.BrokerView adminView;
private org.apache.activemq.broker.jmx.ManagementContext managementContext;
private javax.management.ObjectName brokerObjectName;
private org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory;
private org.apache.activemq.thread.TaskRunnerFactory persistenceTaskRunnerFactory;
private org.apache.activemq.usage.SystemUsage systemUsage;
private org.apache.activemq.usage.SystemUsage producerSystemUsage;
private org.apache.activemq.usage.SystemUsage consumerSystemUsage;
private org.apache.activemq.store.PersistenceAdapter persistenceAdapter;
private org.apache.activemq.store.PersistenceAdapterFactory persistenceFactory;
protected org.apache.activemq.broker.region.DestinationFactory destinationFactory;
private org.apache.activemq.security.MessageAuthorizationPolicy messageAuthorizationPolicy;
private final java.util.List transportConnectors;
private final java.util.List networkConnectors;
private final java.util.List proxyConnectors;
private final java.util.List jmsConnectors;
private final java.util.List services;
private transient java.lang.Thread shutdownHook;
private java.lang.String[] transportConnectorURIs;
private java.lang.String[] networkConnectorURIs;
private org.apache.activemq.network.jms.JmsConnector[] jmsBridgeConnectors;
private boolean deleteAllMessagesOnStartup;
private boolean advisorySupport;
private boolean anonymousProducerAdvisorySupport;
private java.net.URI vmConnectorURI;
private java.lang.String defaultSocketURIString;
private org.apache.activemq.broker.region.policy.PolicyMap destinationPolicy;
private final java.util.concurrent.atomic.AtomicBoolean started;
private final java.util.concurrent.atomic.AtomicBoolean stopped;
private final java.util.concurrent.atomic.AtomicBoolean stopping;
private final java.util.concurrent.atomic.AtomicBoolean preShutdownHooksInvoked;
private org.apache.activemq.broker.BrokerPlugin[] plugins;
private boolean keepDurableSubsActive;
private boolean enableMessageExpirationOnActiveDurableSubs;
private boolean useVirtualTopics;
private boolean useMirroredQueues;
private boolean useTempMirroredQueues;
private boolean useVirtualDestSubs;
private boolean useVirtualDestSubsOnCreation;
private org.apache.activemq.command.BrokerId brokerId;
private volatile org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors;
private org.apache.activemq.command.ActiveMQDestination[] destinations;
private org.apache.activemq.store.PListStore tempDataStore;
private int persistenceThreadPriority;
private boolean useLocalHostBrokerName;
private final java.util.concurrent.CountDownLatch stoppedLatch;
private final java.util.concurrent.CountDownLatch startedLatch;
private org.apache.activemq.broker.Broker regionBroker;
private int producerSystemUsagePortion;
private int consumerSystemUsagePortion;
private boolean splitSystemUsageForProducersConsumers;
private boolean monitorConnectionSplits;
private int taskRunnerPriority;
private boolean dedicatedTaskRunner;
private boolean cacheTempDestinations;
private int timeBeforePurgeTempDestinations;
private final java.util.List shutdownHooks;
private boolean systemExitOnShutdown;
private int systemExitOnShutdownExitCode;
private org.apache.activemq.broker.SslContext sslContext;
private boolean forceStart;
private org.apache.activemq.util.IOExceptionHandler ioExceptionHandler;
private boolean schedulerSupport;
private int maxSchedulerRepeatAllowed;
private java.io.File schedulerDirectoryFile;
private org.apache.activemq.thread.Scheduler scheduler;
private java.util.concurrent.ThreadPoolExecutor executor;
private int schedulePeriodForDestinationPurge;
private int maxPurgedDestinationsPerSweep;
private int schedulePeriodForDiskUsageCheck;
private int diskUsageCheckRegrowThreshold;
private boolean adjustUsageLimits;
private org.apache.activemq.broker.BrokerContext brokerContext;
private boolean networkConnectorStartAsync;
private boolean allowTempAutoCreationOnSend;
private org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore;
private final java.util.concurrent.atomic.AtomicLong totalConnections;
private final java.util.concurrent.atomic.AtomicInteger currentConnections;
private long offlineDurableSubscriberTimeout;
private long offlineDurableSubscriberTaskSchedule;
private org.apache.activemq.filter.DestinationFilter virtualConsumerDestinationFilter;
private final java.util.concurrent.atomic.AtomicBoolean persistenceAdapterStarted;
private java.lang.Throwable startException;
private boolean startAsync;
private java.util.Date startDate;
private boolean slave;
private boolean restartAllowed;
private boolean restartRequested;
private boolean rejectDurableConsumers;
private boolean rollbackOnlyOnAsyncException;
private int storeOpenWireVersion;
private final java.util.List preShutdownHooks;
private static final java.lang.String brokerNameReplacedCharsRegExp;
public void <init>()
{
java.util.concurrent.atomic.AtomicBoolean v, v, v, v, v;
java.util.ArrayList v, v;
java.util.concurrent.atomic.AtomicInteger v;
int v;
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.CountDownLatch v, v;
java.util.concurrent.atomic.AtomicLong v;
java.util.concurrent.CopyOnWriteArrayList v, v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: boolean useJmx> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean enableStatistics> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean persistent> = 1;
v.<org.apache.activemq.broker.BrokerService: long mbeanInvocationTimeout> = 0L;
v.<org.apache.activemq.broker.BrokerService: boolean useShutdownHook> = 1;
v.<org.apache.activemq.broker.BrokerService: long waitForSlaveTimeout> = 600000L;
v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName> = "localhost";
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors> = v;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List networkConnectors> = v;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List proxyConnectors> = v;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List jmsConnectors> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List services> = v;
v.<org.apache.activemq.broker.BrokerService: boolean advisorySupport> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean anonymousProducerAdvisorySupport> = 0;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopping> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean preShutdownHooksInvoked> = v;
v.<org.apache.activemq.broker.BrokerService: boolean keepDurableSubsActive> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean enableMessageExpirationOnActiveDurableSubs> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean useVirtualTopics> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean useMirroredQueues> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean useTempMirroredQueues> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean useVirtualDestSubs> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean useVirtualDestSubsOnCreation> = 0;
v.<org.apache.activemq.broker.BrokerService: int persistenceThreadPriority> = 10;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch stoppedLatch> = v;
v = new java.util.concurrent.CountDownLatch;
specialinvoke v.<java.util.concurrent.CountDownLatch: void <init>(int)>(1);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch startedLatch> = v;
v.<org.apache.activemq.broker.BrokerService: int producerSystemUsagePortion> = 60;
v.<org.apache.activemq.broker.BrokerService: int consumerSystemUsagePortion> = 40;
v.<org.apache.activemq.broker.BrokerService: boolean monitorConnectionSplits> = 0;
v.<org.apache.activemq.broker.BrokerService: int taskRunnerPriority> = 5;
v.<org.apache.activemq.broker.BrokerService: boolean cacheTempDestinations> = 0;
v.<org.apache.activemq.broker.BrokerService: int timeBeforePurgeTempDestinations> = 5000;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks> = v;
v.<org.apache.activemq.broker.BrokerService: boolean forceStart> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean schedulerSupport> = 0;
v.<org.apache.activemq.broker.BrokerService: int maxSchedulerRepeatAllowed> = 1000;
v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDestinationPurge> = 0;
v.<org.apache.activemq.broker.BrokerService: int maxPurgedDestinationsPerSweep> = 0;
v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDiskUsageCheck> = 0;
v = (int) -1;
v.<org.apache.activemq.broker.BrokerService: int diskUsageCheckRegrowThreshold> = v;
v.<org.apache.activemq.broker.BrokerService: boolean adjustUsageLimits> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean networkConnectorStartAsync> = 0;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicLong totalConnections> = v;
v = new java.util.concurrent.atomic.AtomicInteger;
specialinvoke v.<java.util.concurrent.atomic.AtomicInteger: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicInteger currentConnections> = v;
v.<org.apache.activemq.broker.BrokerService: long offlineDurableSubscriberTimeout> = -1L;
v.<org.apache.activemq.broker.BrokerService: long offlineDurableSubscriberTaskSchedule> = 300000L;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean persistenceAdapterStarted> = v;
v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable startException> = null;
v.<org.apache.activemq.broker.BrokerService: boolean startAsync> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean slave> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean restartAllowed> = 1;
v.<org.apache.activemq.broker.BrokerService: boolean restartRequested> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean rejectDurableConsumers> = 0;
v.<org.apache.activemq.broker.BrokerService: boolean rollbackOnlyOnAsyncException> = 1;
v.<org.apache.activemq.broker.BrokerService: int storeOpenWireVersion> = 11;
v = new java.util.concurrent.CopyOnWriteArrayList;
specialinvoke v.<java.util.concurrent.CopyOnWriteArrayList: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.List preShutdownHooks> = v;
return;
}
public java.lang.String toString()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("BrokerService[\u]");
return v;
}
private java.lang.String getBrokerVersion()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
v := @this: org.apache.activemq.broker.BrokerService;
v = <org.apache.activemq.ActiveMQConnectionMetaData: java.lang.String PROVIDER_VERSION>;
if v != null goto label;
v = <org.apache.activemq.broker.BrokerService: java.lang.String BROKER_VERSION>;
label:
return v;
}
public org.apache.activemq.broker.TransportConnector addConnector(java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.TransportConnector v;
java.lang.String v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector addConnector(java.net.URI)>(v);
return v;
}
public org.apache.activemq.broker.TransportConnector addConnector(java.net.URI) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.TransportConnector v, v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.net.URI;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector createTransportConnector(java.net.URI)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector addConnector(org.apache.activemq.broker.TransportConnector)>(v);
return v;
}
public org.apache.activemq.broker.TransportConnector addConnector(org.apache.activemq.transport.TransportServer) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.TransportConnector v, v;
org.apache.activemq.transport.TransportServer v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.transport.TransportServer;
v = new org.apache.activemq.broker.TransportConnector;
specialinvoke v.<org.apache.activemq.broker.TransportConnector: void <init>(org.apache.activemq.transport.TransportServer)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector addConnector(org.apache.activemq.broker.TransportConnector)>(v);
return v;
}
public org.apache.activemq.broker.TransportConnector addConnector(org.apache.activemq.broker.TransportConnector) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.broker.TransportConnector v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.TransportConnector;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
public boolean removeConnector(org.apache.activemq.broker.TransportConnector) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.broker.TransportConnector v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.TransportConnector;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void unregisterConnectorMBean(org.apache.activemq.broker.TransportConnector)>(v);
label:
return v;
}
public org.apache.activemq.network.NetworkConnector addNetworkConnector(java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.NetworkConnector v;
java.lang.String v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.NetworkConnector addNetworkConnector(java.net.URI)>(v);
return v;
}
public org.apache.activemq.proxy.ProxyConnector addProxyConnector(java.lang.String) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.proxy.ProxyConnector v;
java.lang.String v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.proxy.ProxyConnector addProxyConnector(java.net.URI)>(v);
return v;
}
public org.apache.activemq.network.NetworkConnector addNetworkConnector(java.net.URI) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.NetworkConnector v;
java.net.URI v;
org.apache.activemq.network.DiscoveryNetworkConnector v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.net.URI;
v = new org.apache.activemq.network.DiscoveryNetworkConnector;
specialinvoke v.<org.apache.activemq.network.DiscoveryNetworkConnector: void <init>(java.net.URI)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.NetworkConnector addNetworkConnector(org.apache.activemq.network.NetworkConnector)>(v);
return v;
}
public org.apache.activemq.proxy.ProxyConnector addProxyConnector(java.net.URI) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.proxy.ProxyConnector v, v;
java.net.URI v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.net.URI;
v = new org.apache.activemq.proxy.ProxyConnector;
specialinvoke v.<org.apache.activemq.proxy.ProxyConnector: void <init>()>();
virtualinvoke v.<org.apache.activemq.proxy.ProxyConnector: void setBind(java.net.URI)>(v);
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>("fanout:multicast://default");
virtualinvoke v.<org.apache.activemq.proxy.ProxyConnector: void setRemote(java.net.URI)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.proxy.ProxyConnector addProxyConnector(org.apache.activemq.proxy.ProxyConnector)>(v);
return v;
}
public org.apache.activemq.network.NetworkConnector addNetworkConnector(org.apache.activemq.network.NetworkConnector) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.network.NetworkConnector v;
org.apache.activemq.broker.BrokerService$1 v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.net.URI getVmConnectorURI()>();
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setLocalUri(java.net.URI)>(v);
v = new org.apache.activemq.broker.BrokerService$1;
specialinvoke v.<org.apache.activemq.broker.BrokerService$1: void <init>(org.apache.activemq.broker.BrokerService)>(v);
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setConnectionFilter(org.apache.activemq.network.ConnectionFilter)>(v);
v = v.<org.apache.activemq.broker.BrokerService: java.util.List networkConnectors>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
public boolean removeNetworkConnector(org.apache.activemq.network.NetworkConnector)
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.network.NetworkConnector v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List networkConnectors>;
v = interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void unregisterNetworkConnectorMBean(org.apache.activemq.network.NetworkConnector)>(v);
label:
return v;
}
public org.apache.activemq.proxy.ProxyConnector addProxyConnector(org.apache.activemq.proxy.ProxyConnector) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.proxy.ProxyConnector v;
java.net.URI v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.proxy.ProxyConnector;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.net.URI getVmConnectorURI()>();
virtualinvoke v.<org.apache.activemq.proxy.ProxyConnector: void setLocalUri(java.net.URI)>(v);
v = v.<org.apache.activemq.broker.BrokerService: java.util.List proxyConnectors>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void registerProxyConnectorMBean(org.apache.activemq.proxy.ProxyConnector)>(v);
label:
return v;
}
public org.apache.activemq.network.jms.JmsConnector addJmsConnector(org.apache.activemq.network.jms.JmsConnector) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.network.jms.JmsConnector v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.jms.JmsConnector;
virtualinvoke v.<org.apache.activemq.network.jms.JmsConnector: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
v = v.<org.apache.activemq.broker.BrokerService: java.util.List jmsConnectors>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void registerJmsConnectorMBean(org.apache.activemq.network.jms.JmsConnector)>(v);
label:
return v;
}
public final void addPreShutdownHook(java.lang.Runnable)
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.lang.Runnable v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List preShutdownHooks>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public org.apache.activemq.network.jms.JmsConnector removeJmsConnector(org.apache.activemq.network.jms.JmsConnector)
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.network.jms.JmsConnector v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.jms.JmsConnector;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List jmsConnectors>;
v = interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return null;
}
public void masterFailed()
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v, v, v, v;
java.lang.Exception v, v;
org.apache.activemq.broker.Broker v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean shutdownOnMasterFailure>;
if v == 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("The Master has failed ... shutting down");
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void stop()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to stop for master failure", v);
goto label;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String)>("Master Failed - starting all connectors");
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startAllConnectors()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
interfaceinvoke v.<org.apache.activemq.broker.Broker: void nowMasterBroker()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to startAllConnectors", v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public java.lang.String getUptime()
{
org.apache.activemq.broker.BrokerService v;
byte v;
long v;
java.lang.String v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: long getUptimeMillis()>();
v = v cmp 0L;
if v != 0 goto label;
return "not started";
label:
v = staticinvoke <org.apache.activemq.util.TimeUtils: java.lang.String printDuration(double)>(v);
return v;
}
public long getUptimeMillis()
{
org.apache.activemq.broker.BrokerService v;
java.util.Date v, v, v;
long v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.Date startDate>;
if v != null goto label;
return 0L;
label:
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = v.<org.apache.activemq.broker.BrokerService: java.util.Date startDate>;
v = virtualinvoke v.<java.util.Date: long getTime()>();
v = v - v;
return v;
}
public boolean isStarted()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.broker.BrokerService v;
byte v;
java.util.concurrent.atomic.AtomicBoolean v;
long v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch startedLatch>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void start(boolean) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.atomic.AtomicBoolean v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean forceStart> = v;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void start()>();
return;
}
protected boolean shouldAutostart()
{
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
return 1;
}
private void postConstruct()
{
org.apache.activemq.broker.BrokerService v;
java.lang.RuntimeException v;
java.lang.Exception v;
v := @this: org.apache.activemq.broker.BrokerService;
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void autoStart()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void autoStart() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean shouldAutostart()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void start()>();
label:
return;
}
public void start() throws java.lang.Exception
{
java.util.Date v;
boolean v, v, v, v, v, v, v, v, v;
org.apache.activemq.broker.BrokerService v, v;
org.apache.activemq.broker.BrokerRegistry v;
java.lang.Exception v, v;
java.util.List v;
java.lang.Throwable v, v;
java.lang.Object[] v;
java.util.concurrent.atomic.AtomicBoolean v, v, v, v, v;
java.lang.String v, v, v, v, v, v, v;
org.apache.activemq.ConfigurationException v;
org.slf4j.Logger v, v;
java.util.Iterator v;
org.apache.activemq.command.BrokerId v;
java.lang.Object v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v != 0 goto label;
label:
return;
label:
specialinvoke v.<org.apache.activemq.broker.BrokerService: void setStartException(java.lang.Throwable)>(null);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopping>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean preShutdownHooksInvoked>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: java.util.Date startDate> = v;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("activemq.broker", v);
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void checkMemorySystemUsageLimits()>();
v = v.<org.apache.activemq.broker.BrokerService: boolean systemExitOnShutdown>;
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: boolean useShutdownHook>;
if v == 0 goto label;
v = new org.apache.activemq.ConfigurationException;
specialinvoke v.<org.apache.activemq.ConfigurationException: void <init>(java.lang.String)>("\'useShutdownHook\' property cannot be be used with \'systemExitOnShutdown\', please turn it off (useShutdownHook=false)");
throw v;
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void processHelperProperties()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("activemq.broker");
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getNetworkConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void registerNetworkConnectorMBean(org.apache.activemq.network.NetworkConnector)>(v);
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("activemq.broker", v);
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("activemq.broker", v);
throw v;
label:
v = staticinvoke <org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerRegistry getInstance()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerService lookup(java.lang.String)>(v);
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: void bind(java.lang.String,org.apache.activemq.broker.BrokerService)>(v, v);
label:
v = v.<org.apache.activemq.broker.BrokerService: boolean startAsync>;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void startPersistenceAdapter(boolean)>(v);
v = v.<org.apache.activemq.broker.BrokerService: boolean startAsync>;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void startBroker(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: void bind(java.lang.String,org.apache.activemq.broker.BrokerService)>(v, v);
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("activemq.broker");
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v[0] = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
v[1] = v;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object[])>("Failed to start Apache ActiveMQ ({}, {})", v);
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void stop()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Failed to stop broker after failure in start. This exception will be ignored", v);
label:
throw v;
label:
v := @caughtexception;
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("activemq.broker");
throw v;
label:
return;
catch java.lang.Throwable 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.Throwable from label to label with label;
}
private void startPersistenceAdapter(boolean) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService$2 v;
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
if v == 0 goto label;
v = new org.apache.activemq.broker.BrokerService$2;
specialinvoke v.<org.apache.activemq.broker.BrokerService$2: void <init>(org.apache.activemq.broker.BrokerService,java.lang.String)>(v, "Persistence Adapter Starting Thread");
virtualinvoke v.<org.apache.activemq.broker.BrokerService$2: void start()>();
goto label;
label:
specialinvoke v.<org.apache.activemq.broker.BrokerService: void doStartPersistenceAdapter()>();
label:
return;
}
private void doStartPersistenceAdapter() throws java.lang.Exception
{
org.apache.activemq.broker.scheduler.JobSchedulerStore v, v, v;
org.apache.activemq.store.PListStore v, v, v;
org.apache.activemq.usage.SystemUsage v;
java.lang.String v, v, v, v, v;
org.apache.activemq.ConfigurationException v;
boolean v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v, v, v;
java.lang.RuntimeException v, v;
java.lang.Exception v, v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
if v != null goto label;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void checkStartException()>();
v = new org.apache.activemq.ConfigurationException;
specialinvoke v.<org.apache.activemq.ConfigurationException: void <init>(java.lang.String)>("Cannot start null persistence adapter");
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getProducerSystemUsage()>();
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void setUsageManager(org.apache.activemq.usage.SystemUsage)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void setBrokerName(java.lang.String)>(v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Using Persistence Adapter: {}", v);
v = v.<org.apache.activemq.broker.BrokerService: boolean deleteAllMessagesOnStartup>;
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void deleteAllMessages()>();
label:
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void start()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore getTempDataStore()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
if v == null goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
interfaceinvoke v.<org.apache.activemq.store.PListStore: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.store.PListStore)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to start temp data store: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.RuntimeException: java.lang.String getLocalizedMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore getJobSchedulerStore()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
if v == null goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
interfaceinvoke v.<org.apache.activemq.broker.scheduler.JobSchedulerStore: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.broker.scheduler.JobSchedulerStore)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to start job scheduler store: \u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.RuntimeException: java.lang.String getLocalizedMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private void startBroker(boolean) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
boolean v;
org.apache.activemq.broker.BrokerService$3 v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
if v == 0 goto label;
v = new org.apache.activemq.broker.BrokerService$3;
specialinvoke v.<org.apache.activemq.broker.BrokerService$3: void <init>(org.apache.activemq.broker.BrokerService,java.lang.String)>(v, "Broker Starting Thread");
virtualinvoke v.<org.apache.activemq.broker.BrokerService$3: void start()>();
goto label;
label:
specialinvoke v.<org.apache.activemq.broker.BrokerService: void doStartBroker()>();
label:
return;
}
private void doStartBroker() throws java.lang.Exception
{
org.apache.activemq.util.DefaultIOExceptionHandler v;
org.apache.activemq.broker.jmx.BrokerView v;
org.apache.activemq.broker.jmx.ManagementContext v, v, v, v;
org.apache.activemq.broker.jmx.Log4JConfigView v;
org.apache.activemq.util.IOExceptionHandler v;
boolean v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
javax.management.ObjectName v, v;
java.util.concurrent.CountDownLatch v;
java.lang.Object[] v, v;
org.apache.activemq.broker.Broker v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
org.slf4j.Logger v, v, v;
org.apache.activemq.command.BrokerId v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void checkStartException()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startDestinations()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addShutdownHook()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.command.BrokerId getBrokerId()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId> = v;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerVersion()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v[1] = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Apache ActiveMQ {} ({}, {}) is starting", v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
interfaceinvoke v.<org.apache.activemq.broker.Broker: void start()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: boolean isCreateConnector()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: boolean isConnectorStarted()>();
if v != 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void stop()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startManagementContext()>();
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker regionBroker>;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: void setContextBroker(org.apache.activemq.broker.Broker)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView>;
virtualinvoke v.<org.apache.activemq.broker.jmx.BrokerView: void setBroker(org.apache.activemq.broker.jmx.ManagedRegionBroker)>(v);
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.util.IOExceptionHandler ioExceptionHandler>;
if v != null goto label;
v = new org.apache.activemq.util.DefaultIOExceptionHandler;
specialinvoke v.<org.apache.activemq.util.DefaultIOExceptionHandler: void <init>()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void setIoExceptionHandler(org.apache.activemq.util.IOExceptionHandler)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.broker.jmx.Log4JConfigView: boolean isLog4JAvailable()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<javax.management.ObjectName: java.lang.String toString()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createLog4JConfigViewName(java.lang.String)>(v);
v = new org.apache.activemq.broker.jmx.Log4JConfigView;
specialinvoke v.<org.apache.activemq.broker.jmx.Log4JConfigView: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startAllConnectors()>();
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerVersion()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v[1] = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Apache ActiveMQ {} ({}, {}) started", v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("For help or more information please see: http://activemq.apache.org");
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
interfaceinvoke v.<org.apache.activemq.broker.Broker: void brokerServiceStarted()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void checkStoreSystemUsageLimits()>();
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch startedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
interfaceinvoke v.<org.apache.activemq.broker.Broker: void nowMasterBroker()>();
return;
}
private void preDestroy()
{
org.apache.activemq.broker.BrokerService v;
java.lang.RuntimeException v;
java.lang.Exception v;
v := @this: org.apache.activemq.broker.BrokerService;
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void stop()>();
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>()>();
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
public void stop() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerRegistry v;
java.util.concurrent.CountDownLatch v, v;
org.apache.activemq.thread.TaskRunnerFactory v, v;
java.lang.Throwable v, v, v, v;
java.lang.Object[] v, v, v;
org.apache.activemq.broker.Broker v, v;
org.apache.activemq.store.PListStore v, v;
java.lang.String v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.thread.Scheduler v, v;
org.apache.activemq.store.PersistenceAdapter v;
java.util.Date v;
org.apache.activemq.util.ServiceStopper v;
org.apache.activemq.broker.jmx.ManagementContext v;
boolean v, v, v, v, v, v, v;
java.util.List v, v, v, v, v;
java.util.concurrent.ThreadPoolExecutor v, v;
java.util.concurrent.atomic.AtomicBoolean v, v, v, v, v, v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v, v;
org.slf4j.Logger v, v, v, v;
java.util.Iterator v, v, v;
org.apache.activemq.broker.BrokerStoppedException v;
org.apache.activemq.command.BrokerId v, v, v;
java.lang.Object v, v, v;
org.apache.activemq.broker.BrokerService$4 v;
v := @this: org.apache.activemq.broker.BrokerService;
v = new org.apache.activemq.util.ServiceStopper;
specialinvoke v.<org.apache.activemq.util.ServiceStopper: void <init>()>();
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean preShutdownHooksInvoked>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List preShutdownHooks>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void onException(java.lang.Object,java.lang.Throwable)>(v, v);
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopping>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v != 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void trace(java.lang.String)>("Broker already stopping/stopped");
return;
label:
v = new org.apache.activemq.broker.BrokerStoppedException;
specialinvoke v.<org.apache.activemq.broker.BrokerStoppedException: void <init>(java.lang.String)>("Stop invoked");
specialinvoke v.<org.apache.activemq.broker.BrokerService: void setStartException(java.lang.Throwable)>(v);
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
staticinvoke <org.slf4j.MDC: void put(java.lang.String,java.lang.String)>("activemq.broker", v);
v = v.<org.apache.activemq.broker.BrokerService: boolean systemExitOnShutdown>;
if v == 0 goto label;
v = new org.apache.activemq.broker.BrokerService$4;
specialinvoke v.<org.apache.activemq.broker.BrokerService$4: void <init>(org.apache.activemq.broker.BrokerService)>(v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService$4: void start()>();
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerVersion()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v[1] = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Apache ActiveMQ {} ({}, {}) is shutting down", v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void removeShutdownHook()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler>;
virtualinvoke v.<org.apache.activemq.thread.Scheduler: void stop()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler> = null;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void stopAllConnectors(org.apache.activemq.util.ServiceStopper)>(v);
v.<org.apache.activemq.broker.BrokerService: boolean slave> = 1;
v = staticinvoke <org.apache.activemq.broker.BrokerRegistry: org.apache.activemq.broker.BrokerRegistry getInstance()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerRegistry: void unbind(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
staticinvoke <org.apache.activemq.transport.vm.VMTransportFactory: void stopped(java.lang.String)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker> = null;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
interfaceinvoke v.<org.apache.activemq.broker.scheduler.JobSchedulerStore: void stop()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore> = null;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
interfaceinvoke v.<org.apache.activemq.store.PListStore: void stop()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore> = null;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter> = null;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext> = null;
label:
staticinvoke <org.apache.activemq.selector.SelectorParser: void clearCache()>();
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch stoppedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
goto label;
label:
v := @caughtexception;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch stoppedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void countDown()>();
throw v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
virtualinvoke v.<org.apache.activemq.thread.TaskRunnerFactory: void shutdown()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory> = null;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor executor>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor executor>;
staticinvoke <org.apache.activemq.util.ThreadPoolUtils: java.util.List shutdownNow(java.util.concurrent.ExecutorService)>(v);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor executor> = null;
label:
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors> = null;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory> = null;
v = v.<org.apache.activemq.broker.BrokerService: java.util.Date startDate>;
if v == null goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[4];
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerVersion()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v[1] = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
v[2] = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getUptime()>();
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Apache ActiveMQ {} ({}, {}) uptime {}", v);
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerVersion()>();
v[0] = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v[1] = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Apache ActiveMQ {} ({}, {}) is shutdown", v);
v = v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks>;
entermonitor v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
interfaceinvoke v.<java.lang.Runnable: void run()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void onException(java.lang.Object,java.lang.Throwable)>(v, v);
goto label;
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
staticinvoke <org.slf4j.MDC: void remove(java.lang.String)>("activemq.broker");
v.<org.apache.activemq.broker.BrokerService: java.util.Date startDate> = null;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void throwFirstException()>();
return;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
public boolean checkQueueSize(java.lang.String)
{
long v, v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.management.CountStatisticImpl v;
byte v, v;
java.lang.Long v;
java.util.Map v;
java.lang.String v, v, v;
boolean v, v, v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.util.Iterator v;
java.util.Set v;
java.lang.Object v, v, v, v, v;
org.apache.activemq.broker.region.DestinationStatistics v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = 0L;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker regionBroker>;
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: java.util.Map getDestinationMap()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean matches(java.lang.String)>(v);
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: org.apache.activemq.management.CountStatisticImpl getMessages()>();
v = virtualinvoke v.<org.apache.activemq.management.CountStatisticImpl: long getCount()>();
v = v + v;
v = v cmp 0L;
if v <= 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<org.apache.activemq.broker.region.Destination: java.lang.String getName()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Queue has pending message: {} queueSize is: {}", v, v);
goto label;
label:
v = v cmp 0L;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void stopGracefully(java.lang.String, java.lang.String, long, long) throws java.lang.Exception
{
byte v, v, v;
java.lang.Long v, v;
boolean v, v, v, v;
org.apache.activemq.broker.BrokerService v;
java.lang.Exception v;
java.util.List v, v;
java.lang.Object[] v;
java.util.concurrent.atomic.AtomicBoolean v;
long v, v, v, v, v, v, v;
int v, v;
java.lang.String v, v, v, v;
org.slf4j.Logger v, v, v;
java.lang.Object v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
if v == null goto label;
if v == null goto label;
v = v cmp 0L;
if v > 0 goto label;
label:
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>(java.lang.String)>("connectorName and queueName cannot be null and timeout should be >0 for stopGracefully.");
throw v;
label:
v = v cmp 0L;
if v > 0 goto label;
v = 30L;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[4];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[2] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object[])>("Stop gracefully with connectorName: {} queueName: {} timeout: {} pollInterval: {}", v);
v = 0;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.lang.Object get(int)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.lang.String getName()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean matches(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void stop()>();
label:
v = v + 1;
goto label;
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
label:
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v - v;
v = v * 1000L;
v = v cmp v;
if v >= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean checkQueueSize(java.lang.String)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void stop()>();
goto label;
label:
v = v * 1000L;
staticinvoke <java.lang.Thread: void sleep(long)>(v);
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("Successfully stop the broker.");
goto label;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("There is still pending message on the queue. Please check and stop the broker manually.");
label:
return;
}
public void waitUntilStopped()
{
java.util.concurrent.CountDownLatch v;
org.apache.activemq.broker.BrokerService v;
java.lang.InterruptedException v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStarted()>();
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch stoppedLatch>;
virtualinvoke v.<java.util.concurrent.CountDownLatch: void await()>();
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public boolean isStopped()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public boolean waitUntilStarted()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean waitUntilStarted(long)>(600000L);
return v;
}
public boolean waitUntilStarted(long)
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.atomic.AtomicBoolean v;
long v, v, v, v, v;
java.util.concurrent.TimeUnit v;
java.util.concurrent.CountDownLatch v;
byte v;
java.lang.InterruptedException v;
boolean v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: long;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStarted()>();
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v + v;
v = staticinvoke <java.lang.Math: long max(long,long)>(0L, v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isStarted()>();
if v != 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
if v != 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v cmp v;
if v <= 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable getStartException()>();
if v == null goto label;
label:
return v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.CountDownLatch startedLatch>;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit MILLISECONDS>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: boolean await(long,java.util.concurrent.TimeUnit)>(100L, v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
return v;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
public org.apache.activemq.broker.Broker getBroker() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
if v != null goto label;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void checkStartException()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker createBroker()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
return v;
}
public org.apache.activemq.broker.jmx.BrokerView getAdminView() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.BrokerView v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView>;
if v != null goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView>;
return v;
}
public void setAdminView(org.apache.activemq.broker.jmx.BrokerView)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.BrokerView v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.jmx.BrokerView;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView> = v;
return;
}
public java.lang.String getBrokerName()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
return v;
}
public void setBrokerName(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.lang.Object[] v;
org.slf4j.Logger v;
java.lang.NullPointerException v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
if v != null goto label;
v = new java.lang.NullPointerException;
specialinvoke v.<java.lang.NullPointerException: void <init>(java.lang.String)>("The broker name cannot be null");
throw v;
label:
v = virtualinvoke v.<java.lang.String: java.lang.String replaceAll(java.lang.String,java.lang.String)>("[^a-zA-Z0-9\\.\\_\\-\\:]", "_");
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = "[^a-zA-Z0-9\\.\\_\\-\\:]";
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object[])>("Broker Name: {} contained illegal characters matching regExp: {} - replaced with {}", v);
label:
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName> = v;
return;
}
public org.apache.activemq.store.PersistenceAdapterFactory getPersistenceFactory()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PersistenceAdapterFactory v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapterFactory persistenceFactory>;
return v;
}
public java.io.File getDataDirectoryFile()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
java.io.File v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.io.File dataDirectoryFile>;
if v != null goto label;
v = new java.io.File;
v = staticinvoke <org.apache.activemq.util.IOHelper: java.lang.String getDefaultDataDirectory()>();
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.broker.BrokerService: java.io.File dataDirectoryFile> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.io.File dataDirectoryFile>;
return v;
}
public java.io.File getBrokerDataDirectory()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
java.io.File v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = new java.io.File;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getDataDirectoryFile()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
return v;
}
public void setDataDirectory(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void setDataDirectoryFile(java.io.File)>(v);
return;
}
public void setDataDirectoryFile(java.io.File)
{
org.apache.activemq.broker.BrokerService v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.io.File;
v.<org.apache.activemq.broker.BrokerService: java.io.File dataDirectoryFile> = v;
return;
}
public java.io.File getTmpDataDirectory()
{
org.apache.activemq.broker.BrokerService v;
java.io.File v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory>;
if v != null goto label;
v = new java.io.File;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getBrokerDataDirectory()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "tmp_storage");
v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory>;
return v;
}
public void setTmpDataDirectory(java.io.File)
{
org.apache.activemq.broker.BrokerService v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.io.File;
v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory> = v;
return;
}
public void setPersistenceFactory(org.apache.activemq.store.PersistenceAdapterFactory)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PersistenceAdapterFactory v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.store.PersistenceAdapterFactory;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapterFactory persistenceFactory> = v;
return;
}
public void setDestinationFactory(org.apache.activemq.broker.region.DestinationFactory)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.region.DestinationFactory v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.region.DestinationFactory;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory> = v;
return;
}
public boolean isPersistent()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean persistent>;
return v;
}
public void setPersistent(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean persistent> = v;
return;
}
public boolean isPopulateJMSXUserID()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean populateJMSXUserID>;
return v;
}
public void setPopulateJMSXUserID(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean populateJMSXUserID> = v;
return;
}
public org.apache.activemq.usage.SystemUsage getSystemUsage()
{
org.apache.activemq.usage.TempUsage v;
java.util.concurrent.ThreadPoolExecutor v;
org.apache.activemq.usage.JobSchedulerUsage v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v;
org.apache.activemq.store.PListStore v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.usage.SystemUsage v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.io.IOException v;
java.lang.RuntimeException v;
org.apache.activemq.usage.StoreUsage v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.broker.BrokerService;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
if v != null goto label;
v = new org.apache.activemq.usage.SystemUsage;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore getTempDataStore()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore getJobSchedulerStore()>();
specialinvoke v.<org.apache.activemq.usage.SystemUsage: void <init>(java.lang.String,org.apache.activemq.store.PersistenceAdapter,org.apache.activemq.store.PListStore,org.apache.activemq.broker.scheduler.JobSchedulerStore)>("Main", v, v, v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor getExecutor()>();
virtualinvoke v.<org.apache.activemq.usage.SystemUsage: void setExecutor(java.util.concurrent.ThreadPoolExecutor)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setLimit(long)>(1073741824L);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.TempUsage getTempUsage()>();
virtualinvoke v.<org.apache.activemq.usage.TempUsage: void setLimit(long)>(53687091200L);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.StoreUsage getStoreUsage()>();
virtualinvoke v.<org.apache.activemq.usage.StoreUsage: void setLimit(long)>(107374182400L);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.JobSchedulerUsage getJobSchedulerUsage()>();
virtualinvoke v.<org.apache.activemq.usage.JobSchedulerUsage: void setLimit(long)>(53687091200L);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addService(org.apache.activemq.Service)>(v);
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
label:
return v;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Cannot create SystemUsage", v);
v = new java.lang.RuntimeException;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Fatally failed to create SystemUsage\u0001");
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.io.IOException from label to label with label;
}
public void setSystemUsage(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.ThreadPoolExecutor v, v;
org.apache.activemq.usage.SystemUsage v, v, v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.usage.SystemUsage;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void removeService(org.apache.activemq.Service)>(v);
label:
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: java.util.concurrent.ThreadPoolExecutor getExecutor()>();
if v != null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor getExecutor()>();
virtualinvoke v.<org.apache.activemq.usage.SystemUsage: void setExecutor(java.util.concurrent.ThreadPoolExecutor)>(v);
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage systemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addService(org.apache.activemq.Service)>(v);
return;
}
public org.apache.activemq.usage.SystemUsage getConsumerSystemUsage() throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
int v;
float v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.usage.SystemUsage v, v, v, v, v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
if v != null goto label;
v = v.<org.apache.activemq.broker.BrokerService: boolean splitSystemUsageForProducersConsumers>;
if v == 0 goto label;
v = new org.apache.activemq.usage.SystemUsage;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
specialinvoke v.<org.apache.activemq.usage.SystemUsage: void <init>(org.apache.activemq.usage.SystemUsage,java.lang.String)>(v, "Consumer");
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage> = v;
v = v.<org.apache.activemq.broker.BrokerService: int consumerSystemUsagePortion>;
v = v / 100.0F;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setUsagePortion(float)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addService(org.apache.activemq.Service)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
return v;
}
public void setConsumerSystemUsage(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.usage.SystemUsage v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.usage.SystemUsage;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void removeService(org.apache.activemq.Service)>(v);
label:
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage consumerSystemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addService(org.apache.activemq.Service)>(v);
return;
}
public org.apache.activemq.usage.SystemUsage getProducerSystemUsage() throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
int v;
float v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.usage.SystemUsage v, v, v, v, v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
if v != null goto label;
v = v.<org.apache.activemq.broker.BrokerService: boolean splitSystemUsageForProducersConsumers>;
if v == 0 goto label;
v = new org.apache.activemq.usage.SystemUsage;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
specialinvoke v.<org.apache.activemq.usage.SystemUsage: void <init>(org.apache.activemq.usage.SystemUsage,java.lang.String)>(v, "Producer");
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage> = v;
v = v.<org.apache.activemq.broker.BrokerService: int producerSystemUsagePortion>;
v = v / 100.0F;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setUsagePortion(float)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addService(org.apache.activemq.Service)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
return v;
}
public void setProducerSystemUsage(org.apache.activemq.usage.SystemUsage)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.usage.SystemUsage v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.usage.SystemUsage;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void removeService(org.apache.activemq.Service)>(v);
label:
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage producerSystemUsage>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addService(org.apache.activemq.Service)>(v);
return;
}
public synchronized org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter() throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PersistenceAdapter v, v, v, v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
if v != null goto label;
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: boolean hasStartException()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter createPersistenceAdapter()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter registerPersistenceAdapterMBean(org.apache.activemq.store.PersistenceAdapter)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
return v;
}
public void setPersistenceAdapter(org.apache.activemq.store.PersistenceAdapter) throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
org.apache.activemq.store.PersistenceAdapter v, v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.store.PersistenceAdapter;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isPersistent()>();
if v != 0 goto label;
v = v instanceof org.apache.activemq.store.memory.MemoryPersistenceAdapter;
if v != 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("persistent=\"false\", ignoring configured persistenceAdapter: {}", v);
return;
label:
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter registerPersistenceAdapterMBean(org.apache.activemq.store.PersistenceAdapter)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter persistenceAdapter> = v;
return;
}
public org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.thread.TaskRunnerFactory v, v, v, v;
int v;
java.lang.Class v;
java.lang.ClassLoader v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
if v != null goto label;
v = new org.apache.activemq.thread.TaskRunnerFactory;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("ActiveMQ BrokerService[\u] Task");
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: int getTaskRunnerPriority()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isDedicatedTaskRunner()>();
specialinvoke v.<org.apache.activemq.thread.TaskRunnerFactory: void <init>(java.lang.String,int,boolean,int,boolean)>(v, v, 1, 1000, v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
virtualinvoke v.<org.apache.activemq.thread.TaskRunnerFactory: void setThreadClassLoader(java.lang.ClassLoader)>(v);
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
return v;
}
public void setTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.thread.TaskRunnerFactory v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.thread.TaskRunnerFactory;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory> = v;
return;
}
public org.apache.activemq.thread.TaskRunnerFactory getPersistenceTaskRunnerFactory()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.thread.TaskRunnerFactory v, v, v;
int v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory>;
if v != null goto label;
v = new org.apache.activemq.thread.TaskRunnerFactory;
v = v.<org.apache.activemq.broker.BrokerService: int persistenceThreadPriority>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isDedicatedTaskRunner()>();
specialinvoke v.<org.apache.activemq.thread.TaskRunnerFactory: void <init>(java.lang.String,int,boolean,int,boolean)>("Persistence Adaptor Task", v, 1, 1000, v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory persistenceTaskRunnerFactory> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory persistenceTaskRunnerFactory>;
return v;
}
public void setPersistenceTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.thread.TaskRunnerFactory v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.thread.TaskRunnerFactory;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory persistenceTaskRunnerFactory> = v;
return;
}
public boolean isUseJmx()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useJmx>;
return v;
}
public boolean isEnableStatistics()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean enableStatistics>;
return v;
}
public void setEnableStatistics(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean enableStatistics> = v;
return;
}
public void setUseJmx(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useJmx> = v;
return;
}
public javax.management.ObjectName getBrokerObjectName() throws javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.BrokerService v;
javax.management.ObjectName v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName brokerObjectName>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName createBrokerObjectName()>();
v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName brokerObjectName> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName brokerObjectName>;
return v;
}
public void setBrokerObjectName(javax.management.ObjectName)
{
org.apache.activemq.broker.BrokerService v;
javax.management.ObjectName v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: javax.management.ObjectName;
v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName brokerObjectName> = v;
return;
}
public org.apache.activemq.broker.jmx.ManagementContext getManagementContext()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagementContext v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
if v != null goto label;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void checkStartException()>();
v = new org.apache.activemq.broker.jmx.ManagementContext;
specialinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext>;
return v;
}
private synchronized void checkStartException()
{
java.lang.Throwable v, v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerStoppedException v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable startException>;
if v == null goto label;
v = new org.apache.activemq.broker.BrokerStoppedException;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable startException>;
specialinvoke v.<org.apache.activemq.broker.BrokerStoppedException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
}
private synchronized boolean hasStartException()
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable startException>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private synchronized void setStartException(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Throwable;
v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable startException> = v;
return;
}
public void setManagementContext(org.apache.activemq.broker.jmx.ManagementContext)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagementContext v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.jmx.ManagementContext;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext managementContext> = v;
return;
}
public org.apache.activemq.network.NetworkConnector getNetworkConnectorByName(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List networkConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.network.NetworkConnector: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return null;
}
public java.lang.String[] getNetworkConnectorURIs()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] networkConnectorURIs>;
return v;
}
public void setNetworkConnectorURIs(java.lang.String[])
{
org.apache.activemq.broker.BrokerService v;
java.lang.String[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String[];
v.<org.apache.activemq.broker.BrokerService: java.lang.String[] networkConnectorURIs> = v;
return;
}
public org.apache.activemq.broker.TransportConnector getConnectorByName(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return null;
}
public java.util.Map getTransportConnectorURIsAsMap()
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.util.Iterator v;
java.util.HashMap v;
java.lang.Exception v;
java.util.List v;
java.util.Locale v;
java.lang.Object v;
java.lang.String v, v, v;
java.net.URI v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.net.URI getConnectUri()>();
if v == null goto label;
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
if v == null goto label;
v = <java.util.Locale: java.util.Locale ENGLISH>;
v = virtualinvoke v.<java.lang.String: java.lang.String toLowerCase(java.util.Locale)>(v);
v = virtualinvoke v.<java.net.URI: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Failed to read URI to build transportURIsAsMap", v);
goto label;
label:
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.activemq.broker.ProducerBrokerExchange getProducerBrokerExchange(org.apache.activemq.command.ProducerInfo)
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v, v;
java.util.List v;
org.apache.activemq.command.ProducerInfo v;
java.lang.Object v, v;
org.apache.activemq.broker.ProducerBrokerExchange v;
boolean v, v;
java.util.concurrent.CopyOnWriteArrayList v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.command.ProducerInfo;
v = null;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.util.concurrent.CopyOnWriteArrayList getConnections()>();
v = virtualinvoke v.<java.util.concurrent.CopyOnWriteArrayList: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnection: org.apache.activemq.broker.ProducerBrokerExchange getProducerBrokerExchangeIfExists(org.apache.activemq.command.ProducerInfo)>(v);
if v == null goto label;
return v;
label:
return v;
}
public java.lang.String[] getTransportConnectorURIs()
{
org.apache.activemq.broker.BrokerService v;
java.lang.String[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] transportConnectorURIs>;
return v;
}
public void setTransportConnectorURIs(java.lang.String[])
{
org.apache.activemq.broker.BrokerService v;
java.lang.String[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String[];
v.<org.apache.activemq.broker.BrokerService: java.lang.String[] transportConnectorURIs> = v;
return;
}
public org.apache.activemq.network.jms.JmsConnector[] getJmsBridgeConnectors()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.jms.JmsConnector[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.jms.JmsConnector[] jmsBridgeConnectors>;
return v;
}
public void setJmsBridgeConnectors(org.apache.activemq.network.jms.JmsConnector[])
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.jms.JmsConnector[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.jms.JmsConnector[];
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.jms.JmsConnector[] jmsBridgeConnectors> = v;
return;
}
public org.apache.activemq.Service[] getServices()
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.Service[] v;
java.lang.Object[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
v = newarray (org.apache.activemq.Service)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
public void setServices(org.apache.activemq.Service[])
{
org.apache.activemq.broker.BrokerService v;
java.util.List v, v;
org.apache.activemq.Service[] v;
int v, v;
org.apache.activemq.Service v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.Service[];
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
interfaceinvoke v.<java.util.List: void clear()>();
if v == null goto label;
v = 0;
label:
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
v = v[v];
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return;
}
public void addService(org.apache.activemq.Service)
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.Service v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.Service;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public void removeService(org.apache.activemq.Service)
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
org.apache.activemq.Service v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.Service;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
return;
}
public boolean isUseLoggingForShutdownErrors()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useLoggingForShutdownErrors>;
return v;
}
public void setUseLoggingForShutdownErrors(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useLoggingForShutdownErrors> = v;
return;
}
public boolean isUseShutdownHook()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useShutdownHook>;
return v;
}
public void setUseShutdownHook(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useShutdownHook> = v;
return;
}
public boolean isAdvisorySupport()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean advisorySupport>;
return v;
}
public void setAdvisorySupport(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean advisorySupport> = v;
return;
}
public boolean isAnonymousProducerAdvisorySupport()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean anonymousProducerAdvisorySupport>;
return v;
}
public void setAnonymousProducerAdvisorySupport(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean anonymousProducerAdvisorySupport> = v;
return;
}
public java.util.List getTransportConnectors()
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.ArrayList v;
v := @this: org.apache.activemq.broker.BrokerService;
v = new java.util.ArrayList;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
return v;
}
public void setTransportConnectors(java.util.List) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.Iterator v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector addConnector(org.apache.activemq.broker.TransportConnector)>(v);
goto label;
label:
return;
}
public org.apache.activemq.broker.TransportConnector getTransportConnectorByName(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return null;
}
public org.apache.activemq.broker.TransportConnector getTransportConnectorByScheme(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v;
java.net.URI v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.net.URI getUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getScheme()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
return v;
label:
return null;
}
public java.util.List getNetworkConnectors()
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.ArrayList v;
v := @this: org.apache.activemq.broker.BrokerService;
v = new java.util.ArrayList;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List networkConnectors>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
return v;
}
public java.util.List getProxyConnectors()
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.ArrayList v;
v := @this: org.apache.activemq.broker.BrokerService;
v = new java.util.ArrayList;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List proxyConnectors>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
return v;
}
public void setNetworkConnectors(java.util.List) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.Iterator v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.NetworkConnector addNetworkConnector(org.apache.activemq.network.NetworkConnector)>(v);
goto label;
label:
return;
}
public void setProxyConnectors(java.util.List) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.Iterator v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.proxy.ProxyConnector addProxyConnector(org.apache.activemq.proxy.ProxyConnector)>(v);
goto label;
label:
return;
}
public org.apache.activemq.broker.region.policy.PolicyMap getDestinationPolicy()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.region.policy.PolicyMap v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.policy.PolicyMap destinationPolicy>;
return v;
}
public void setDestinationPolicy(org.apache.activemq.broker.region.policy.PolicyMap)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.region.policy.PolicyMap v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.region.policy.PolicyMap;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.policy.PolicyMap destinationPolicy> = v;
return;
}
public org.apache.activemq.broker.BrokerPlugin[] getPlugins()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerPlugin[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerPlugin[] plugins>;
return v;
}
public void setPlugins(org.apache.activemq.broker.BrokerPlugin[])
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerPlugin[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.BrokerPlugin[];
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerPlugin[] plugins> = v;
return;
}
public org.apache.activemq.security.MessageAuthorizationPolicy getMessageAuthorizationPolicy()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.security.MessageAuthorizationPolicy v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.security.MessageAuthorizationPolicy messageAuthorizationPolicy>;
return v;
}
public void setMessageAuthorizationPolicy(org.apache.activemq.security.MessageAuthorizationPolicy)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.security.MessageAuthorizationPolicy v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.security.MessageAuthorizationPolicy;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.security.MessageAuthorizationPolicy messageAuthorizationPolicy> = v;
return;
}
public void deleteAllMessages() throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void deleteAllMessages()>();
return;
}
public boolean isDeleteAllMessagesOnStartup()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean deleteAllMessagesOnStartup>;
return v;
}
public void setDeleteAllMessagesOnStartup(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean deleteAllMessagesOnStartup> = v;
return;
}
public java.net.URI getVmConnectorURI()
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.net.URISyntaxException v;
java.lang.String v, v, v;
java.net.URI v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.net.URI vmConnectorURI>;
if v != null goto label;
label:
v = new java.net.URI;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("vm://\u0001");
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.broker.BrokerService: java.net.URI vmConnectorURI> = v;
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Badly formed URI from {}", v, v);
label:
v = v.<org.apache.activemq.broker.BrokerService: java.net.URI vmConnectorURI>;
return v;
catch java.net.URISyntaxException from label to label with label;
}
public void setVmConnectorURI(java.net.URI)
{
org.apache.activemq.broker.BrokerService v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.net.URI;
v.<org.apache.activemq.broker.BrokerService: java.net.URI vmConnectorURI> = v;
return;
}
public java.lang.String getDefaultSocketURIString()
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.util.Iterator v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.Exception v;
java.util.List v;
java.lang.Object v;
java.lang.String v, v, v, v;
boolean v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String defaultSocketURIString>;
if v != null goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = null;
label:
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.lang.String getPublishableConnectString()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to get the ConnectURI for {}", v, v);
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: boolean isUpdateClusterClients()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: boolean isRebalanceClusterClients()>();
if v == 0 goto label;
label:
v.<org.apache.activemq.broker.BrokerService: java.lang.String defaultSocketURIString> = v;
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String defaultSocketURIString>;
if v != null goto label;
v.<org.apache.activemq.broker.BrokerService: java.lang.String defaultSocketURIString> = v;
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String defaultSocketURIString>;
return v;
label:
return null;
catch java.lang.Exception from label to label with label;
}
public boolean isShutdownOnMasterFailure()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean shutdownOnMasterFailure>;
return v;
}
public void setShutdownOnMasterFailure(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean shutdownOnMasterFailure> = v;
return;
}
public boolean isKeepDurableSubsActive()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean keepDurableSubsActive>;
return v;
}
public void setKeepDurableSubsActive(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean keepDurableSubsActive> = v;
return;
}
public boolean isEnableMessageExpirationOnActiveDurableSubs()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean enableMessageExpirationOnActiveDurableSubs>;
return v;
}
public void setEnableMessageExpirationOnActiveDurableSubs(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean enableMessageExpirationOnActiveDurableSubs> = v;
return;
}
public boolean isUseVirtualTopics()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useVirtualTopics>;
return v;
}
public void setUseVirtualTopics(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useVirtualTopics> = v;
return;
}
public org.apache.activemq.broker.region.DestinationInterceptor[] getDestinationInterceptors()
{
org.apache.activemq.broker.region.DestinationInterceptor[] v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors>;
return v;
}
public boolean isUseMirroredQueues()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useMirroredQueues>;
return v;
}
public void setUseMirroredQueues(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useMirroredQueues> = v;
return;
}
public void setDestinationInterceptors(org.apache.activemq.broker.region.DestinationInterceptor[])
{
org.apache.activemq.broker.region.DestinationInterceptor[] v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.region.DestinationInterceptor[];
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors> = v;
return;
}
public org.apache.activemq.command.ActiveMQDestination[] getDestinations()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.command.ActiveMQDestination[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.ActiveMQDestination[] destinations>;
return v;
}
public void setDestinations(org.apache.activemq.command.ActiveMQDestination[])
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.command.ActiveMQDestination[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.command.ActiveMQDestination[];
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.ActiveMQDestination[] destinations> = v;
return;
}
public synchronized org.apache.activemq.store.PListStore getTempDataStore()
{
org.apache.activemq.store.PListStore v, v, v, v;
boolean v, v, v;
org.apache.activemq.broker.BrokerService v;
java.io.IOException v;
java.lang.RuntimeException v, v, v;
java.io.File v;
java.lang.Exception v;
java.lang.Class v, v;
java.lang.ClassNotFoundException v;
java.lang.Object v;
java.lang.ClassLoader v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
if v != null goto label;
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: boolean hasStartException()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isPersistent()>();
if v != 0 goto label;
return null;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
if v == null goto label;
v = v instanceof org.apache.activemq.store.PListStore;
if v == 0 goto label;
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.lang.Class loadClass(java.lang.String)>("org.apache.activemq.store.kahadb.plist.PListStoreImpl");
v = virtualinvoke v.<java.lang.Class: java.lang.Object newInstance()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getTmpDataDirectory()>();
interfaceinvoke v.<org.apache.activemq.store.PListStore: void setDirectory(java.io.File)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Kahadb class PListStoreImpl not found. Add activemq-kahadb jar or set persistent to false on BrokerService.", v);
throw v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore>;
return v;
catch java.io.IOException from label to label with label;
catch java.lang.ClassNotFoundException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void setTempDataStore(org.apache.activemq.store.PListStore)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PListStore v;
java.io.File v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.store.PListStore;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PListStore tempDataStore> = v;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory>;
if v != null goto label;
v = interfaceinvoke v.<org.apache.activemq.store.PListStore: java.io.File getDirectory()>();
v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory> = v;
goto label;
label:
v = interfaceinvoke v.<org.apache.activemq.store.PListStore: java.io.File getDirectory()>();
if v != null goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.io.File tmpDataDirectory>;
interfaceinvoke v.<org.apache.activemq.store.PListStore: void setDirectory(java.io.File)>(v);
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
return;
}
public int getPersistenceThreadPriority()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int persistenceThreadPriority>;
return v;
}
public void setPersistenceThreadPriority(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int persistenceThreadPriority> = v;
return;
}
public boolean isUseLocalHostBrokerName()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useLocalHostBrokerName>;
return v;
}
public void setUseLocalHostBrokerName(boolean)
{
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.atomic.AtomicBoolean v;
java.lang.String v, v, v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useLocalHostBrokerName> = v;
if v == 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean started>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
if v == null goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
if v != "localhost" goto label;
label:
v = <org.apache.activemq.broker.BrokerService: java.lang.String LOCAL_HOST_NAME>;
v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName> = v;
label:
return;
}
public org.apache.activemq.broker.region.Destination getDestination(org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.broker.region.Destination v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 0);
return v;
}
public void removeDestination(org.apache.activemq.command.ActiveMQDestination) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
interfaceinvoke v.<org.apache.activemq.broker.Broker: void removeDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,long)>(v, v, 0L);
return;
}
public int getProducerSystemUsagePortion()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int producerSystemUsagePortion>;
return v;
}
public void setProducerSystemUsagePortion(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int producerSystemUsagePortion> = v;
return;
}
public int getConsumerSystemUsagePortion()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int consumerSystemUsagePortion>;
return v;
}
public void setConsumerSystemUsagePortion(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int consumerSystemUsagePortion> = v;
return;
}
public boolean isSplitSystemUsageForProducersConsumers()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean splitSystemUsageForProducersConsumers>;
return v;
}
public void setSplitSystemUsageForProducersConsumers(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean splitSystemUsageForProducersConsumers> = v;
return;
}
public boolean isMonitorConnectionSplits()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean monitorConnectionSplits>;
return v;
}
public void setMonitorConnectionSplits(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean monitorConnectionSplits> = v;
return;
}
public int getTaskRunnerPriority()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int taskRunnerPriority>;
return v;
}
public void setTaskRunnerPriority(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int taskRunnerPriority> = v;
return;
}
public boolean isDedicatedTaskRunner()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean dedicatedTaskRunner>;
return v;
}
public void setDedicatedTaskRunner(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean dedicatedTaskRunner> = v;
return;
}
public boolean isCacheTempDestinations()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean cacheTempDestinations>;
return v;
}
public void setCacheTempDestinations(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean cacheTempDestinations> = v;
return;
}
public int getTimeBeforePurgeTempDestinations()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int timeBeforePurgeTempDestinations>;
return v;
}
public void setTimeBeforePurgeTempDestinations(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int timeBeforePurgeTempDestinations> = v;
return;
}
public boolean isUseTempMirroredQueues()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useTempMirroredQueues>;
return v;
}
public void setUseTempMirroredQueues(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useTempMirroredQueues> = v;
return;
}
public synchronized org.apache.activemq.broker.scheduler.JobSchedulerStore getJobSchedulerStore()
{
boolean v, v, v, v;
org.apache.activemq.broker.BrokerService v;
java.lang.Exception v, v;
java.lang.ClassLoader v;
org.apache.activemq.broker.scheduler.memory.InMemoryJobSchedulerStore v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.UnsupportedOperationException v;
org.slf4j.Logger v;
java.io.IOException v, v;
java.lang.RuntimeException v, v, v, v;
java.io.File v, v, v;
java.lang.Class v, v;
java.lang.Object v;
org.apache.activemq.store.PersistenceAdapter v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isSchedulerSupport()>();
if v != 0 goto label;
return null;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
if v != null goto label;
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: boolean hasStartException()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isPersistent()>();
if v != 0 goto label;
v = new org.apache.activemq.broker.scheduler.memory.InMemoryJobSchedulerStore;
specialinvoke v.<org.apache.activemq.broker.scheduler.memory.InMemoryJobSchedulerStore: void <init>()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
return v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getSchedulerDirectoryFile()>();
interfaceinvoke v.<org.apache.activemq.broker.scheduler.JobSchedulerStore: void setDirectory(java.io.File)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v := @caughtexception;
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
if v == null goto label;
v = v instanceof org.apache.activemq.broker.scheduler.JobSchedulerStore;
if v == 0 goto label;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.lang.Class loadClass(java.lang.String)>("org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter");
v = virtualinvoke v.<java.lang.Class: java.lang.Object newInstance()>();
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: org.apache.activemq.broker.scheduler.JobSchedulerStore createJobSchedulerStore()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getSchedulerDirectoryFile()>();
interfaceinvoke v.<org.apache.activemq.broker.scheduler.JobSchedulerStore: void setDirectory(java.io.File)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getSchedulerDirectoryFile()>();
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("JobScheduler using directory: {}", v);
label:
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore>;
return v;
catch java.io.IOException from label to label with label;
catch java.lang.UnsupportedOperationException from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.io.IOException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public void setJobSchedulerStore(org.apache.activemq.broker.scheduler.JobSchedulerStore)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.scheduler.JobSchedulerStore;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore jobSchedulerStore> = v;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
return;
}
protected void processHelperProperties() throws java.lang.Exception
{
org.apache.activemq.network.jms.JmsConnector v;
java.lang.String[] v, v, v, v, v, v;
int v, v, v, v, v, v;
java.lang.String v, v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.jms.JmsConnector[] v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] transportConnectorURIs>;
if v == null goto label;
v = 0;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] transportConnectorURIs>;
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] transportConnectorURIs>;
v = v[v];
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector addConnector(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] networkConnectorURIs>;
if v == null goto label;
v = 0;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] networkConnectorURIs>;
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String[] networkConnectorURIs>;
v = v[v];
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.NetworkConnector addNetworkConnector(java.lang.String)>(v);
v = v + 1;
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.jms.JmsConnector[] jmsBridgeConnectors>;
if v == null goto label;
v = 0;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.jms.JmsConnector[] jmsBridgeConnectors>;
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.jms.JmsConnector[] jmsBridgeConnectors>;
v = v[v];
virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.network.jms.JmsConnector addJmsConnector(org.apache.activemq.network.jms.JmsConnector)>(v);
v = v + 1;
goto label;
label:
return;
}
protected void checkStoreUsageLimits() throws java.lang.Exception
{
long v, v, v;
byte v, v;
java.lang.Long v, v;
int v, v;
org.apache.activemq.usage.SystemUsage v;
boolean v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.io.File v;
org.apache.activemq.usage.StoreUsage v, v, v;
org.apache.activemq.store.PersistenceAdapter v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: java.io.File getDirectory()>();
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.StoreUsage getStoreUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.StoreUsage getStoreUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.StoreUsage: int getPercentLimit()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void checkUsageLimit(java.io.File,org.apache.activemq.usage.PercentLimitUsage,int)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.StoreUsage getStoreUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.StoreUsage: long getLimit()>();
v = v instanceof org.apache.activemq.store.JournaledStore;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.activemq.store.JournaledStore: int getJournalMaxFileLength()>();
label:
v = v cmp 0L;
if v <= 0 goto label;
v = v cmp v;
if v >= 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Store limit is {} mb, whilst the max journal file size for the store is {} mb, the store will not accept any data when used.", v, v);
label:
return;
}
protected void checkTmpStoreUsageLimits() throws java.lang.Exception
{
org.apache.activemq.usage.TempUsage v, v, v, v;
long v, v, v;
byte v, v;
java.lang.Long v, v;
int v, v;
org.apache.activemq.store.PListStore v;
org.apache.activemq.usage.SystemUsage v;
boolean v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getTmpDataDirectory()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.TempUsage getTempUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.TempUsage getTempUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.TempUsage: int getPercentLimit()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void checkUsageLimit(java.io.File,org.apache.activemq.usage.PercentLimitUsage,int)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isPersistent()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.TempUsage getTempUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.TempUsage: org.apache.activemq.store.PListStore getStore()>();
if v == null goto label;
v = v instanceof org.apache.activemq.store.JournaledStore;
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.activemq.store.JournaledStore: int getJournalMaxFileLength()>();
goto label;
label:
v = 33554432L;
label:
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.TempUsage getTempUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.TempUsage: long getLimit()>();
v = v cmp 0L;
if v <= 0 goto label;
v = v cmp v;
if v >= 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object,java.lang.Object)>("Temporary Store limit {} mb, whilst the max journal file size for the temporary store is {} mb, the temp store will not accept any data when used.", v, v);
label:
return;
}
protected void checkUsageLimit(java.io.File, org.apache.activemq.usage.PercentLimitUsage, int) throws org.apache.activemq.ConfigurationException
{
java.lang.Integer v, v;
byte v, v, v, v, v, v, v, v, v, v;
java.lang.Long v, v, v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
java.lang.Object[] v;
long 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;
java.lang.String v, v, v, v, v;
java.io.File v, v;
org.apache.activemq.usage.PercentLimitUsage v;
boolean v, v;
int v, v, v, v;
org.apache.activemq.ConfigurationException v, v;
org.slf4j.Logger v, v, v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.io.File;
v := @parameter: org.apache.activemq.usage.PercentLimitUsage;
v := @parameter: int;
if v == null goto label;
v = staticinvoke <org.apache.activemq.util.StoreUtil: java.io.File findParentDirectory(java.io.File)>(v);
v = v instanceof org.apache.activemq.usage.StoreUsage;
if v == 0 goto label;
v = "Store";
goto label;
label:
v = "Temporary Store";
label:
v = v;
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getLimit()>();
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getTotal()>();
v = v cmp 0L;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getTotal()>();
goto label;
label:
v = virtualinvoke v.<java.io.File: long getTotalSpace()>();
label:
v = v;
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getTotal()>();
v = v cmp 0L;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getTotal()>();
goto label;
label:
v = virtualinvoke v.<java.io.File: long getUsableSpace()>();
label:
v = v + v;
v = v cmp 0L;
if v < 0 goto label;
v = v cmp 0L;
if v >= 0 goto label;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Object)>("File system space reported by {} was negative, possibly a huge file system, set a sane usage.total to provide some guidance", v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("File system space reported by: \u was negative, possibly a huge file system, set a sane usage.total to provide some guidance");
v = new org.apache.activemq.ConfigurationException;
specialinvoke v.<org.apache.activemq.ConfigurationException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v * v;
v = v / 100L;
v = v.<org.apache.activemq.broker.BrokerService: int diskUsageCheckRegrowThreshold>;
v = (int) -1;
if v <= v goto label;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: long getTotal()>();
v = v cmp 0L;
if v != 0 goto label;
v = v cmp v;
if v >= 0 goto label;
v = v cmp v;
if v >= 0 goto label;
v = v cmp v;
if v <= 0 goto label;
v = v;
goto label;
label:
v = v;
label:
v = v - v;
v = v.<org.apache.activemq.broker.BrokerService: int diskUsageCheckRegrowThreshold>;
v = v cmp v;
if v < 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("Usable disk space has been increased, attempting to regrow {} limit to {}% of the parition size", v, v);
virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: void setLimit(long)>(v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = v * 100L;
v = v / v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v = v / 1048576;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object,java.lang.Object)>("{} limit has been increase to {}% ({} mb) of the partition size.", v, v);
goto label;
label:
v = v cmp v;
if v <= 0 goto label;
v = v / 1048576;
v = v / 1048576;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = v / 1048576;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long,long,java.lang.String,long)>(v, v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u limit is \u mb (current store usage is \u mb). The data directory: \u only has \u mb of usable space.");
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isAdjustUsageLimits()>();
if v != 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
v = new org.apache.activemq.ConfigurationException;
specialinvoke v.<org.apache.activemq.ConfigurationException: void <init>(java.lang.String)>(v);
throw v;
label:
if v <= 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[6];
v[0] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[1] = v;
v = v / 1048576;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[2] = v;
v = v / 1048576;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[3] = v;
v = v * 100L;
v = v / v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[4] = v;
v = v / 1048576;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[5] = v;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object[])>("{} limit has been set to {}% ({} mb) of the partition size but there is not enough usable space.The current store limit (which may have been adjusted by a previous usage limit check) is set to ({} mb) but only {}% ({} mb) is available - resetting limit", v);
goto label;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = v / 1048576;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("{} - resetting to maximum available disk space: {} mb", v, v);
label:
virtualinvoke v.<org.apache.activemq.usage.PercentLimitUsage: void setLimit(long)>(v);
label:
return;
}
protected void scheduleDiskUsageLimitsCheck() throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.thread.Scheduler v;
int v, v;
org.apache.activemq.store.PersistenceAdapter v;
org.apache.activemq.broker.BrokerService$5 v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDiskUsageCheck>;
if v <= 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getTmpDataDirectory()>();
if v == null goto label;
label:
v = new org.apache.activemq.broker.BrokerService$5;
specialinvoke v.<org.apache.activemq.broker.BrokerService$5: void <init>(org.apache.activemq.broker.BrokerService)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler>;
v = v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDiskUsageCheck>;
virtualinvoke v.<org.apache.activemq.thread.Scheduler: void executePeriodically(java.lang.Runnable,long)>(v, v);
label:
return;
}
protected void checkMemorySystemUsageLimits() throws java.lang.Exception
{
long v, v, v, v, v, v;
byte v;
java.lang.Long v;
org.apache.activemq.usage.MemoryUsage v, v, v;
org.apache.activemq.usage.SystemUsage v;
java.lang.String v;
org.apache.activemq.ConfigurationException v;
boolean v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v, v;
java.lang.Runtime v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: long getLimit()>();
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = virtualinvoke v.<java.lang.Runtime: long maxMemory()>();
v = v cmp v;
if v <= 0 goto label;
v = v / 1048576L;
v = v / 1048576L;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Memory Usage for the Broker (\u0001mb) is more than the maximum available for the JVM: \u0001");
v = v.<org.apache.activemq.broker.BrokerService: boolean adjustUsageLimits>;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void setPercentOfJvmHeap(int)>(70);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: long getLimit()>();
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("{} mb - resetting to 70% of maximum available: {}", v, v);
goto label;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>(v);
v = new org.apache.activemq.ConfigurationException;
specialinvoke v.<org.apache.activemq.ConfigurationException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
protected void checkStoreSystemUsageLimits() throws java.lang.Exception
{
java.lang.Object[] v;
long v, v, v, v, v;
org.apache.activemq.usage.JobSchedulerUsage v, v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v, v;
byte v;
java.lang.Long v, v, v;
org.apache.activemq.usage.SystemUsage v;
java.lang.String v, v;
boolean v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.io.File v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getSystemUsage()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void checkStoreUsageLimits()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void checkTmpStoreUsageLimits()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void scheduleDiskUsageLimitsCheck()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore getJobSchedulerStore()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore getJobSchedulerStore()>();
v = interfaceinvoke v.<org.apache.activemq.broker.scheduler.JobSchedulerStore: java.io.File getDirectory()>();
if v == null goto label;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v = virtualinvoke v.<java.io.File: boolean isAbsolute()>();
if v != 0 goto label;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = v;
label:
if v == null goto label;
v = virtualinvoke v.<java.io.File: boolean isDirectory()>();
if v != 0 goto label;
v = virtualinvoke v.<java.io.File: java.io.File getParentFile()>();
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.JobSchedulerUsage getJobSchedulerUsage()>();
v = virtualinvoke v.<org.apache.activemq.usage.JobSchedulerUsage: long getLimit()>();
v = virtualinvoke v.<java.io.File: long getUsableSpace()>();
v = v cmp v;
if v <= 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = newarray (java.lang.Object)[4];
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[0] = v;
v = virtualinvoke v.<java.io.File: java.lang.String getAbsolutePath()>();
v[1] = v;
v = v / 1048576L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[2] = v;
v = v / 1067008L;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[3] = v;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object[])>("Job Scheduler Store limit is {} mb, whilst the data directory: {} only has {} mb of usage space - resetting to {} mb.", v);
v = virtualinvoke v.<org.apache.activemq.usage.SystemUsage: org.apache.activemq.usage.JobSchedulerUsage getJobSchedulerUsage()>();
virtualinvoke v.<org.apache.activemq.usage.JobSchedulerUsage: void setLimit(long)>(v);
label:
return;
}
public void stopAllConnectors(org.apache.activemq.util.ServiceStopper)
{
org.apache.activemq.util.ServiceStopper v;
boolean v, v, v, v;
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v, v, v, v;
java.io.IOException v;
java.util.List v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.util.ServiceStopper;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getNetworkConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void unregisterNetworkConnectorMBean(org.apache.activemq.network.NetworkConnector)>(v);
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getProxyConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List jmsConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getTransportConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void unregisterConnectorMBean(org.apache.activemq.broker.TransportConnector)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void stop(org.apache.activemq.Service)>(v);
goto label;
label:
return;
catch java.io.IOException from label to label with label;
}
protected org.apache.activemq.broker.TransportConnector registerConnectorMBean(org.apache.activemq.broker.TransportConnector) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ConnectorView v;
java.io.IOException v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ManagementContext v, v;
org.apache.activemq.broker.jmx.ManagedTransportConnector v;
org.apache.activemq.broker.TransportConnector v;
java.lang.String v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.TransportConnector;
label:
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName createConnectorObjectName(org.apache.activemq.broker.TransportConnector)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: org.apache.activemq.broker.jmx.ManagedTransportConnector asManagedConnector(org.apache.activemq.broker.jmx.ManagementContext,javax.management.ObjectName)>(v, v);
v = new org.apache.activemq.broker.jmx.ConnectorView;
specialinvoke v.<org.apache.activemq.broker.jmx.ConnectorView: void <init>(org.apache.activemq.broker.Connector)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
return v;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Transport Connector could not be registered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.Throwable from label to label with label;
}
protected void unregisterConnectorMBean(org.apache.activemq.broker.TransportConnector) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
java.io.IOException v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.broker.TransportConnector v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.TransportConnector;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
label:
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName createConnectorObjectName(org.apache.activemq.broker.TransportConnector)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Transport Connector could not be unregistered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected org.apache.activemq.store.PersistenceAdapter registerPersistenceAdapterMBean(org.apache.activemq.store.PersistenceAdapter) throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.store.PersistenceAdapter;
return v;
}
protected void unregisterPersistenceAdapterMBean(org.apache.activemq.store.PersistenceAdapter) throws java.io.IOException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.store.PersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.store.PersistenceAdapter;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
return;
}
private javax.management.ObjectName createConnectorObjectName(org.apache.activemq.broker.TransportConnector) throws javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.TransportConnector v;
java.lang.String v;
javax.management.ObjectName v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.TransportConnector;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: java.lang.String getName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createConnectorName(javax.management.ObjectName,java.lang.String,java.lang.String)>(v, "clientConnectors", v);
return v;
}
public void registerNetworkConnectorMBean(org.apache.activemq.network.NetworkConnector) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.NetworkConnector v;
java.io.IOException v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.broker.jmx.NetworkConnectorView v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
v = new org.apache.activemq.broker.jmx.NetworkConnectorView;
specialinvoke v.<org.apache.activemq.broker.jmx.NetworkConnectorView: void <init>(org.apache.activemq.network.NetworkConnector)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName createNetworkConnectorObjectName(org.apache.activemq.network.NetworkConnector)>(v);
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setObjectName(javax.management.ObjectName)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Network Connector could not be registered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public javax.management.ObjectName createNetworkConnectorObjectName(org.apache.activemq.network.NetworkConnector) throws javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.NetworkConnector v;
java.lang.String v;
javax.management.ObjectName v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<org.apache.activemq.network.NetworkConnector: java.lang.String getName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createNetworkConnectorName(javax.management.ObjectName,java.lang.String,java.lang.String)>(v, "networkConnectors", v);
return v;
}
public javax.management.ObjectName createDuplexNetworkConnectorObjectName(java.lang.String) throws javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
javax.management.ObjectName v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createNetworkConnectorName(javax.management.ObjectName,java.lang.String,java.lang.String)>(v, "duplexNetworkConnectors", v);
return v;
}
protected void unregisterNetworkConnectorMBean(org.apache.activemq.network.NetworkConnector)
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
org.apache.activemq.network.NetworkConnector v;
javax.management.ObjectName v;
java.lang.Exception v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName createNetworkConnectorObjectName(org.apache.activemq.network.NetworkConnector)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void unregisterMBean(javax.management.ObjectName)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<java.lang.Exception: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Network Connector could not be unregistered from JMX due {}. This exception is ignored.", v, v);
label:
return;
catch java.lang.Exception from label to label with label;
}
protected void registerProxyConnectorMBean(org.apache.activemq.proxy.ProxyConnector) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ProxyConnectorView v;
java.io.IOException v;
javax.management.ObjectName v, v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.proxy.ProxyConnector v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.proxy.ProxyConnector;
v = new org.apache.activemq.broker.jmx.ProxyConnectorView;
specialinvoke v.<org.apache.activemq.broker.jmx.ProxyConnectorView: void <init>(org.apache.activemq.proxy.ProxyConnector)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<org.apache.activemq.proxy.ProxyConnector: java.lang.String getName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createNetworkConnectorName(javax.management.ObjectName,java.lang.String,java.lang.String)>(v, "proxyConnectors", v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Broker could not be registered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected void registerJmsConnectorMBean(org.apache.activemq.network.jms.JmsConnector) throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.JmsConnectorView v;
org.apache.activemq.network.jms.JmsConnector v;
java.io.IOException v;
javax.management.ObjectName v, v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.lang.String v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.jms.JmsConnector;
v = new org.apache.activemq.broker.jmx.JmsConnectorView;
specialinvoke v.<org.apache.activemq.broker.jmx.JmsConnectorView: void <init>(org.apache.activemq.network.jms.JmsConnector)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<org.apache.activemq.network.jms.JmsConnector: java.lang.String getName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createNetworkConnectorName(javax.management.ObjectName,java.lang.String,java.lang.String)>(v, "jmsConnectors", v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Broker could not be registered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
protected org.apache.activemq.broker.Broker createBroker() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v, v, v;
org.apache.activemq.broker.BrokerService$6 v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker createRegionBroker()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker regionBroker> = v;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker regionBroker>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker addInterceptors(org.apache.activemq.broker.Broker)>(v);
v = new org.apache.activemq.broker.BrokerService$6;
specialinvoke v.<org.apache.activemq.broker.BrokerService$6: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.broker.Broker)>(v, v);
return v;
}
protected org.apache.activemq.broker.Broker createRegionBroker() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.region.CompositeDestinationInterceptor v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.thread.TaskRunnerFactory v;
org.apache.activemq.broker.region.DestinationInterceptor[] v, v, v, v;
org.apache.activemq.store.PersistenceAdapter v;
org.apache.activemq.broker.region.DestinationFactory v;
org.apache.activemq.broker.region.DestinationFactoryImpl v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] createDefaultDestinationInterceptor()>();
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors>;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureServices(java.lang.Object[])>(v);
v = new org.apache.activemq.broker.region.CompositeDestinationInterceptor;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors>;
specialinvoke v.<org.apache.activemq.broker.region.CompositeDestinationInterceptor: void <init>(org.apache.activemq.broker.region.DestinationInterceptor[])>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory>;
if v != null goto label;
v = new org.apache.activemq.broker.region.DestinationFactoryImpl;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
specialinvoke v.<org.apache.activemq.broker.region.DestinationFactoryImpl: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.store.PersistenceAdapter)>(v, v, v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory> = v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker createRegionBroker(org.apache.activemq.broker.region.DestinationInterceptor)>(v);
return v;
}
protected org.apache.activemq.broker.Broker createRegionBroker(org.apache.activemq.broker.region.DestinationInterceptor) throws java.io.IOException
{
java.util.concurrent.ThreadPoolExecutor v, v;
org.apache.activemq.broker.jmx.ManagedRegionBroker v;
org.apache.activemq.broker.jmx.ManagementContext v;
org.apache.activemq.usage.SystemUsage v, v;
java.lang.String v, v;
org.apache.activemq.broker.region.DestinationFactory v, v, v;
boolean v, v, v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.io.IOException v;
javax.management.ObjectName v;
org.apache.activemq.broker.region.DestinationInterceptor v;
javax.management.MalformedObjectNameException v;
org.apache.activemq.command.BrokerId v, v;
org.apache.activemq.thread.Scheduler v, v;
org.apache.activemq.thread.TaskRunnerFactory v, v;
org.apache.activemq.broker.region.DestinationStatistics v;
org.apache.activemq.broker.region.RegionBroker v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.region.DestinationInterceptor;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
label:
v = new org.apache.activemq.broker.jmx.ManagedRegionBroker;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getConsumerSystemUsage()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler getScheduler()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor getExecutor()>();
specialinvoke v.<org.apache.activemq.broker.jmx.ManagedRegionBroker: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.broker.jmx.ManagementContext,javax.management.ObjectName,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.region.DestinationFactory,org.apache.activemq.broker.region.DestinationInterceptor,org.apache.activemq.thread.Scheduler,java.util.concurrent.ThreadPoolExecutor)>(v, v, v, v, v, v, v, v, v);
v = v;
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = virtualinvoke v.<javax.management.MalformedObjectNameException: java.lang.String getMessage()>();
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object,java.lang.Object)>("Cannot create ManagedRegionBroker due {}", v, v);
v = new java.io.IOException;
specialinvoke v.<java.io.IOException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
v = new org.apache.activemq.broker.region.RegionBroker;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.usage.SystemUsage getConsumerSystemUsage()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler getScheduler()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor getExecutor()>();
specialinvoke v.<org.apache.activemq.broker.region.RegionBroker: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.thread.TaskRunnerFactory,org.apache.activemq.usage.SystemUsage,org.apache.activemq.broker.region.DestinationFactory,org.apache.activemq.broker.region.DestinationInterceptor,org.apache.activemq.thread.Scheduler,java.util.concurrent.ThreadPoolExecutor)>(v, v, v, v, v, v, v);
v = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory>;
virtualinvoke v.<org.apache.activemq.broker.region.DestinationFactory: void setRegionBroker(org.apache.activemq.broker.region.RegionBroker)>(v);
v = v.<org.apache.activemq.broker.BrokerService: boolean keepDurableSubsActive>;
virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: void setKeepDurableSubsActive(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: void setBrokerName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: org.apache.activemq.broker.region.DestinationStatistics getDestinationStatistics()>();
v = v.<org.apache.activemq.broker.BrokerService: boolean enableStatistics>;
virtualinvoke v.<org.apache.activemq.broker.region.DestinationStatistics: void setEnabled(boolean)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isAllowTempAutoCreationOnSend()>();
virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: void setAllowTempAutoCreationOnSend(boolean)>(v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId>;
virtualinvoke v.<org.apache.activemq.broker.region.RegionBroker: void setBrokerId(org.apache.activemq.command.BrokerId)>(v);
label:
return v;
catch javax.management.MalformedObjectNameException from label to label with label;
}
protected org.apache.activemq.broker.region.DestinationInterceptor[] createDefaultDestinationInterceptor()
{
org.apache.activemq.broker.BrokerService v;
java.util.ArrayList v;
org.apache.activemq.broker.region.virtual.MirroredQueue v;
org.apache.activemq.broker.region.virtual.VirtualTopic v;
int v;
org.apache.activemq.broker.region.DestinationInterceptor[] v;
org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor v;
org.apache.activemq.broker.region.virtual.VirtualDestination[] v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseVirtualTopics()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor;
specialinvoke v.<org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor: void <init>()>();
v = new org.apache.activemq.broker.region.virtual.VirtualTopic;
specialinvoke v.<org.apache.activemq.broker.region.virtual.VirtualTopic: void <init>()>();
virtualinvoke v.<org.apache.activemq.broker.region.virtual.VirtualTopic: void setName(java.lang.String)>("VirtualTopic.>");
v = newarray (org.apache.activemq.broker.region.virtual.VirtualDestination)[1];
v[0] = v;
virtualinvoke v.<org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor: void setVirtualDestinations(org.apache.activemq.broker.region.virtual.VirtualDestination[])>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseMirroredQueues()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.region.virtual.MirroredQueue;
specialinvoke v.<org.apache.activemq.broker.region.virtual.MirroredQueue: void <init>()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.activemq.broker.region.DestinationInterceptor)[v];
interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
return v;
}
protected org.apache.activemq.broker.Broker addInterceptors(org.apache.activemq.broker.Broker) throws java.lang.Exception
{
org.apache.activemq.broker.scheduler.SchedulerBroker v;
org.apache.activemq.broker.UserIDBroker v;
org.apache.activemq.advisory.AdvisoryBroker v;
org.apache.activemq.broker.jmx.BrokerView v;
org.apache.activemq.broker.jmx.ManagementContext v, v;
boolean v, v, v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerPlugin[] v, v, v;
javax.management.ObjectName v, v, v, v;
org.apache.activemq.broker.TransactionBroker v;
java.lang.Throwable v, v;
org.apache.activemq.broker.CompositeDestinationBroker v;
org.apache.activemq.broker.cluster.ConnectionSplitBroker v;
org.apache.activemq.broker.scheduler.JobScheduler v;
org.apache.activemq.broker.Broker v, v, v;
org.apache.activemq.broker.scheduler.JobSchedulerStore v;
org.apache.activemq.broker.jmx.JobSchedulerView v;
org.apache.activemq.broker.jmx.HealthView v;
int v, v, v;
java.lang.String v, v, v, v;
org.apache.activemq.broker.BrokerPlugin v;
org.apache.activemq.store.TransactionStore v;
java.io.IOException v, v;
org.apache.activemq.store.PersistenceAdapter v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.Broker;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isSchedulerSupport()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.scheduler.SchedulerBroker;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.scheduler.JobSchedulerStore getJobSchedulerStore()>();
specialinvoke v.<org.apache.activemq.broker.scheduler.SchedulerBroker: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.broker.Broker,org.apache.activemq.broker.scheduler.JobSchedulerStore)>(v, v, v);
v = v.<org.apache.activemq.broker.BrokerService: int maxSchedulerRepeatAllowed>;
virtualinvoke v.<org.apache.activemq.broker.scheduler.SchedulerBroker: void setMaxRepeatAllowed(int)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.jmx.JobSchedulerView;
v = virtualinvoke v.<org.apache.activemq.broker.scheduler.SchedulerBroker: org.apache.activemq.broker.scheduler.JobScheduler getJobScheduler()>();
specialinvoke v.<org.apache.activemq.broker.jmx.JobSchedulerView: void <init>(org.apache.activemq.broker.scheduler.JobScheduler)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createJobSchedulerServiceName(javax.management.ObjectName)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView>;
virtualinvoke v.<org.apache.activemq.broker.jmx.BrokerView: void setJMSJobScheduler(javax.management.ObjectName)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("JobScheduler could not be registered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.jmx.HealthView;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getRegionBroker()>();
specialinvoke v.<org.apache.activemq.broker.jmx.HealthView: void <init>(org.apache.activemq.broker.jmx.ManagedRegionBroker)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createHealthServiceName(javax.management.ObjectName)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String getMessage()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Status MBean could not be registered in JMX: \u0001");
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isAdvisorySupport()>();
if v == 0 goto label;
v = new org.apache.activemq.advisory.AdvisoryBroker;
specialinvoke v.<org.apache.activemq.advisory.AdvisoryBroker: void <init>(org.apache.activemq.broker.Broker)>(v);
v = v;
label:
v = new org.apache.activemq.broker.CompositeDestinationBroker;
specialinvoke v.<org.apache.activemq.broker.CompositeDestinationBroker: void <init>(org.apache.activemq.broker.Broker)>(v);
v = new org.apache.activemq.broker.TransactionBroker;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapter getPersistenceAdapter()>();
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: org.apache.activemq.store.TransactionStore createTransactionStore()>();
specialinvoke v.<org.apache.activemq.broker.TransactionBroker: void <init>(org.apache.activemq.broker.Broker,org.apache.activemq.store.TransactionStore)>(v, v);
v = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isPopulateJMSXUserID()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.UserIDBroker;
specialinvoke v.<org.apache.activemq.broker.UserIDBroker: void <init>(org.apache.activemq.broker.Broker)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseAuthenticatedPrincipalForJMSXUserID()>();
virtualinvoke v.<org.apache.activemq.broker.UserIDBroker: void setUseAuthenticatePrincipal(boolean)>(v);
v = v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isMonitorConnectionSplits()>();
if v == 0 goto label;
v = new org.apache.activemq.broker.cluster.ConnectionSplitBroker;
specialinvoke v.<org.apache.activemq.broker.cluster.ConnectionSplitBroker: void <init>(org.apache.activemq.broker.Broker)>(v);
v = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerPlugin[] plugins>;
if v == null goto label;
v = 0;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerPlugin[] plugins>;
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerPlugin[] plugins>;
v = v[v];
v = interfaceinvoke v.<org.apache.activemq.broker.BrokerPlugin: org.apache.activemq.broker.Broker installPlugin(org.apache.activemq.broker.Broker)>(v);
v = v + 1;
goto label;
label:
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
protected org.apache.activemq.store.PersistenceAdapter createPersistenceAdapter() throws java.io.IOException
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
java.io.IOException v;
org.apache.activemq.store.PersistenceAdapterFactory v;
java.io.File v, v;
org.apache.activemq.store.memory.MemoryPersistenceAdapter v;
java.lang.Class v, v;
java.lang.Object v;
java.lang.ClassLoader v;
org.apache.activemq.store.PersistenceAdapter v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isPersistent()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.store.PersistenceAdapterFactory getPersistenceFactory()>();
if v == null goto label;
v = interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapterFactory: org.apache.activemq.store.PersistenceAdapter createPersistenceAdapter()>();
return v;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.lang.Class loadClass(java.lang.String)>("org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter");
v = virtualinvoke v.<java.lang.Class: java.lang.Object newInstance()>();
v = new java.io.File;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getBrokerDataDirectory()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "KahaDB");
interfaceinvoke v.<org.apache.activemq.store.PersistenceAdapter: void setDirectory(java.io.File)>(v);
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Throwable)>(v);
throw v;
label:
v = new org.apache.activemq.store.memory.MemoryPersistenceAdapter;
specialinvoke v.<org.apache.activemq.store.memory.MemoryPersistenceAdapter: void <init>()>();
return v;
catch java.lang.Throwable from label to label with label;
}
protected javax.management.ObjectName createBrokerObjectName() throws javax.management.MalformedObjectNameException
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.lang.String v, v;
javax.management.ObjectName v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: java.lang.String getJmxDomainName()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = staticinvoke <org.apache.activemq.broker.jmx.BrokerMBeanSupport: javax.management.ObjectName createBrokerObjectName(java.lang.String,java.lang.String)>(v, v);
return v;
}
protected org.apache.activemq.broker.TransportConnector createTransportConnector(java.net.URI) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.TransportConnector v;
org.apache.activemq.transport.TransportServer v;
java.net.URI v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.net.URI;
v = staticinvoke <org.apache.activemq.transport.TransportFactorySupport: org.apache.activemq.transport.TransportServer bind(org.apache.activemq.broker.BrokerService,java.net.URI)>(v, v);
v = new org.apache.activemq.broker.TransportConnector;
specialinvoke v.<org.apache.activemq.broker.TransportConnector: void <init>(org.apache.activemq.transport.TransportServer)>(v);
return v;
}
protected java.lang.Object getPort(java.util.Map)
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.util.Map v;
java.lang.Object v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.util.Map;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>("port");
if v != null goto label;
v = "61616";
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Object)>("No port specified so defaulting to: {}", "61616");
label:
return v;
}
protected void addShutdownHook()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.BrokerService$7 v;
java.lang.Runtime v;
java.lang.Thread v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useShutdownHook>;
if v == 0 goto label;
v = new org.apache.activemq.broker.BrokerService$7;
specialinvoke v.<org.apache.activemq.broker.BrokerService$7: void <init>(org.apache.activemq.broker.BrokerService,java.lang.String)>(v, "ActiveMQ ShutdownHook");
v.<org.apache.activemq.broker.BrokerService: java.lang.Thread shutdownHook> = v;
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Thread shutdownHook>;
virtualinvoke v.<java.lang.Runtime: void addShutdownHook(java.lang.Thread)>(v);
label:
return;
}
protected void removeShutdownHook()
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.lang.Runtime v;
java.lang.Thread v, v;
java.lang.Exception v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Thread shutdownHook>;
if v == null goto label;
label:
v = staticinvoke <java.lang.Runtime: java.lang.Runtime getRuntime()>();
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Thread shutdownHook>;
virtualinvoke v.<java.lang.Runtime: boolean removeShutdownHook(java.lang.Thread)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Throwable)>("Caught exception, must be shutting down. This exception is ignored.", v);
label:
return;
catch java.lang.Exception from label to label with label;
}
public void setShutdownHooks(java.util.List) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.util.Iterator v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void addShutdownHook(java.lang.Runnable)>(v);
goto label;
label:
return;
}
protected void containerShutdown()
{
java.io.PrintStream v;
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
java.io.IOException v;
java.lang.Exception v;
java.lang.String v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
label:
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void stop()>();
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<java.io.IOException: java.lang.Throwable getCause()>();
if v == null goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.IOException,java.lang.Throwable)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to shut down: \u. Reason: \u0001");
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void logError(java.lang.String,java.lang.Throwable)>(v, v);
goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.IOException)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to shut down: \u0001");
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void logError(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = v.<org.apache.activemq.broker.BrokerService: boolean useLoggingForShutdownErrors>;
if v != 0 goto label;
v = <java.lang.System: java.io.PrintStream err>;
virtualinvoke v.<java.io.IOException: void printStackTrace(java.io.PrintStream)>(v);
goto label;
label:
v := @caughtexception;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Exception)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to shut down: \u0001");
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void logError(java.lang.String,java.lang.Throwable)>(v, v);
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.Exception from label to label with label;
}
protected void logError(java.lang.String, java.lang.Throwable)
{
java.io.PrintStream v;
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Throwable;
v = v.<org.apache.activemq.broker.BrokerService: boolean useLoggingForShutdownErrors>;
if v == 0 goto label;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to shut down", v);
goto label;
label:
v = <java.lang.System: java.io.PrintStream err>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Failed to shut down: \u0001");
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>(v);
label:
return;
}
protected void startDestinations() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.ConnectionContext v;
int v, v;
org.apache.activemq.command.ActiveMQDestination[] v, v, v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.ActiveMQDestination[] destinations>;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
v = 0;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.ActiveMQDestination[] destinations>;
v = lengthof v;
if v >= v goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.ActiveMQDestination[] destinations>;
v = v[v];
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 1);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseVirtualTopics()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startVirtualConsumerDestinations()>();
label:
return;
}
public org.apache.activemq.broker.ConnectionContext getAdminConnectionContext() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.ConnectionContext v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = staticinvoke <org.apache.activemq.util.BrokerSupport: org.apache.activemq.broker.ConnectionContext getConnectionContext(org.apache.activemq.broker.Broker)>(v);
return v;
}
protected void startManagementContext() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
javax.management.ObjectName v;
org.apache.activemq.broker.jmx.BrokerView v, v;
org.apache.activemq.broker.jmx.ManagementContext v, v, v;
java.lang.String v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = v.<org.apache.activemq.broker.BrokerService: java.lang.String brokerName>;
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void setBrokerName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: void start()>();
v = new org.apache.activemq.broker.jmx.BrokerView;
specialinvoke v.<org.apache.activemq.broker.jmx.BrokerView: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.broker.jmx.ManagedRegionBroker)>(v, null);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView> = v;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName getBrokerObjectName()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.BrokerView adminView>;
staticinvoke <org.apache.activemq.broker.jmx.AnnotatedMBean: void registerMBean(org.apache.activemq.broker.jmx.ManagementContext,java.lang.Object,javax.management.ObjectName)>(v, v, v);
return;
}
public void startAllConnectors() throws java.lang.Exception
{
java.net.URI v;
boolean v, v, v, v, v, v, v;
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.SynchronousQueue v;
java.util.Set v;
java.util.List v, v, v, v, v, v;
java.util.concurrent.ThreadPoolExecutor v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.ArrayList v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.TransportConnector v;
int v;
java.util.Iterator v, v, v, v, v;
java.util.concurrent.TimeUnit v;
org.apache.activemq.broker.BrokerService$8 v;
java.lang.Object v, v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: java.util.Set getDurableDestinations()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getTransportConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector startTransportConnector(org.apache.activemq.broker.TransportConnector)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 0 goto label;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List transportConnectors>;
interfaceinvoke v.<java.util.List: void clear()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void setTransportConnectors(java.util.List)>(v);
label:
v.<org.apache.activemq.broker.BrokerService: boolean slave> = 0;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopped>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = null;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isNetworkConnectorStartAsync()>();
if v == 0 goto label;
v = new java.util.concurrent.ThreadPoolExecutor;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = new java.util.concurrent.SynchronousQueue;
specialinvoke v.<java.util.concurrent.SynchronousQueue: void <init>()>();
v = new org.apache.activemq.broker.BrokerService$8;
specialinvoke v.<org.apache.activemq.broker.BrokerService$8: void <init>(org.apache.activemq.broker.BrokerService)>(v);
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory)>(0, 2147483647, 10L, v, v, v);
v = v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getNetworkConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.net.URI getVmConnectorURI()>();
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setLocalUri(java.net.URI)>(v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startNetworkConnector(org.apache.activemq.network.NetworkConnector,java.util.Set,java.util.concurrent.ThreadPoolExecutor)>(v, v, v);
goto label;
label:
if v == null goto label;
staticinvoke <org.apache.activemq.util.ThreadPoolUtils: void shutdown(java.util.concurrent.ExecutorService)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.util.List getProxyConnectors()>();
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.proxy.ProxyConnector: void start()>();
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List jmsConnectors>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.network.jms.JmsConnector: void start()>();
goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List services>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.activemq.Service: void start()>();
goto label;
label:
return;
}
public void startNetworkConnector(org.apache.activemq.network.NetworkConnector, java.util.concurrent.ThreadPoolExecutor) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v;
java.util.concurrent.ThreadPoolExecutor v;
org.apache.activemq.network.NetworkConnector v;
java.util.Set v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
v := @parameter: java.util.concurrent.ThreadPoolExecutor;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker getBroker()>();
v = interfaceinvoke v.<org.apache.activemq.broker.Broker: java.util.Set getDurableDestinations()>();
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void startNetworkConnector(org.apache.activemq.network.NetworkConnector,java.util.Set,java.util.concurrent.ThreadPoolExecutor)>(v, v, v);
return;
}
public void startNetworkConnector(org.apache.activemq.network.NetworkConnector, java.util.Set, java.util.concurrent.ThreadPoolExecutor) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.util.concurrent.ThreadPoolExecutor v;
org.apache.activemq.network.NetworkConnector v;
java.util.Set v, v;
javax.management.ObjectName v;
org.apache.activemq.broker.BrokerService$9 v;
org.apache.activemq.broker.jmx.ManagementContext v;
java.lang.String v, v;
javax.management.InstanceNotFoundException v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.network.NetworkConnector;
v := @parameter: java.util.Set;
v := @parameter: java.util.concurrent.ThreadPoolExecutor;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setBrokerName(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.network.NetworkConnector: java.util.Set getDurableDestinations()>();
if v != null goto label;
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setDurableDestinations(java.util.Set)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getDefaultSocketURIString()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void setBrokerURL(java.lang.String)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: javax.management.ObjectName createNetworkConnectorObjectName(org.apache.activemq.network.NetworkConnector)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.jmx.ManagementContext getManagementContext()>();
virtualinvoke v.<org.apache.activemq.broker.jmx.ManagementContext: javax.management.ObjectInstance getObjectInstance(javax.management.ObjectName)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Network connector MBean {} not found, registering", v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void registerNetworkConnectorMBean(org.apache.activemq.network.NetworkConnector)>(v);
label:
if v == null goto label;
v = new org.apache.activemq.broker.BrokerService$9;
specialinvoke v.<org.apache.activemq.broker.BrokerService$9: void <init>(org.apache.activemq.broker.BrokerService,org.apache.activemq.network.NetworkConnector)>(v, v);
virtualinvoke v.<java.util.concurrent.ThreadPoolExecutor: void execute(java.lang.Runnable)>(v);
goto label;
label:
virtualinvoke v.<org.apache.activemq.network.NetworkConnector: void start()>();
label:
return;
catch javax.management.InstanceNotFoundException from label to label with label;
}
public org.apache.activemq.broker.TransportConnector startTransportConnector(org.apache.activemq.broker.TransportConnector) throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.region.ConnectorStatistics v;
org.apache.activemq.broker.TransportConnector v;
org.apache.activemq.thread.TaskRunnerFactory v;
org.apache.activemq.security.MessageAuthorizationPolicy v;
boolean v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.TransportConnector;
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()>();
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void setTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory)>(v);
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.security.MessageAuthorizationPolicy getMessageAuthorizationPolicy()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void setMessageAuthorizationPolicy(org.apache.activemq.security.MessageAuthorizationPolicy)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseJmx()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.TransportConnector registerConnectorMBean(org.apache.activemq.broker.TransportConnector)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.TransportConnector: org.apache.activemq.broker.region.ConnectorStatistics getStatistics()>();
v = v.<org.apache.activemq.broker.BrokerService: boolean enableStatistics>;
virtualinvoke v.<org.apache.activemq.broker.region.ConnectorStatistics: void setEnabled(boolean)>(v);
virtualinvoke v.<org.apache.activemq.broker.TransportConnector: void start()>();
return v;
}
protected void configureServices(java.lang.Object[])
{
org.apache.activemq.broker.BrokerService v;
java.lang.Object[] v;
int v, v;
java.lang.Object v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Object[];
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return;
}
protected void configureService(java.lang.Object)
{
org.apache.activemq.broker.BrokerService v;
java.lang.Object v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.activemq.broker.BrokerServiceAware;
if v == 0 goto label;
interfaceinvoke v.<org.apache.activemq.broker.BrokerServiceAware: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
label:
return;
}
public void handleIOException(java.io.IOException)
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.io.IOException v;
org.apache.activemq.util.IOExceptionHandler v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.io.IOException;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.util.IOExceptionHandler ioExceptionHandler>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.util.IOExceptionHandler ioExceptionHandler>;
interfaceinvoke v.<org.apache.activemq.util.IOExceptionHandler: void handle(java.io.IOException)>(v);
goto label;
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Throwable)>("No IOExceptionHandler registered, ignoring IO exception", v);
label:
return;
}
protected void startVirtualConsumerDestinations() throws java.lang.Exception
{
org.apache.activemq.broker.BrokerService v;
java.util.Iterator v;
java.util.Set v;
org.apache.activemq.filter.DestinationFilter v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.ConnectionContext v;
java.lang.Object v;
org.apache.activemq.broker.region.DestinationFactory v;
boolean v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
specialinvoke v.<org.apache.activemq.broker.BrokerService: void checkStartException()>();
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationFactory destinationFactory>;
v = virtualinvoke v.<org.apache.activemq.broker.region.DestinationFactory: java.util.Set getDestinations()>();
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.filter.DestinationFilter getVirtualTopicConsumerDestinationFilter()>();
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.filter.DestinationFilter: boolean matches(org.apache.activemq.command.ActiveMQDestination)>(v);
if v != 1 goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
interfaceinvoke v.<org.apache.activemq.broker.Broker: org.apache.activemq.broker.region.Destination addDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,boolean)>(v, v, 0);
goto label;
label:
return;
}
private org.apache.activemq.filter.DestinationFilter getVirtualTopicConsumerDestinationFilter()
{
java.lang.Object[] v;
org.apache.activemq.command.ActiveMQQueue v, v;
java.util.HashSet v;
org.apache.activemq.broker.Broker v;
org.apache.activemq.broker.ConnectionContext v;
int v, v, v, v;
org.apache.activemq.broker.region.DestinationInterceptor[] v, v;
java.lang.String v, v;
boolean v, v, v;
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v, v;
org.apache.activemq.broker.region.virtual.VirtualDestination v;
java.lang.Exception v;
org.apache.activemq.broker.region.DestinationInterceptor v;
org.apache.activemq.filter.DestinationFilter v, v, v;
org.apache.activemq.broker.region.virtual.VirtualDestination[] v;
org.apache.activemq.command.ActiveMQDestination[] v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.filter.DestinationFilter virtualConsumerDestinationFilter>;
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors>;
if v == null goto label;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.region.DestinationInterceptor[] destinationInterceptors>;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v instanceof org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor: org.apache.activemq.broker.region.virtual.VirtualDestination[] getVirtualDestinations()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v instanceof org.apache.activemq.broker.region.virtual.VirtualTopic;
if v == 0 goto label;
v = new org.apache.activemq.command.ActiveMQQueue;
v = virtualinvoke v.<org.apache.activemq.broker.region.virtual.VirtualTopic: java.lang.String getPrefix()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001>");
specialinvoke v.<org.apache.activemq.command.ActiveMQQueue: void <init>(java.lang.String)>(v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseVirtualDestSubs()>();
if v == 0 goto label;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker broker>;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.ConnectionContext getAdminConnectionContext()>();
interfaceinvoke v.<org.apache.activemq.broker.Broker: void virtualDestinationAdded(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.broker.region.virtual.VirtualDestination)>(v, v);
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Adding virtual destination: {}", v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Could not fire virtual destination consumer advisory", v);
label:
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = new org.apache.activemq.command.ActiveMQQueue;
specialinvoke v.<org.apache.activemq.command.ActiveMQQueue: void <init>()>();
v = newarray (org.apache.activemq.command.ActiveMQDestination)[0];
v = interfaceinvoke v.<java.util.Set: java.lang.Object[] toArray(java.lang.Object[])>(v);
virtualinvoke v.<org.apache.activemq.command.ActiveMQQueue: void setCompositeDestinations(org.apache.activemq.command.ActiveMQDestination[])>(v);
v = staticinvoke <org.apache.activemq.filter.DestinationFilter: org.apache.activemq.filter.DestinationFilter parseFilter(org.apache.activemq.command.ActiveMQDestination)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.filter.DestinationFilter virtualConsumerDestinationFilter> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.filter.DestinationFilter virtualConsumerDestinationFilter>;
return v;
catch java.lang.Exception from label to label with label;
}
protected synchronized java.util.concurrent.ThreadPoolExecutor getExecutor()
{
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.ThreadPoolExecutor v, v, v;
java.util.concurrent.LinkedBlockingQueue v;
java.util.concurrent.TimeUnit v;
org.apache.activemq.broker.BrokerService$10 v;
org.apache.activemq.broker.BrokerService$11 v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor executor>;
if v != null goto label;
v = new java.util.concurrent.ThreadPoolExecutor;
v = <java.util.concurrent.TimeUnit: java.util.concurrent.TimeUnit SECONDS>;
v = new java.util.concurrent.LinkedBlockingQueue;
specialinvoke v.<java.util.concurrent.LinkedBlockingQueue: void <init>()>();
v = new org.apache.activemq.broker.BrokerService$10;
specialinvoke v.<org.apache.activemq.broker.BrokerService$10: void <init>(org.apache.activemq.broker.BrokerService)>(v);
v = new org.apache.activemq.broker.BrokerService$11;
specialinvoke v.<org.apache.activemq.broker.BrokerService$11: void <init>(org.apache.activemq.broker.BrokerService)>(v);
specialinvoke v.<java.util.concurrent.ThreadPoolExecutor: void <init>(int,int,long,java.util.concurrent.TimeUnit,java.util.concurrent.BlockingQueue,java.util.concurrent.ThreadFactory,java.util.concurrent.RejectedExecutionHandler)>(1, 10, 60L, v, v, v, v);
v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor executor> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.ThreadPoolExecutor executor>;
return v;
}
public synchronized org.apache.activemq.thread.Scheduler getScheduler()
{
org.apache.activemq.broker.BrokerService v;
org.slf4j.Logger v;
java.lang.Exception v;
org.apache.activemq.thread.Scheduler v, v, v, v;
java.lang.String v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler>;
if v != null goto label;
v = new org.apache.activemq.thread.Scheduler;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.lang.String getBrokerName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("ActiveMQ Broker[\u] Scheduler");
specialinvoke v.<org.apache.activemq.thread.Scheduler: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler>;
virtualinvoke v.<org.apache.activemq.thread.Scheduler: void start()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Failed to start Scheduler", v);
label:
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.thread.Scheduler scheduler>;
return v;
catch java.lang.Exception from label to label with label;
}
public org.apache.activemq.broker.Broker getRegionBroker()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker regionBroker>;
return v;
}
public void setRegionBroker(org.apache.activemq.broker.Broker)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.Broker v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.Broker;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.Broker regionBroker> = v;
return;
}
public final void removePreShutdownHook(java.lang.Runnable)
{
org.apache.activemq.broker.BrokerService v;
java.util.List v;
java.lang.Runnable v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List preShutdownHooks>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
return;
}
public void addShutdownHook(java.lang.Runnable)
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
java.util.List v, v;
java.lang.Runnable v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks>;
entermonitor v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void removeShutdownHook(java.lang.Runnable)
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
java.util.List v, v;
java.lang.Runnable v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.Runnable;
v = v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks>;
entermonitor v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.util.List shutdownHooks>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
public boolean isSystemExitOnShutdown()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean systemExitOnShutdown>;
return v;
}
public void setSystemExitOnShutdown(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean systemExitOnShutdown> = v;
return;
}
public int getSystemExitOnShutdownExitCode()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int systemExitOnShutdownExitCode>;
return v;
}
public void setSystemExitOnShutdownExitCode(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int systemExitOnShutdownExitCode> = v;
return;
}
public org.apache.activemq.broker.SslContext getSslContext()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.SslContext v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.SslContext sslContext>;
return v;
}
public void setSslContext(org.apache.activemq.broker.SslContext)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.broker.SslContext v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.SslContext;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.SslContext sslContext> = v;
return;
}
public boolean isShutdownOnSlaveFailure()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean shutdownOnSlaveFailure>;
return v;
}
public void setShutdownOnSlaveFailure(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean shutdownOnSlaveFailure> = v;
return;
}
public boolean isWaitForSlave()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean waitForSlave>;
return v;
}
public void setWaitForSlave(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean waitForSlave> = v;
return;
}
public long getWaitForSlaveTimeout()
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: long waitForSlaveTimeout>;
return v;
}
public void setWaitForSlaveTimeout(long)
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: long;
v.<org.apache.activemq.broker.BrokerService: long waitForSlaveTimeout> = v;
return;
}
public boolean isPassiveSlave()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean passiveSlave>;
return v;
}
public void setPassiveSlave(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean passiveSlave> = v;
return;
}
public void setIoExceptionHandler(org.apache.activemq.util.IOExceptionHandler)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.util.IOExceptionHandler v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.util.IOExceptionHandler;
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void configureService(java.lang.Object)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.util.IOExceptionHandler ioExceptionHandler> = v;
return;
}
public org.apache.activemq.util.IOExceptionHandler getIoExceptionHandler()
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.util.IOExceptionHandler v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.util.IOExceptionHandler ioExceptionHandler>;
return v;
}
public boolean isSchedulerSupport()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean schedulerSupport>;
return v;
}
public void setSchedulerSupport(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean schedulerSupport> = v;
return;
}
public java.io.File getSchedulerDirectoryFile()
{
org.apache.activemq.broker.BrokerService v;
java.io.File v, v, v, v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.io.File schedulerDirectoryFile>;
if v != null goto label;
v = new java.io.File;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: java.io.File getBrokerDataDirectory()>();
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "scheduler");
v.<org.apache.activemq.broker.BrokerService: java.io.File schedulerDirectoryFile> = v;
label:
v = v.<org.apache.activemq.broker.BrokerService: java.io.File schedulerDirectoryFile>;
return v;
}
public void setSchedulerDirectoryFile(java.io.File)
{
org.apache.activemq.broker.BrokerService v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.io.File;
v.<org.apache.activemq.broker.BrokerService: java.io.File schedulerDirectoryFile> = v;
return;
}
public void setSchedulerDirectory(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
java.io.File v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.broker.BrokerService: void setSchedulerDirectoryFile(java.io.File)>(v);
return;
}
public int getSchedulePeriodForDestinationPurge()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDestinationPurge>;
return v;
}
public void setSchedulePeriodForDestinationPurge(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDestinationPurge> = v;
return;
}
public void setSchedulePeriodForDiskUsageCheck(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int schedulePeriodForDiskUsageCheck> = v;
return;
}
public int getDiskUsageCheckRegrowThreshold()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int diskUsageCheckRegrowThreshold>;
return v;
}
public void setDiskUsageCheckRegrowThreshold(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int diskUsageCheckRegrowThreshold> = v;
return;
}
public int getMaxPurgedDestinationsPerSweep()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int maxPurgedDestinationsPerSweep>;
return v;
}
public void setMaxPurgedDestinationsPerSweep(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int maxPurgedDestinationsPerSweep> = v;
return;
}
public org.apache.activemq.broker.BrokerContext getBrokerContext()
{
org.apache.activemq.broker.BrokerContext v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerContext brokerContext>;
return v;
}
public void setBrokerContext(org.apache.activemq.broker.BrokerContext)
{
org.apache.activemq.broker.BrokerContext v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.broker.BrokerContext;
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.broker.BrokerContext brokerContext> = v;
return;
}
public void setBrokerId(java.lang.String)
{
org.apache.activemq.broker.BrokerService v;
java.lang.String v;
org.apache.activemq.command.BrokerId v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: java.lang.String;
v = new org.apache.activemq.command.BrokerId;
specialinvoke v.<org.apache.activemq.command.BrokerId: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.command.BrokerId brokerId> = v;
return;
}
public boolean isUseAuthenticatedPrincipalForJMSXUserID()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useAuthenticatedPrincipalForJMSXUserID>;
return v;
}
public void setUseAuthenticatedPrincipalForJMSXUserID(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useAuthenticatedPrincipalForJMSXUserID> = v;
return;
}
public boolean isPopulateUserNameInMBeans()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean populateUserNameInMBeans>;
return v;
}
public void setPopulateUserNameInMBeans(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean populateUserNameInMBeans> = v;
return;
}
public long getMbeanInvocationTimeout()
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: long mbeanInvocationTimeout>;
return v;
}
public void setMbeanInvocationTimeout(long)
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: long;
v.<org.apache.activemq.broker.BrokerService: long mbeanInvocationTimeout> = v;
return;
}
public boolean isNetworkConnectorStartAsync()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean networkConnectorStartAsync>;
return v;
}
public void setNetworkConnectorStartAsync(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean networkConnectorStartAsync> = v;
return;
}
public boolean isAllowTempAutoCreationOnSend()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean allowTempAutoCreationOnSend>;
return v;
}
public void setAllowTempAutoCreationOnSend(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean allowTempAutoCreationOnSend> = v;
return;
}
public long getOfflineDurableSubscriberTimeout()
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: long offlineDurableSubscriberTimeout>;
return v;
}
public void setOfflineDurableSubscriberTimeout(long)
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: long;
v.<org.apache.activemq.broker.BrokerService: long offlineDurableSubscriberTimeout> = v;
return;
}
public long getOfflineDurableSubscriberTaskSchedule()
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: long offlineDurableSubscriberTaskSchedule>;
return v;
}
public void setOfflineDurableSubscriberTaskSchedule(long)
{
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: long;
v.<org.apache.activemq.broker.BrokerService: long offlineDurableSubscriberTaskSchedule> = v;
return;
}
public boolean shouldRecordVirtualDestination(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.broker.BrokerService v;
boolean v, v, v, v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.filter.DestinationFilter v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = virtualinvoke v.<org.apache.activemq.broker.BrokerService: boolean isUseVirtualTopics()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean isQueue()>();
if v == 0 goto label;
v = specialinvoke v.<org.apache.activemq.broker.BrokerService: org.apache.activemq.filter.DestinationFilter getVirtualTopicConsumerDestinationFilter()>();
v = virtualinvoke v.<org.apache.activemq.filter.DestinationFilter: boolean matches(org.apache.activemq.command.ActiveMQDestination)>(v);
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public synchronized java.lang.Throwable getStartException()
{
java.lang.Throwable v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.lang.Throwable startException>;
return v;
}
public boolean isStartAsync()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean startAsync>;
return v;
}
public void setStartAsync(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean startAsync> = v;
return;
}
public boolean isSlave()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean slave>;
return v;
}
public boolean isStopping()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicBoolean stopping>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
return v;
}
public boolean isRestartAllowed()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean restartAllowed>;
return v;
}
public void setRestartAllowed(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean restartAllowed> = v;
return;
}
public boolean isRestartRequested()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean restartRequested>;
return v;
}
public void requestRestart()
{
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v.<org.apache.activemq.broker.BrokerService: boolean restartRequested> = 1;
return;
}
public int getStoreOpenWireVersion()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int storeOpenWireVersion>;
return v;
}
public void setStoreOpenWireVersion(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int storeOpenWireVersion> = v;
return;
}
public int getCurrentConnections()
{
int v;
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.atomic.AtomicInteger v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicInteger currentConnections>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
public long getTotalConnections()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.broker.BrokerService v;
long v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicLong totalConnections>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
return v;
}
public void incrementCurrentConnections()
{
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.atomic.AtomicInteger v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicInteger currentConnections>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int incrementAndGet()>();
return;
}
public void decrementCurrentConnections()
{
org.apache.activemq.broker.BrokerService v;
java.util.concurrent.atomic.AtomicInteger v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicInteger currentConnections>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int decrementAndGet()>();
return;
}
public void incrementTotalConnections()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: java.util.concurrent.atomic.AtomicLong totalConnections>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
return;
}
public boolean isRejectDurableConsumers()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean rejectDurableConsumers>;
return v;
}
public void setRejectDurableConsumers(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean rejectDurableConsumers> = v;
return;
}
public boolean isUseVirtualDestSubs()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useVirtualDestSubs>;
return v;
}
public void setUseVirtualDestSubs(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useVirtualDestSubs> = v;
return;
}
public boolean isUseVirtualDestSubsOnCreation()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean useVirtualDestSubsOnCreation>;
return v;
}
public void setUseVirtualDestSubsOnCreation(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean useVirtualDestSubsOnCreation> = v;
return;
}
public boolean isAdjustUsageLimits()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean adjustUsageLimits>;
return v;
}
public void setAdjustUsageLimits(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean adjustUsageLimits> = v;
return;
}
public void setRollbackOnlyOnAsyncException(boolean)
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: boolean;
v.<org.apache.activemq.broker.BrokerService: boolean rollbackOnlyOnAsyncException> = v;
return;
}
public boolean isRollbackOnlyOnAsyncException()
{
org.apache.activemq.broker.BrokerService v;
boolean v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: boolean rollbackOnlyOnAsyncException>;
return v;
}
public int getMaxSchedulerRepeatAllowed()
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v = v.<org.apache.activemq.broker.BrokerService: int maxSchedulerRepeatAllowed>;
return v;
}
public void setMaxSchedulerRepeatAllowed(int)
{
int v;
org.apache.activemq.broker.BrokerService v;
v := @this: org.apache.activemq.broker.BrokerService;
v := @parameter: int;
v.<org.apache.activemq.broker.BrokerService: int maxSchedulerRepeatAllowed> = v;
return;
}
static void <clinit>()
{
java.lang.Throwable v, v, v, v;
java.lang.Integer v, v;
int v, v;
java.lang.String v, v;
org.slf4j.Logger v, v, v, v;
java.io.IOException v;
java.io.InputStreamReader v;
java.net.UnknownHostException v;
java.lang.Class v, v, v;
java.lang.Object v;
java.io.BufferedReader v;
java.lang.ClassLoader v;
java.io.InputStream v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/broker/BrokerService;");
<org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG> = v;
label:
v = class "Lorg/apache/activemq/broker/BrokerService;";
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
v = virtualinvoke v.<java.lang.ClassLoader: java.lang.Class loadClass(java.lang.String)>("org.bouncycastle.jce.provider.BouncyCastleProvider");
v = virtualinvoke v.<java.lang.Class: java.lang.Object newInstance()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer getInteger(java.lang.String)>("org.apache.activemq.broker.BouncyCastlePosition");
if v == null goto label;
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = staticinvoke <java.security.Security: int insertProviderAt(java.security.Provider,int)>(v, v);
goto label;
label:
v = staticinvoke <java.security.Security: int addProvider(java.security.Provider)>(v);
label:
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("Loaded the Bouncy Castle security provider at position: {}", v);
label:
goto label;
label:
v := @caughtexception;
label:
v = "localhost";
label:
v = staticinvoke <org.apache.activemq.util.InetAddressUtil: java.lang.String getLocalHostName()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Failed to resolve localhost");
label:
<org.apache.activemq.broker.BrokerService: java.lang.String LOCAL_HOST_NAME> = v;
v = null;
label:
v = class "Lorg/apache/activemq/broker/BrokerService;";
v = virtualinvoke v.<java.lang.Class: java.io.InputStream getResourceAsStream(java.lang.String)>("/org/apache/activemq/version.txt");
label:
if v == null goto label;
v = new java.io.InputStreamReader;
specialinvoke v.<java.io.InputStreamReader: void <init>(java.io.InputStream)>(v);
label:
v = new java.io.BufferedReader;
specialinvoke v.<java.io.BufferedReader: void <init>(java.io.Reader)>(v);
label:
v = virtualinvoke v.<java.io.BufferedReader: java.lang.String readLine()>();
label:
virtualinvoke v.<java.io.BufferedReader: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
virtualinvoke v.<java.io.InputStreamReader: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.BrokerService: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Error reading broker version", v);
label:
<org.apache.activemq.broker.BrokerService: java.lang.String BROKER_VERSION> = v;
return;
catch java.lang.Throwable from label to label with label;
catch java.net.UnknownHostException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.io.IOException from label to label with label;
}
}