public abstract class org.apache.activemq.network.DemandForwardingBridgeSupport extends java.lang.Object implements org.apache.activemq.network.NetworkBridge, org.apache.activemq.broker.BrokerServiceAware { private static final org.slf4j.Logger LOG; protected static final java.lang.String DURABLE_SUB_PREFIX; protected final org.apache.activemq.transport.Transport localBroker; protected final org.apache.activemq.transport.Transport remoteBroker; protected org.apache.activemq.util.IdGenerator idGenerator; protected final org.apache.activemq.util.LongSequenceGenerator consumerIdGenerator; protected org.apache.activemq.command.ConnectionInfo localConnectionInfo; protected org.apache.activemq.command.ConnectionInfo remoteConnectionInfo; protected org.apache.activemq.command.SessionInfo localSessionInfo; protected org.apache.activemq.command.ProducerInfo producerInfo; protected java.lang.String remoteBrokerName; protected java.lang.String localClientId; protected org.apache.activemq.command.ConsumerInfo demandConsumerInfo; protected int demandConsumerDispatched; protected final java.util.concurrent.atomic.AtomicBoolean localBridgeStarted; protected final java.util.concurrent.atomic.AtomicBoolean remoteBridgeStarted; protected final java.util.concurrent.atomic.AtomicBoolean bridgeFailed; protected final java.util.concurrent.atomic.AtomicBoolean disposed; protected org.apache.activemq.command.BrokerId localBrokerId; protected org.apache.activemq.command.ActiveMQDestination[] excludedDestinations; protected org.apache.activemq.command.ActiveMQDestination[] dynamicallyIncludedDestinations; protected org.apache.activemq.command.ActiveMQDestination[] staticallyIncludedDestinations; protected org.apache.activemq.command.ActiveMQDestination[] durableDestinations; protected final java.util.concurrent.ConcurrentMap subscriptionMapByLocalId; protected final java.util.concurrent.ConcurrentMap subscriptionMapByRemoteId; protected final java.util.Set forcedDurableRemoteId; protected final org.apache.activemq.command.BrokerId[] localBrokerPath; protected final java.util.concurrent.CountDownLatch startedLatch; protected final java.util.concurrent.CountDownLatch localStartedLatch; protected final java.util.concurrent.CountDownLatch staticDestinationsLatch; protected final java.util.concurrent.atomic.AtomicBoolean lastConnectSucceeded; protected org.apache.activemq.network.NetworkBridgeConfiguration configuration; protected final org.apache.activemq.network.NetworkBridgeFilterFactory defaultFilterFactory; protected final org.apache.activemq.command.BrokerId[] remoteBrokerPath; protected org.apache.activemq.command.BrokerId remoteBrokerId; protected final org.apache.activemq.network.NetworkBridgeStatistics networkBridgeStatistics; private org.apache.activemq.network.NetworkBridgeListener networkBridgeListener; private boolean createdByDuplex; private org.apache.activemq.command.BrokerInfo localBrokerInfo; private org.apache.activemq.command.BrokerInfo remoteBrokerInfo; private final org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo futureRemoteBrokerInfo; private final org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo futureLocalBrokerInfo; private final java.util.concurrent.atomic.AtomicBoolean started; private org.apache.activemq.broker.TransportConnection duplexInitiatingConnection; private final java.util.concurrent.atomic.AtomicBoolean duplexInitiatingConnectionInfoReceived; protected org.apache.activemq.broker.BrokerService brokerService; private javax.management.ObjectName mbeanObjectName; private final java.util.concurrent.ExecutorService serialExecutor; private final java.util.concurrent.ExecutorService syncExecutor; private org.apache.activemq.transport.Transport duplexInboundLocalBroker; private org.apache.activemq.command.ProducerInfo duplexInboundLocalProducerInfo; public void (org.apache.activemq.network.NetworkBridgeConfiguration, org.apache.activemq.transport.Transport, org.apache.activemq.transport.Transport) { org.apache.activemq.network.DefaultNetworkBridgeFilterFactory v; org.apache.activemq.network.NetworkBridgeStatistics v; java.util.concurrent.ConcurrentHashMap v, v, v; java.util.Set v; org.apache.activemq.transport.Transport v, v; java.util.concurrent.CountDownLatch v, v, v; org.apache.activemq.util.LongSequenceGenerator v; java.util.concurrent.atomic.AtomicBoolean v, v, v, v, v, v, v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerInfo v, v; java.util.concurrent.ExecutorService v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.apache.activemq.command.BrokerId[] v, v; org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo v, v; org.apache.activemq.util.IdGenerator v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.NetworkBridgeConfiguration; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: org.apache.activemq.transport.Transport; specialinvoke v.()>(); v = new org.apache.activemq.util.IdGenerator; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.util.LongSequenceGenerator; specialinvoke v.()>(); v. = v; v. = "Unknown"; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v = staticinvoke (v); v. = v; v = newarray (org.apache.activemq.command.BrokerId)[1]; v[0] = null; v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(2); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new org.apache.activemq.network.DefaultNetworkBridgeFilterFactory; specialinvoke v.()>(); v. = v; v = newarray (org.apache.activemq.command.BrokerId)[1]; v[0] = null; v. = v; v = new org.apache.activemq.network.NetworkBridgeStatistics; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo; v = v.; v = v.; specialinvoke v.(org.apache.activemq.command.BrokerInfo,java.util.concurrent.atomic.AtomicBoolean)>(v, v); v. = v; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo; v = v.; v = v.; specialinvoke v.(org.apache.activemq.command.BrokerInfo,java.util.concurrent.atomic.AtomicBoolean)>(v, v); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v. = null; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v. = null; v. = v; v. = v; v. = v; return; } public void duplexStart(org.apache.activemq.broker.TransportConnection, org.apache.activemq.command.BrokerInfo, org.apache.activemq.command.BrokerInfo) throws java.lang.Exception { org.apache.activemq.broker.TransportConnection v; org.apache.activemq.command.BrokerInfo v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.broker.TransportConnection; v := @parameter: org.apache.activemq.command.BrokerInfo; v := @parameter: org.apache.activemq.command.BrokerInfo; v. = v; v. = v; v. = v; virtualinvoke v.(); virtualinvoke v.(v); return; } public void start() throws java.lang.Exception { org.apache.activemq.network.DemandForwardingBridgeSupport$3 v; org.apache.activemq.network.DemandForwardingBridgeSupport$2 v; org.apache.activemq.network.DemandForwardingBridgeSupport$1 v; java.util.concurrent.atomic.AtomicBoolean v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.broker.Broker v; java.lang.String v; java.net.URI v; boolean v, v, v, v; org.apache.activemq.broker.BrokerService v, v, v; org.apache.activemq.network.NetworkBridgeStatistics v; org.slf4j.Logger v, v; java.io.IOException v; org.apache.activemq.transport.Transport v, v, v, v, v, v, v; java.lang.IllegalArgumentException v; org.apache.activemq.transport.TransportDisposedIOException v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = v.; if v != null goto label; v = new java.lang.IllegalArgumentException; v = dynamicinvoke "makeConcatWithConstants" (v) ("BrokerService is null on \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); v. = v; v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$1; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); label: v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$2; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v); interfaceinvoke v.(v); v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$3; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v); interfaceinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Caught exception from remote start", v); goto label; label: v = ; interfaceinvoke v.("Bridge was disposed before the start() method was fully executed."); v = new org.apache.activemq.transport.TransportDisposedIOException; specialinvoke v.()>(); throw v; label: return; catch java.io.IOException from label to label with label; } public void stop() throws java.lang.Exception { org.apache.activemq.util.ServiceStopper v, v; byte v; boolean v, v, v; org.apache.activemq.broker.BrokerService v, v, v; org.apache.activemq.transport.Transport v, v, v, v, v, v, v, v; java.util.concurrent.CountDownLatch v, v, v, v, v, v, v, v, v, v; org.apache.activemq.thread.TaskRunnerFactory v; java.lang.Throwable v; java.lang.Object[] v; java.util.concurrent.atomic.AtomicBoolean v, v, v; long v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.network.NetworkBridgeListener v; org.apache.activemq.command.BrokerInfo v, v; java.lang.String v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v; org.slf4j.Logger v, v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo v, v; java.util.concurrent.TimeUnit v; org.apache.activemq.network.DemandForwardingBridgeSupport$4 v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(1, 0); if v == 0 goto label; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(" stopping {} bridge to {}", v, v); v = v.; virtualinvoke v.(1); v = v.; virtualinvoke v.(1); v = v.; if v == null goto label; interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v cmp 2L; if v >= 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("{} unregister bridge ({}) to {}", v); v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(null, v); v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(0); v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.network.DemandForwardingBridgeSupport$4; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,java.util.concurrent.CountDownLatch)>(v, v); virtualinvoke v.(v, "ActiveMQ ForwardingBridge StopTask"); v = ; v = virtualinvoke v.(10L, v); if v != 0 goto label; v = ; interfaceinvoke v.("Network Could not shutdown in a timely manner"); label: v = new org.apache.activemq.util.ServiceStopper; specialinvoke v.()>(); v = v.; specialinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = new org.apache.activemq.util.ServiceStopper; specialinvoke v.()>(); v = v.; specialinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = ; v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("{} bridge to {} stopped", v, v); label: return; catch java.lang.Throwable from label to label with label; } private void stopFailoverTransport(org.apache.activemq.transport.Transport) { java.lang.InterruptedException v; java.io.IOException v; java.lang.Object v; org.apache.activemq.transport.Transport v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.transport.Transport; v = interfaceinvoke v.(class "Lorg/apache/activemq/transport/failover/FailoverTransport;"); if v == null goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Bridge stopped"); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; label: return; catch java.lang.InterruptedException from label to label with label; } protected void triggerStartAsyncNetworkBridgeCreation() throws java.io.IOException { org.apache.activemq.broker.BrokerService v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.network.DemandForwardingBridgeSupport$5 v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.network.DemandForwardingBridgeSupport$5; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v); virtualinvoke v.(v); return; } private void collectBrokerInfos() { boolean v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.transport.Transport v, v, v; java.lang.Exception v; java.lang.Throwable v, v, v; java.lang.Object[] v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerInfo v, v, v, v, v, v; int v; java.lang.String v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v; org.slf4j.Logger v; org.apache.activemq.command.BrokerId[] v; org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo v, v; java.util.concurrent.TimeUnit v, v; org.apache.activemq.command.BrokerId v, v, v, v, v; java.lang.Object v; org.apache.activemq.util.IdGenerator v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = 30000; v = v.; v = interfaceinvoke v.(class "Lorg/apache/activemq/transport/tcp/TcpTransport;"); if v == null goto label; v = virtualinvoke v.(); label: v = v.; v = ; v = virtualinvoke v.(v, v); v. = v; v = v.; if v != null goto label; v = new java.lang.Throwable; specialinvoke v.(java.lang.String)>("remoteBrokerInfo is null"); virtualinvoke v.(v); label: return; label: v := @caughtexception; virtualinvoke v.(v); return; label: v = v.; v = ; v = virtualinvoke v.(v, v); v. = v; v = v.; if v != null goto label; v = new java.lang.Throwable; specialinvoke v.(java.lang.String)>("localBrokerInfo is null"); virtualinvoke v.(v); label: return; label: v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("{} disconnecting remote loop back connector for: {}, with id: {}", v); v = v.; staticinvoke (v); v = v.; staticinvoke (v); label: return; label: v = v.; v = v.; v[0] = v; v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.util.IdGenerator; v = v.; v = virtualinvoke v.(); v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001->\u0001"); specialinvoke v.(java.lang.String)>(v); v. = v; label: goto label; label: v := @caughtexception; virtualinvoke v.(v); label: return; catch java.lang.Exception 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; } private void doStartLocalAndRemoteBridges() { boolean v, v, v; java.util.concurrent.CountDownLatch v; java.util.List v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination[] v, v, v; java.lang.Throwable v, v, v, v; java.lang.Object[] v, v, v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerInfo v; int v, v, v; java.lang.String v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v, v, v, v, v, v, v, v; java.util.Properties v; org.slf4j.Logger v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); if v == 0 goto label; return; label: v = virtualinvoke v.(); if v == 0 goto label; v = null; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; staticinvoke (v, v, null); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = newarray (org.apache.activemq.command.ActiveMQDestination)[v]; v = interfaceinvoke v.(v); v. = v; label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = newarray (org.apache.activemq.command.ActiveMQDestination)[v]; v = interfaceinvoke v.(v); v. = v; label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = newarray (org.apache.activemq.command.ActiveMQDestination)[v]; v = interfaceinvoke v.(v); v. = v; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error mapping remote configuration: {}", v, v); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; virtualinvoke v.(v); return; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; virtualinvoke v.(v); return; label: v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; virtualinvoke v.(v); label: 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; } private void startLocalBridge() throws java.lang.Throwable { org.apache.activemq.broker.BrokerService v, v; java.util.concurrent.CountDownLatch v, v; java.lang.Throwable v, v, v; java.lang.Object[] v, v; org.apache.activemq.broker.Broker v, v; org.apache.activemq.command.ConnectionInfo v, v, v, v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeListener v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.IllegalStateException v; org.apache.activemq.command.SessionInfo v, v, v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.activemq.transport.Transport v, v, v, v, v, v, v, v, v, v, v, v; java.security.cert.X509Certificate[] v, v; java.util.concurrent.atomic.AtomicBoolean v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerInfo v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.activemq.command.ConnectionId v, v; org.apache.activemq.command.ProducerInfo v, v; java.lang.Object v, v; org.apache.activemq.util.IdGenerator v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; entermonitor v; label: v = ; v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("{} starting local Bridge, localBroker={}", v, v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v != null goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Id Generator cannot be null"); throw v; label: v = new org.apache.activemq.command.ConnectionInfo; specialinvoke v.()>(); v. = v; v = v.; v = new org.apache.activemq.command.ConnectionId; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v) ("\u0001\u0001\u0001\u0001inbound\u0001\u0001"); v. = v; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; label: v = v instanceof org.apache.activemq.transport.TransportFilter; if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = v instanceof org.apache.activemq.transport.tcp.TcpTransport; if v == 0 goto label; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v); label: v = v.; v = v.; v = interfaceinvoke v.(v); v = v instanceof org.apache.activemq.command.ExceptionResponse; if v == 0 goto label; v = virtualinvoke v.(); throw v; label: v = new org.apache.activemq.command.SessionInfo; v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionInfo,long)>(v, 1L); v. = v; v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(1); v = v.; v = v.; interfaceinvoke v.(v); v = new org.apache.activemq.command.ConnectionInfo; specialinvoke v.()>(); v = new org.apache.activemq.command.ConnectionId; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v, v) ("\u0001\u0001\u0001\u0001inbound\u0001duplex\u0001\u0001"); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v instanceof org.apache.activemq.transport.tcp.TcpTransport; if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); v = v instanceof org.apache.activemq.command.ExceptionResponse; if v == 0 goto label; v = virtualinvoke v.(); throw v; label: v = new org.apache.activemq.command.SessionInfo; specialinvoke v.(org.apache.activemq.command.ConnectionInfo,long)>(v, 1L); v = new org.apache.activemq.command.ProducerInfo; specialinvoke v.(org.apache.activemq.command.SessionInfo,long)>(v, 1L); v. = v; v = v.; interfaceinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v.; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v, v); v = v.; if v == null goto label; interfaceinvoke v.(v); label: v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.(null, v); v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = v.; v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("Network connection between {} and {} ({}) has been established.", v); v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = v.; v[2] = v; interfaceinvoke v.("{} register bridge ({}) to {}", v); goto label; label: v = ; interfaceinvoke v.("Bridge was disposed before the startLocalBridge() method was fully executed."); label: v = v.; virtualinvoke v.(); v = v.; virtualinvoke 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; } protected void startRemoteBridge() throws java.lang.Exception { org.apache.activemq.broker.BrokerService v; java.util.concurrent.CountDownLatch v; java.lang.Throwable v; org.apache.activemq.command.RemoveInfo v; org.apache.activemq.command.ConnectionInfo v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v; java.util.Properties v; org.apache.activemq.command.BrokerSubscriptionInfo v; org.apache.activemq.command.SessionInfo v; boolean v, v, v, v, v, v, v, v, v; org.apache.activemq.wireformat.WireFormat v; org.apache.activemq.transport.Transport v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ActiveMQTopic v, v; java.util.List v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerInfo v; int v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.ProducerInfo v, v, v; org.apache.activemq.command.BrokerId v; org.apache.activemq.util.IdGenerator v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("{} starting remote Bridge, remoteBroker={}", v, v); entermonitor v; label: v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.activemq.command.BrokerInfo; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.util.Properties; specialinvoke v.()>(); v = v.; staticinvoke (v, v, null); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, 1); virtualinvoke v.("dynamicallyIncludedDestinations", v); label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, 1); virtualinvoke v.("staticallyIncludedDestinations", v); label: virtualinvoke v.("networkTTL"); v = staticinvoke (v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v < 12 goto label; v = v.; v = v.; v = v.; v = staticinvoke (v, v); interfaceinvoke v.(v); label: v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = new org.apache.activemq.command.ConnectionInfo; specialinvoke v.()>(); v. = v; v = v.; v = new org.apache.activemq.command.ConnectionId; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("\u0001\u0001\u0001\u0001outbound"); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = v.; interfaceinvoke v.(v); v = new org.apache.activemq.command.SessionInfo; v = v.; specialinvoke v.(org.apache.activemq.command.ConnectionInfo,long)>(v, 1L); v = v.; interfaceinvoke v.(v); v = new org.apache.activemq.command.ProducerInfo; specialinvoke v.(org.apache.activemq.command.SessionInfo,long)>(v, 1L); v. = v; v = v.; virtualinvoke v.(0); v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.activemq.command.ConsumerInfo; specialinvoke v.(org.apache.activemq.command.SessionInfo,long)>(v, 1L); v. = v; v = v.; virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u,\u0001"); label: v = v.; v = new org.apache.activemq.command.ActiveMQTopic; specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = v.; interfaceinvoke v.(v); label: v = v.; virtualinvoke 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 serviceRemoteException(java.lang.Throwable) { java.lang.Throwable v; java.lang.Object[] v, v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.lang.String v, v; boolean v, v, v; org.apache.activemq.broker.BrokerService v; org.slf4j.Logger v, v, v; org.apache.activemq.transport.Transport v, v, v, v; org.apache.activemq.thread.TaskRunnerFactory v; org.apache.activemq.network.DemandForwardingBridgeSupport$6 v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.lang.Throwable; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v instanceof java.lang.SecurityException; if v != 0 goto label; v = v instanceof java.security.GeneralSecurityException; if v == 0 goto label; label: v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Network connection between {} and {} shutdown due to a remote error: {}", v); goto label; label: v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Network connection between {} and {} shutdown due to a remote error: {}", v); label: v = ; interfaceinvoke v.("The remote Exception was: {}", v, v); v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.network.DemandForwardingBridgeSupport$6; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v); virtualinvoke v.(v); specialinvoke v.(v); label: return; } protected boolean isDirectBridgeConsumer(org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.network.DemandForwardingBridgeSupport v; java.lang.String v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.("NC-DS_"); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } protected boolean isProxyBridgeSubscription(java.lang.String, java.lang.String) { java.lang.String v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; boolean v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.lang.String; v := @parameter: java.lang.String; if v == null goto label; if v == null goto label; v = virtualinvoke v.("NC-DS_"); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; return 1; label: return 0; } protected void addProxyNetworkSubscriptionClientId(org.apache.activemq.network.DemandSubscription, java.lang.String, java.lang.String) { org.apache.activemq.command.SubscriptionInfo v; org.slf4j.Logger v, v; java.util.Set v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.lang.String v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; v := @parameter: java.lang.String; v := @parameter: java.lang.String; if v == null goto label; if v == null goto label; if v == null goto label; v = specialinvoke v.(v); v = new org.apache.activemq.command.SubscriptionInfo; specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); v = ; interfaceinvoke v.("Adding proxy network subscription {} to demand subscription", v); goto label; label: v = ; interfaceinvoke v.("Skipping addProxyNetworkSubscription"); label: return; } protected void addProxyNetworkSubscriptionBrokerPath(org.apache.activemq.network.DemandSubscription, org.apache.activemq.command.BrokerId[], java.lang.String) { org.apache.activemq.network.DemandForwardingBridgeSupport v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v; org.apache.activemq.command.SubscriptionInfo v; org.apache.activemq.command.BrokerId[] v; java.util.Set v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.command.BrokerId v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; v := @parameter: org.apache.activemq.command.BrokerId[]; v := @parameter: java.lang.String; if v == null goto label; v = lengthof v; if v <= 1 goto label; if v == null goto label; v = lengthof v; v = v - 1; v = v[v]; v = virtualinvoke v.(); v = lengthof v; v = v - 2; v = v[v]; v = virtualinvoke v.(); v = new org.apache.activemq.command.SubscriptionInfo; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("\u0001\u0001inbound\u0001\u0001"); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; } private java.lang.String getProxyBridgeClientId(java.lang.String) { java.lang.String[] v; org.apache.activemq.network.DemandForwardingBridgeSupport v; int v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.lang.String; v = v; if v == null goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); goto label; label: v = null; label: if v == null goto label; v = lengthof v; if v <= 2 goto label; v = lengthof v; v = v - 3; v = v[v]; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = lengthof v; v = v - 1; v = v[v]; v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v) ("\u0001\u0001inbound\u0001\u0001"); label: return v; } protected boolean isProxyNSConsumerBrokerPath(org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.command.BrokerId[] v, v; int v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = lengthof v; if v <= 1 goto label; v = 1; goto label; label: v = 0; label: return v; } protected boolean isProxyNSConsumerClientId(java.lang.String) { java.lang.String[] v; org.apache.activemq.network.DemandForwardingBridgeSupport v; int v; java.lang.String v, v, v; boolean v; org.apache.activemq.network.NetworkBridgeConfiguration v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.lang.String; if v == null goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); v = lengthof v; if v <= 3 goto label; v = 1; goto label; label: v = 0; label: return v; } protected void serviceRemoteCommand(org.apache.activemq.command.Command) { org.apache.activemq.command.ConsumerId v, v; org.apache.activemq.command.Message v, v; byte v, v, v; org.apache.activemq.broker.BrokerService v; java.util.concurrent.CountDownLatch v; org.apache.activemq.command.DataStructure v, v; java.lang.Throwable v, v, v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v; java.io.IOException v; org.apache.activemq.command.ProducerId v; org.apache.activemq.network.DemandForwardingBridgeSupport$7 v; org.apache.activemq.network.DemandForwardingBridgeSupport$8 v; org.apache.activemq.management.CountStatisticImpl v; java.net.URI v; java.lang.Byte v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeStatistics v; org.apache.activemq.broker.TransportConnection v, v; org.apache.activemq.transport.Transport v, v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.Response v; java.util.concurrent.atomic.AtomicBoolean v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.util.concurrent.ConcurrentMap v; int v; java.util.concurrent.ExecutorService v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v; org.slf4j.Logger v, v, v, v, v, v, v; org.apache.activemq.command.Command v; org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo v; org.apache.activemq.command.ProducerInfo v; java.lang.Class v; java.lang.Object v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.Command; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = v instanceof org.apache.activemq.command.BrokerSubscriptionInfo; if v == 0 goto label; v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$7; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,org.apache.activemq.command.BrokerSubscriptionInfo)>(v, v); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/command/ConnectionError;" goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("{} duplex command type: {}", v, v); v = interfaceinvoke v.(); if v == 0 goto label; v = staticinvoke (v); if v == 0 goto label; v = virtualinvoke v.(); specialinvoke v.(v); specialinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v, 1); if v != 0 goto label; label: return; label: virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$8; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,org.apache.activemq.command.ActiveMQMessage)>(v, v); interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = new org.apache.activemq.command.Response; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); tableswitch(v) { case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; case 7: goto label; case 8: goto label; case 9: goto label; case 10: goto label; case 11: goto label; case 12: goto label; case 13: goto label; case 14: goto label; case 15: goto label; case 16: goto label; case 17: goto label; case 18: goto label; case 19: goto label; case 20: goto label; case 21: goto label; case 22: goto label; default: goto label; }; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("Matching local subscription not found for ack: {}", v); goto label; label: v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); entermonitor v; label: virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; interfaceinvoke v.("Stopping - ignoring ConsumerInfo: {}", v); goto label; label: v = ; interfaceinvoke v.("Stopping network bridge on shutdown of remote broker"); v = new java.io.IOException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); virtualinvoke v.(v); goto label; label: v = ; interfaceinvoke v.("Ignoring remote command: {}", v); goto label; label: v = interfaceinvoke v.(); lookupswitch(v) { case 1: goto label; case 10: goto label; case 11: goto label; default: goto label; }; label: v = ; interfaceinvoke v.("Unexpected remote command: {}", v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Exception processing remote command: {}", v, v); virtualinvoke v.(v); label: 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; } private void ackAdvisory(org.apache.activemq.command.Message) throws java.io.IOException { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.Message v; byte v; int v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.MessageAck v; org.apache.activemq.thread.TaskRunnerFactory v; float v, v; org.apache.activemq.network.DemandForwardingBridgeSupport$9 v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.Message; v = v.; v = v + 1; v. = v; v = v.; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v / 100.0F; v = v * v; v = v cmpl v; if v <= 0 goto label; v = new org.apache.activemq.command.MessageAck; v = v.; specialinvoke v.(org.apache.activemq.command.Message,byte,int)>(v, 2, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.network.DemandForwardingBridgeSupport$9; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,org.apache.activemq.command.MessageAck)>(v, v); virtualinvoke v.(v); v. = 0; label: return; } private void serviceRemoteConsumerAdvisory(org.apache.activemq.command.DataStructure) throws java.io.IOException { java.lang.Integer v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.SessionId v; java.util.Set v, v, v, v; org.apache.activemq.command.DataStructure v, v; java.lang.Throwable v; java.lang.Object[] v, v, v, v, v; org.apache.activemq.command.ConnectionInfo v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.SubscriptionInfo v; org.apache.activemq.command.BrokerId[] v, v, v, v, v, v, v, v; org.apache.activemq.command.SessionInfo v; java.net.URI v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Collection v, v; org.apache.activemq.transport.Transport v, v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport$10 v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.util.concurrent.ConcurrentMap v, v; int v, v, v, v, v; java.util.concurrent.ExecutorService v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v; java.util.Iterator v, v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.BrokerId v, v; java.lang.Class v, v, v, v; java.lang.Object v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.DataStructure; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/command/ConsumerInfo;" goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = v.; interfaceinvoke v.("{} Ignoring sub from {}, browsers explicitly suppressed", v, v); return; label: if v == null goto label; v = (int) -1; if v <= v goto label; v = lengthof v; if v < v goto label; v = ; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = staticinvoke (v); v[2] = v; v[3] = v; interfaceinvoke v.("{} Ignoring sub from {}, restricted to {} network hops only: {}", v); return; label: v = v.; v = v[0]; v = staticinvoke (v, v); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v[2] = v; interfaceinvoke v.("{} Ignoring sub from {}, already routed through this broker once: {}", v); return; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v[2] = v; v[3] = v; interfaceinvoke v.("{} Ignoring sub from {}, destination {} is not permitted: {}", v); return; label: v = specialinvoke v.(v); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); entermonitor v; label: virtualinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/command/DestinationInfo;" goto label; v = virtualinvoke v.(); if v == null goto label; v = (int) -1; if v <= v goto label; v = lengthof v; if v < v goto label; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("{} Ignoring destination {} restricted to {} network hops only", v); return; label: v = virtualinvoke v.(); v = v.; v = v[0]; v = staticinvoke (v, v); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} Ignoring destination {} already routed through this broker once", v, v); return; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = v instanceof org.apache.activemq.command.ActiveMQTempDestination; if v == 0 goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); virtualinvoke v.(v); v = ; v = newarray (java.lang.Object)[5]; v = v.; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); if v == 0 goto label; v = "add"; goto label; label: v = "remove"; label: v[1] = v; v = v.; v[2] = v; v = v.; v[3] = v; v[4] = v; interfaceinvoke v.("{} bridging {} destination on {} from {}, destination: {}", v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$10; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,org.apache.activemq.command.DestinationInfo)>(v, v); interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/command/RemoveInfo;" goto label; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(v, v); goto label; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/command/RemoveSubscriptionInfo;" goto label; v = new org.apache.activemq.command.SubscriptionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v != 0 goto label; if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); v = 1; label: if v == 0 goto label; specialinvoke v.(v, v); goto label; label: return; catch java.lang.Throwable from label to label with label; } private void cleanupDurableSub(org.apache.activemq.network.DemandSubscription, java.util.Iterator) throws java.io.IOException { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v, v; org.apache.activemq.command.RemoveInfo v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.command.ConnectionInfo v; int v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v, v; boolean v; org.apache.activemq.command.SubscriptionInfo v, v; org.apache.activemq.command.RemoveSubscriptionInfo v; java.util.Iterator v; org.apache.activemq.command.ConnectionId v; java.util.Set v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.transport.Transport v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; v := @parameter: java.util.Iterator; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new org.apache.activemq.command.RemoveInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.DataStructure)>(v); v = v.; interfaceinvoke v.(v); v = new org.apache.activemq.command.RemoveSubscriptionInfo; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; } public void serviceLocalException(java.lang.Throwable) { java.lang.Throwable v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.lang.Throwable; virtualinvoke v.(null, v); return; } public void serviceLocalException(org.apache.activemq.command.MessageDispatch, java.lang.Throwable) { java.lang.Throwable v; java.lang.Object[] v; java.util.concurrent.atomic.AtomicBoolean v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; java.lang.Boolean v; boolean v, v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.command.MessageAck v; org.slf4j.Logger v, v, v, v, v, v; org.apache.activemq.command.MessageId v; java.io.IOException v; org.apache.activemq.transport.Transport v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport$11 v; org.apache.activemq.thread.TaskRunnerFactory v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.MessageDispatch; v := @parameter: java.lang.Throwable; v = ; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("serviceLocalException: disposed {} ex", v, v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v instanceof org.apache.activemq.DestinationDoesNotExistException; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; if v == null goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("PoisonAck of {} on forwarding error: {}", v, v); label: v = new org.apache.activemq.command.MessageAck; specialinvoke v.(org.apache.activemq.command.MessageDispatch,byte,int)>(v, 1, 1); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to poison ack message following forward failure: ", v); label: specialinvoke v.(v, v); goto label; label: v = ; interfaceinvoke v.("Ignoring exception on forwarding to non existent temp dest: ", v); label: return; label: v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; v = v.; v[1] = v; v[2] = v; interfaceinvoke v.("Network connection between {} and {} shutdown due to a local error: {}", v); v = ; interfaceinvoke v.("The local Exception was: {}", v, v); v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.network.DemandForwardingBridgeSupport$11; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v); virtualinvoke v.(v); specialinvoke v.(v); label: return; catch java.io.IOException from label to label with label; } private void fireFailedForwardAdvisory(org.apache.activemq.command.MessageDispatch, java.lang.Throwable) { java.lang.Throwable v; org.apache.activemq.security.SecurityContext v; org.apache.activemq.command.ActiveMQMessage v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.broker.Broker v, v, v; org.apache.activemq.broker.ConnectionContext v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; java.lang.String v; boolean v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.apache.activemq.broker.BrokerService v, v; org.slf4j.Logger v, v; java.lang.Exception v; org.apache.activemq.command.ActiveMQTopic v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.MessageDispatch; v := @parameter: java.lang.Throwable; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(class "Lorg/apache/activemq/advisory/AdvisoryBroker;"); if v == null goto label; v = new org.apache.activemq.broker.ConnectionContext; specialinvoke v.()>(); v = ; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = new org.apache.activemq.command.ActiveMQMessage; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.("cause", v); v = staticinvoke (); v = virtualinvoke v.(); virtualinvoke v.(v, v, v, null, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("failed to fire forward failure advisory, cause: {}", v); v = ; interfaceinvoke v.("detail", v); label: return; catch java.lang.Exception from label to label with label; } protected org.apache.activemq.Service getControllingService() { org.apache.activemq.Service v; org.apache.activemq.broker.TransportConnection v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; if v == null goto label; v = v.; goto label; label: v = v; label: return v; } protected void addSubscription(org.apache.activemq.network.DemandSubscription) throws java.io.IOException { org.apache.activemq.network.DemandSubscription v; org.apache.activemq.transport.Transport v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; if v == null goto label; v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v); label: return; } protected void removeSubscription(org.apache.activemq.network.DemandSubscription) throws java.io.IOException { java.lang.Object[] v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v, v, v, v; java.util.concurrent.ConcurrentMap v, v; java.lang.String v; java.util.concurrent.ExecutorService v; org.apache.activemq.command.ConsumerInfo v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.slf4j.Logger v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.network.DemandForwardingBridgeSupport$12 v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; if v == null goto label; v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("{} remove local subscription: {} for remote {}", v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$12; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,org.apache.activemq.network.DemandSubscription)>(v, v); interfaceinvoke v.(v); label: return; } protected org.apache.activemq.command.Message configureMessage(org.apache.activemq.command.MessageDispatch) throws java.io.IOException { org.apache.activemq.command.BrokerId[] v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ProducerId v; org.apache.activemq.command.Message v, v; org.apache.activemq.command.MessageDispatch v; org.apache.activemq.command.ProducerInfo v; org.apache.activemq.command.TransactionId v, v; boolean v; org.apache.activemq.network.NetworkBridgeConfiguration v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.MessageDispatch; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(null); v = virtualinvoke v.(); if v != null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(null); v = v.; v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: return v; } protected void serviceLocalCommand(org.apache.activemq.command.Command) { org.apache.activemq.command.ConsumerId v, v, v; org.apache.activemq.command.Message v, v, v, v, v; byte v; org.apache.activemq.command.DataStructure v; java.lang.Throwable v, v, v, v, v; java.lang.Object[] v, v; java.lang.String v, v, v, v, v, v, v, v; org.apache.activemq.command.BrokerId[] v, v; org.apache.activemq.management.CountStatisticImpl v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeStatistics v, v; org.apache.activemq.transport.Transport v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.network.DemandForwardingBridgeSupport$13 v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v, v, v; org.apache.activemq.command.MessageAck v, v; org.slf4j.Logger v, v, v, v, v, v, v; org.apache.activemq.command.Command v; org.apache.activemq.network.DemandForwardingBridgeSupport$FutureBrokerInfo v; java.lang.Class v; java.lang.Object v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.Command; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v, v); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("{} message not forwarded to {} because message came from there or fails TTL, brokerPath: {}, message: {}", v); label: v = v.; v = new org.apache.activemq.command.MessageAck; specialinvoke v.(org.apache.activemq.command.MessageDispatch,byte,int)>(v, 4, 1); interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: return; label: v = virtualinvoke v.(v); v = ; v = newarray (java.lang.Object)[6]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = virtualinvoke v.(); v[2] = v; v = virtualinvoke v.(); v[3] = v; v = virtualinvoke v.(); v = staticinvoke (v); v[4] = v; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = v; goto label; label: v = virtualinvoke v.(); label: v[5] = v; interfaceinvoke v.("bridging ({} -> {}), consumer: {}, destination: {}, brokerPath: {}, message: {}", v); v = virtualinvoke v.(); if v == 0 goto label; v = staticinvoke (v); if v == 0 goto label; label: v = v.; interfaceinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: return; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = v.; v = new org.apache.activemq.network.DemandForwardingBridgeSupport$13; specialinvoke v.(org.apache.activemq.network.DemandForwardingBridgeSupport,org.apache.activemq.command.MessageDispatch,org.apache.activemq.network.DemandSubscription)>(v, v, v); interfaceinvoke v.(v, v); goto label; label: v = v.; interfaceinvoke v.(v); v = v.; v = new org.apache.activemq.command.MessageAck; specialinvoke v.(org.apache.activemq.command.MessageDispatch,byte,int)>(v, 4, 1); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: virtualinvoke v.(v); goto label; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("No subscription registered with this network bridge for consumerId: {} for message: {}", v, v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} Shutting down {}", v, v); virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/command/ConnectionError;" goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = interfaceinvoke v.(); lookupswitch(v) { case 1: goto label; case 92: goto label; default: goto label; }; label: v = ; interfaceinvoke v.("Unexpected local command: {}", v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Caught an exception processing local command", v); virtualinvoke v.(v); label: 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; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private boolean suppressMessageDispatch(org.apache.activemq.command.MessageDispatch, org.apache.activemq.network.DemandSubscription) throws java.lang.Exception { org.apache.activemq.filter.NonCachedMessageEvaluationContext v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.command.NetworkBridgeFilter v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.Message v; org.apache.activemq.command.MessageDispatch v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.MessageDispatch; v := @parameter: org.apache.activemq.network.DemandSubscription; v = 0; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.filter.NonCachedMessageEvaluationContext; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = v; label: return v; } public static boolean contains(org.apache.activemq.command.BrokerId[], org.apache.activemq.command.BrokerId) { org.apache.activemq.command.BrokerId[] v; org.apache.activemq.command.BrokerId v, v; int v, v; boolean v; v := @parameter: org.apache.activemq.command.BrokerId[]; v := @parameter: org.apache.activemq.command.BrokerId; if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(v); if v == 0 goto label; return 1; label: v = v + 1; goto label; label: return 0; } protected org.apache.activemq.command.BrokerId[] appendToBrokerPath(org.apache.activemq.command.BrokerId[], org.apache.activemq.command.BrokerId[]) { org.apache.activemq.command.BrokerId[] v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; int v, v, v, v, v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.BrokerId[]; v := @parameter: org.apache.activemq.command.BrokerId[]; if v == null goto label; v = lengthof v; if v != 0 goto label; label: return v; label: v = lengthof v; v = lengthof v; v = v + v; v = newarray (org.apache.activemq.command.BrokerId)[v]; v = lengthof v; staticinvoke (v, 0, v, 0, v); v = lengthof v; v = lengthof v; staticinvoke (v, 0, v, v, v); return v; } protected org.apache.activemq.command.BrokerId[] appendToBrokerPath(org.apache.activemq.command.BrokerId[], org.apache.activemq.command.BrokerId) { org.apache.activemq.command.BrokerId[] v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerId v; int v, v, v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.BrokerId[]; v := @parameter: org.apache.activemq.command.BrokerId; if v == null goto label; v = lengthof v; if v != 0 goto label; label: v = newarray (org.apache.activemq.command.BrokerId)[1]; v[0] = v; return v; label: v = lengthof v; v = v + 1; v = newarray (org.apache.activemq.command.BrokerId)[v]; v = lengthof v; staticinvoke (v, 0, v, 0, v); v = lengthof v; v[v] = v; return v; } protected boolean isPermissableDestination(org.apache.activemq.command.ActiveMQDestination) { org.apache.activemq.network.DemandForwardingBridgeSupport v; boolean v; org.apache.activemq.command.ActiveMQDestination v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = virtualinvoke v.(v, 0); return v; } protected boolean isPermissableDestination(org.apache.activemq.command.ActiveMQDestination, boolean) { byte v, v, v, v, v, v; boolean v, v, v, v, v, v; org.apache.activemq.command.ActiveMQDestination v, v, v, v; org.apache.activemq.command.ActiveMQDestination[] v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; int v, v, v, v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.apache.activemq.filter.DestinationFilter v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: boolean; v = virtualinvoke v.(); if v == 0 goto label; if v == 0 goto label; return 1; label: v = v.; v = virtualinvoke v.(); return v; label: v = v.; if v == null goto label; v = lengthof v; if v <= 0 goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; return 0; label: v = v + 1; goto label; label: v = v.; if v == null goto label; v = lengthof v; if v <= 0 goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; return 1; label: v = v + 1; goto label; label: v = v.; if v == null goto label; v = lengthof v; if v <= 0 goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = staticinvoke (v); if v == null goto label; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; return 1; label: v = v + 1; goto label; label: return 0; label: return 1; } protected void setupStaticDestinations() { org.apache.activemq.network.DemandForwardingBridgeSupport v; int v, v; java.lang.String v, v, v; boolean v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v; org.slf4j.Logger v, v, v, v; java.io.IOException v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(v, null); if v == null goto label; virtualinvoke v.(1); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to add static destination {}", v, v); label: v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{}, bridging messages for static destination: {}", v, v); goto label; label: v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{}, static destination excluded: {}, demand already exists", v, v); goto label; label: v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{}, static destination excluded: {}", v, v); label: v = v + 1; goto label; label: return; catch java.io.IOException from label to label with label; } protected void addConsumerInfo(org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { org.apache.activemq.network.DemandForwardingBridgeSupport v; java.lang.String v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v, v; boolean v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.apache.activemq.command.SubscriptionInfo v; org.slf4j.Logger v; org.apache.activemq.command.BrokerId[] v; java.util.Set v; org.apache.activemq.network.DemandSubscription v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(v); if v == null goto label; v = specialinvoke v.(v); if v == 0 goto label; specialinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.("NC-DS_"); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(); v = new org.apache.activemq.command.SubscriptionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); interfaceinvoke v.(v); label: virtualinvoke v.(v); v = ; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("{} new demand subscription: {}", v, v); label: return; } private void undoMapRegistration(org.apache.activemq.network.DemandSubscription) { org.apache.activemq.network.DemandSubscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v, v; java.util.concurrent.ConcurrentMap v, v; org.apache.activemq.command.ConsumerInfo v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v); return; } private boolean duplicateSuppressionIsRequired(org.apache.activemq.network.DemandSubscription) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerInfo v, v, v; boolean v, v, v, v, v, v; java.util.Iterator v; java.util.Collection v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.command.ActiveMQDestination v; java.util.List v, v; java.lang.Object v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.DemandSubscription; v = virtualinvoke v.(); v = 0; v = specialinvoke v.(v); if v == 0 goto label; return 0; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v, v); if v == 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; v = 0; goto label; label: v = virtualinvoke v.(); v = specialinvoke v.(v, v); label: return v; } private boolean isDuplicateSuppressionOff(org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private boolean isInActiveDurableSub(org.apache.activemq.broker.region.Subscription) { org.apache.activemq.broker.region.Subscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerInfo v; boolean v, v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.broker.region.Subscription; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v instanceof org.apache.activemq.broker.region.DurableTopicSubscription; if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } private boolean hasLowerPriority(org.apache.activemq.broker.region.Subscription, org.apache.activemq.command.ConsumerInfo) { java.lang.Object[] v, v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; byte v, v; java.lang.String v, v, v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v; boolean v; org.apache.activemq.network.NetworkBridgeConfiguration v, v; org.slf4j.Logger v, v, v; java.io.IOException v; java.util.List v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.broker.region.Subscription; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = 0; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v < v goto label; v = ; v = newarray (java.lang.Object)[5]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v[2] = v; v[3] = v; v = interfaceinvoke v.(); v = virtualinvoke v.(); v[4] = v; interfaceinvoke v.("{} Ignoring duplicate subscription from {}, sub: {} is duplicate by network subscription with equal or higher network priority: {}, networkConsumerIds: {}", v); v = 1; goto label; label: specialinvoke v.(v); v = ; v = newarray (java.lang.Object)[5]; v = v.; v = virtualinvoke v.(); v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = v.; v[2] = v; v[3] = v; v = virtualinvoke v.(); v[4] = v; interfaceinvoke v.("{} Replacing duplicate subscription {} with sub from {}, which has a higher priority, new sub: {}, networkConsumerIds: {}", v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to remove duplicated sub as a result of sub with higher priority, sub: {}", v, v); label: return v; catch java.io.IOException from label to label with label; } private void removeDuplicateSubscription(org.apache.activemq.broker.region.Subscription) throws java.io.IOException { org.apache.activemq.broker.BrokerService v; java.util.Iterator v; org.apache.activemq.broker.region.Subscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v; java.util.List v; java.lang.Object v; org.apache.activemq.command.ConsumerInfo v; boolean v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.broker.region.Subscription; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: return; } private boolean matchFound(java.util.List, java.util.List) { java.util.Iterator v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.util.List v, v; java.lang.Object v; boolean v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.util.List; v := @parameter: java.util.List; v = 0; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = 1; label: return v; } protected final java.util.Collection getRegionSubscriptions(org.apache.activemq.command.ActiveMQDestination) { org.apache.activemq.broker.BrokerService v; java.util.Collection v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.Broker v; byte v; java.util.Map v; org.apache.activemq.broker.region.Region v; boolean v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v = v.; v = virtualinvoke v.(); v = null; v = virtualinvoke v.(); tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; case 5: goto label; case 6: goto label; default: goto label; }; label: v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: v = v instanceof org.apache.activemq.broker.region.AbstractRegion; if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); goto label; label: v = null; label: return v; } protected org.apache.activemq.network.DemandSubscription createDemandSubscription(org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { org.apache.activemq.network.DemandSubscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(v); return v; } protected org.apache.activemq.network.DemandSubscription doCreateDemandSubscription(org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { java.lang.Object[] v; long v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.ConnectionInfo v; org.apache.activemq.command.SessionInfo v; int v, v, v; java.lang.String v, v; java.lang.Byte v; org.apache.activemq.command.ConsumerInfo v, v, v, v; boolean v, v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v; org.slf4j.Logger v; org.apache.activemq.command.ConnectionId v; org.apache.activemq.command.BrokerId[] v, v, v; org.apache.activemq.command.SessionId v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.command.ActiveMQDestination v, v; org.apache.activemq.util.LongSequenceGenerator v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = new org.apache.activemq.network.DemandSubscription; specialinvoke v.(org.apache.activemq.command.ConsumerInfo)>(v); v = virtualinvoke v.(); v = new org.apache.activemq.command.ConsumerId; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.SessionId,long)>(v, v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = lengthof v; if v <= 1 goto label; v = virtualinvoke v.(); v = lengthof v; label: v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = newarray (java.lang.Object)[3]; v = v.; v = virtualinvoke v.(); v[0] = v; v = staticinvoke (v); v[1] = v; v[2] = v; interfaceinvoke v.("{} using priority: {} for subscription: {}", v); label: virtualinvoke v.(v, v); return v; } protected final org.apache.activemq.network.DemandSubscription createDemandSubscription(org.apache.activemq.command.ActiveMQDestination, java.lang.String) { org.slf4j.Logger v; org.apache.activemq.command.BrokerId[] v; org.apache.activemq.command.SessionId v; java.io.IOException v; long v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.util.LongSequenceGenerator v; org.apache.activemq.command.SessionInfo v; org.apache.activemq.command.BrokerId v; java.lang.String v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination; v := @parameter: java.lang.String; v = new org.apache.activemq.command.ConsumerInfo; specialinvoke v.()>(); virtualinvoke v.(1); virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = newarray (org.apache.activemq.command.BrokerId)[1]; v = v.; v[0] = v; virtualinvoke v.(v); v = new org.apache.activemq.command.ConsumerId; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.command.SessionId,long)>(v, v); virtualinvoke v.(v); v = null; label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to create DemandSubscription ", v); label: return v; catch java.io.IOException from label to label with label; } protected void configureDemandSubscription(org.apache.activemq.command.ConsumerInfo, org.apache.activemq.network.DemandSubscription) throws java.io.IOException { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v, v; java.util.concurrent.ConcurrentMap v, v; java.lang.String v, v; org.apache.activemq.command.ConsumerInfo v, v, v, v, v, v, v; boolean v, v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.apache.activemq.command.SubscriptionInfo v; org.apache.activemq.network.DemandSubscription v; org.apache.activemq.command.NetworkBridgeFilter v, v; org.apache.activemq.command.ActiveMQDestination v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v := @parameter: org.apache.activemq.network.DemandSubscription; v = virtualinvoke v.(); v = staticinvoke (v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; label: v = virtualinvoke v.(); virtualinvoke v.(1); goto label; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = new org.apache.activemq.command.SubscriptionInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.lang.String,java.lang.String)>(v, v); virtualinvoke v.(v); label: return; } protected void removeDemandSubscription(org.apache.activemq.command.ConsumerId) throws java.io.IOException { java.lang.Object[] v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v; java.util.concurrent.ConcurrentMap v; java.lang.String v, v, v, v; org.apache.activemq.command.ConsumerInfo v; org.apache.activemq.network.NetworkBridgeConfiguration v, v; org.slf4j.Logger v, v; org.apache.activemq.transport.Transport v, v; java.lang.Object v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerId; v = v.; v = interfaceinvoke v.(v); v = ; v = newarray (java.lang.Object)[5]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = v.; v[2] = v; v[3] = v; v[4] = v; interfaceinvoke v.("{} remove request on {} from {}, consumer id: {}, matching sub: {}", v); if v == null goto label; virtualinvoke v.(v); v = ; v = newarray (java.lang.Object)[4]; v = v.; v = virtualinvoke v.(); v[0] = v; v = v.; v[1] = v; v = v.; v[2] = v; v = virtualinvoke v.(); v[3] = v; interfaceinvoke v.("{} removed sub on {} from {}: {}", v); label: return; } protected boolean removeDemandSubscriptionByLocalId(org.apache.activemq.command.ConsumerId) { org.slf4j.Logger v; java.io.IOException v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerId v, v; java.util.concurrent.ConcurrentMap v; java.lang.Object v; org.apache.activemq.command.ConsumerInfo v; boolean v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerId; v = 0; v = v.; v = interfaceinvoke v.(v); if v == null goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = 1; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("removeDemandSubscriptionByLocalId failed for localId: {}", v, v); label: return v; catch java.io.IOException from label to label with label; } protected boolean safeWaitUntilStarted() throws java.lang.InterruptedException { java.util.concurrent.atomic.AtomicBoolean v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; java.util.concurrent.TimeUnit v; java.util.concurrent.CountDownLatch v; boolean v, v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = ; v = virtualinvoke v.(1L, v); if v == 0 goto label; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; } protected org.apache.activemq.command.NetworkBridgeFilter createNetworkBridgeFilter(org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { org.apache.activemq.broker.region.policy.PolicyMap v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.network.NetworkBridgeFilterFactory v, v; int v, v; org.apache.activemq.command.ConsumerInfo v; org.apache.activemq.network.NetworkBridgeConfiguration v, v; org.apache.activemq.broker.BrokerService v, v, v; org.apache.activemq.command.BrokerId[] v; org.apache.activemq.command.NetworkBridgeFilter v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.broker.region.policy.PolicyEntry v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = v.; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v, v, v, v); return v; } protected void addRemoteBrokerToBrokerPath(org.apache.activemq.command.ConsumerInfo) throws java.io.IOException { org.apache.activemq.command.BrokerId[] v, v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ConsumerInfo v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); virtualinvoke v.(v); return; } protected org.apache.activemq.command.BrokerId[] getRemoteBrokerPath() { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.BrokerId[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setNetworkBridgeListener(org.apache.activemq.network.NetworkBridgeListener) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.network.NetworkBridgeListener v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.network.NetworkBridgeListener; v. = v; return; } private void fireBridgeFailed(java.lang.Throwable) { java.lang.Throwable v; org.slf4j.Logger v; org.apache.activemq.network.NetworkBridgeListener v, v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.network.DemandForwardingBridgeSupport v; boolean v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: java.lang.Throwable; v = ; v = v.; interfaceinvoke v.("fire bridge failed, listener: {}", v, v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; interfaceinvoke v.(); label: return; } public org.apache.activemq.command.ActiveMQDestination[] getDynamicallyIncludedDestinations() { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setDynamicallyIncludedDestinations(org.apache.activemq.command.ActiveMQDestination[]) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination[]; v. = v; return; } public org.apache.activemq.command.ActiveMQDestination[] getExcludedDestinations() { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setExcludedDestinations(org.apache.activemq.command.ActiveMQDestination[]) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination[]; v. = v; return; } public org.apache.activemq.command.ActiveMQDestination[] getStaticallyIncludedDestinations() { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setStaticallyIncludedDestinations(org.apache.activemq.command.ActiveMQDestination[]) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination[]; v. = v; return; } public org.apache.activemq.command.ActiveMQDestination[] getDurableDestinations() { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setDurableDestinations(org.apache.activemq.command.ActiveMQDestination[]) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination[] v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ActiveMQDestination[]; v. = v; return; } public org.apache.activemq.transport.Transport getLocalBroker() { org.apache.activemq.transport.Transport v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public org.apache.activemq.transport.Transport getRemoteBroker() { org.apache.activemq.transport.Transport v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public boolean isCreatedByDuplex() { org.apache.activemq.network.DemandForwardingBridgeSupport v; boolean v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setCreatedByDuplex(boolean) { org.apache.activemq.network.DemandForwardingBridgeSupport v; boolean v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: boolean; v. = v; return; } public java.lang.String getRemoteAddress() { org.apache.activemq.transport.Transport v; java.lang.String v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = interfaceinvoke v.(); return v; } public java.lang.String getLocalAddress() { org.apache.activemq.transport.Transport v; java.lang.String v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = interfaceinvoke v.(); return v; } public java.lang.String getRemoteBrokerName() { org.apache.activemq.command.BrokerInfo v, v; java.lang.String v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; if v != null goto label; v = null; goto label; label: v = v.; v = virtualinvoke v.(); label: return v; } public java.lang.String getRemoteBrokerId() { org.apache.activemq.command.BrokerInfo v, v, v; org.apache.activemq.command.BrokerId v, v; java.lang.String v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v != null goto label; label: v = null; goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); label: return v; } public java.lang.String getLocalBrokerName() { org.apache.activemq.command.BrokerInfo v, v; java.lang.String v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; if v != null goto label; v = null; goto label; label: v = v.; v = virtualinvoke v.(); label: return v; } public long getDequeueCounter() { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.network.NetworkBridgeStatistics v; long v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public long getEnqueueCounter() { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.network.NetworkBridgeStatistics v; long v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); return v; } public org.apache.activemq.network.NetworkBridgeStatistics getNetworkBridgeStatistics() { org.apache.activemq.network.NetworkBridgeStatistics v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } protected boolean isDuplex() { org.apache.activemq.network.DemandForwardingBridgeSupport v; boolean v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public java.util.concurrent.ConcurrentMap getLocalSubscriptionMap() { org.apache.activemq.network.DemandForwardingBridgeSupport v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void setBrokerService(org.apache.activemq.broker.BrokerService) { org.apache.activemq.broker.BrokerService v; org.apache.activemq.broker.Broker v; org.apache.activemq.command.BrokerId[] v; org.apache.activemq.command.BrokerId v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.broker.BrokerService; v. = v; v = virtualinvoke v.(); v = interfaceinvoke v.(); v. = v; v = v.; v = v.; v[0] = v; return; } public void setMbeanObjectName(javax.management.ObjectName) { javax.management.ObjectName v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: javax.management.ObjectName; v. = v; return; } public javax.management.ObjectName getMbeanObjectName() { javax.management.ObjectName v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; return v; } public void resetStats() { org.apache.activemq.network.NetworkBridgeStatistics v; org.apache.activemq.network.DemandForwardingBridgeSupport v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v = v.; virtualinvoke v.(); return; } protected void serviceOutbound(org.apache.activemq.command.Message) { org.apache.activemq.command.Message v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.network.NetworkBridgeListener v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.Message; v = v.; if v == null goto label; interfaceinvoke v.(v, v); label: return; } protected void serviceInboundMessage(org.apache.activemq.command.Message) { org.apache.activemq.command.Message v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.network.NetworkBridgeListener v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.Message; v = v.; if v == null goto label; interfaceinvoke v.(v, v); label: return; } protected boolean canDuplexDispatch(org.apache.activemq.command.Message) { java.lang.Object[] v; long v, v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.Message v; byte v; java.lang.Long v, v; boolean v, v, v; org.apache.activemq.network.NetworkBridgeConfiguration v; org.slf4j.Logger v, v; org.apache.activemq.command.MessageId v, v; org.apache.activemq.command.DataStructure v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.Message; v = 1; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v cmp v; if v > 0 goto label; v = 0; v = ; v = newarray (java.lang.Object)[3]; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = v; goto label; label: v = virtualinvoke v.(); label: v[0] = v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("suppressing duplicate message send [{}] from network producer with producerSequence [{}] less than last stored: {}", v); label: return v; } protected long getStoredSequenceIdForMessage(org.apache.activemq.command.MessageId) { org.apache.activemq.broker.BrokerService v; org.slf4j.Logger v; org.apache.activemq.command.MessageId v; java.io.IOException v; long v; org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ProducerId v; org.apache.activemq.store.PersistenceAdapter v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.MessageId; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(v); label: return v; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to determine last producer sequence id for: {}", v, v); return -1L; catch java.io.IOException from label to label with label; } protected void configureConsumerPrefetch(org.apache.activemq.command.ConsumerInfo) { org.apache.activemq.network.DemandForwardingBridgeSupport v; org.apache.activemq.command.ActiveMQDestination v; int v, v, v; org.apache.activemq.command.ConsumerInfo v; boolean v; org.apache.activemq.network.NetworkBridgeConfiguration v, v, v; v := @this: org.apache.activemq.network.DemandForwardingBridgeSupport; v := @parameter: org.apache.activemq.command.ConsumerInfo; v = virtualinvoke v.(); v = staticinvoke (v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/activemq/network/DemandForwardingBridgeSupport;"); = v; return; } }