public class org.apache.activemq.transport.failover.FailoverTransport extends java.lang.Object implements org.apache.activemq.transport.CompositeTransport { private static final org.slf4j.Logger LOG; private static final int DEFAULT_INITIAL_RECONNECT_DELAY; private static final int INFINITE; private org.apache.activemq.transport.TransportListener transportListener; private volatile boolean disposed; private final java.util.concurrent.CopyOnWriteArrayList uris; private final java.util.concurrent.CopyOnWriteArrayList updated; private final java.lang.Object reconnectMutex; private final java.lang.Object backupMutex; private final java.lang.Object sleepMutex; private final java.lang.Object listenerMutex; private final org.apache.activemq.state.ConnectionStateTracker stateTracker; private final java.util.Map requestMap; private java.net.URI connectedTransportURI; private java.net.URI failedConnectTransportURI; private final java.util.concurrent.atomic.AtomicReference connectedTransport; private final org.apache.activemq.thread.TaskRunnerFactory reconnectTaskFactory; private final org.apache.activemq.thread.TaskRunner reconnectTask; private volatile boolean started; private long initialReconnectDelay; private long maxReconnectDelay; private double backOffMultiplier; private long timeout; private boolean useExponentialBackOff; private boolean randomize; private int maxReconnectAttempts; private int startupMaxReconnectAttempts; private int connectFailures; private int warnAfterReconnectAttempts; private long reconnectDelay; private java.lang.Exception connectionFailure; private boolean firstConnection; private boolean backup; private final java.util.List backups; private int backupPoolSize; private boolean trackMessages; private boolean trackTransactionProducers; private int maxCacheSize; private final org.apache.activemq.transport.TransportListener disposedListener; private boolean updateURIsSupported; private boolean reconnectSupported; private org.apache.activemq.broker.SslContext brokerSslContext; private java.lang.String updateURIsURL; private boolean rebalanceUpdateURIs; private boolean doRebalance; private boolean doReconnect; private boolean connectedToPriority; private boolean priorityBackup; private final java.util.ArrayList priorityList; private boolean priorityBackupAvailable; private java.lang.String nestedExtraQueryOptions; private volatile boolean shuttingDown; public void () { java.util.concurrent.atomic.AtomicReference v; java.util.ArrayList v; java.util.LinkedHashMap v; org.apache.activemq.broker.SslContext v; int v, v, v; java.lang.String v; org.apache.activemq.state.ConnectionStateTracker v, v; org.apache.activemq.transport.failover.FailoverTransport$2 v; org.apache.activemq.transport.failover.FailoverTransport$1 v; org.apache.activemq.thread.TaskRunner v; org.apache.activemq.thread.TaskRunnerFactory v, v, v; java.lang.Object v, v, v, v; org.apache.activemq.transport.failover.FailoverTransport v; java.util.concurrent.CopyOnWriteArrayList v, v, v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; specialinvoke v.()>(); v = new java.util.concurrent.CopyOnWriteArrayList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.CopyOnWriteArrayList; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.state.ConnectionStateTracker; specialinvoke v.()>(); v. = v; v = new java.util.LinkedHashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v. = 10L; v. = 30000L; v. = 2.0; v. = -1L; v. = 1; v. = 1; v = (int) -1; v. = v; v = (int) -1; v. = v; v. = 10; v. = 10L; v. = 1; v. = 0; v = new java.util.concurrent.CopyOnWriteArrayList; specialinvoke v.()>(); v. = v; v. = 1; v. = 0; v. = 1; v. = 131072; v = new org.apache.activemq.transport.failover.FailoverTransport$1; specialinvoke v.(org.apache.activemq.transport.failover.FailoverTransport)>(v); v. = v; v. = 1; v. = 1; v. = null; v. = 1; v. = 0; v. = 0; v. = 0; v. = 0; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v. = 0; v. = 0; v = staticinvoke (); v. = v; v = v.; virtualinvoke v.(1); v = new org.apache.activemq.thread.TaskRunnerFactory; specialinvoke v.()>(); v. = v; v = v.; virtualinvoke v.(); v = v.; v = new org.apache.activemq.transport.failover.FailoverTransport$2; specialinvoke v.(org.apache.activemq.transport.failover.FailoverTransport)>(v); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("ActiveMQ Failover Worker: \u0001"); v = virtualinvoke v.(v, v); v. = v; return; } private void processCommand(java.lang.Object) { java.lang.Throwable v; org.apache.activemq.transport.TransportListener v, v; java.lang.Integer v; org.apache.activemq.command.ConsumerId v; java.util.Map v, v; int v; boolean v, v, v, v; org.apache.activemq.command.Command v; org.apache.activemq.state.ConnectionStateTracker v; java.lang.Class v; java.lang.Object v, v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.lang.Object; if v != null goto label; return; label: v = interfaceinvoke v.(); if v == 0 goto label; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = virtualinvoke v.(); if v != class "Lorg/apache/activemq/state/Tracked;" goto label; virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); goto label; label: v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, -2L); label: v = v.; if v == null goto label; v = v.; interfaceinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } private org.apache.activemq.transport.TransportListener createTransportListener(org.apache.activemq.transport.Transport) { org.apache.activemq.transport.failover.FailoverTransport$3 v; org.apache.activemq.transport.Transport v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: org.apache.activemq.transport.Transport; v = new org.apache.activemq.transport.failover.FailoverTransport$3; specialinvoke v.(org.apache.activemq.transport.failover.FailoverTransport,org.apache.activemq.transport.Transport)>(v, v); return v; } public final void disposeTransport(org.apache.activemq.transport.Transport) { org.apache.activemq.transport.Transport v; org.apache.activemq.transport.failover.FailoverTransport v; org.apache.activemq.transport.TransportListener v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: org.apache.activemq.transport.Transport; v = v.; interfaceinvoke v.(v); staticinvoke (v); return; } public final void handleTransportFailure(java.io.IOException) throws java.lang.InterruptedException { java.io.IOException v; org.apache.activemq.transport.Transport v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.io.IOException; v = virtualinvoke v.(); virtualinvoke v.(v, v); return; } public final void handleTransportFailure(org.apache.activemq.transport.Transport, java.io.IOException) throws java.lang.InterruptedException { java.lang.Throwable v; java.lang.Object[] v; org.apache.activemq.transport.TransportListener v, v; java.util.concurrent.atomic.AtomicReference v, v; java.lang.String v, v; java.net.URI v, v; boolean v, v, v, v, v, v; org.slf4j.Logger v, v, v; java.io.IOException v; org.apache.activemq.transport.Transport v, v; org.apache.activemq.thread.TaskRunner v; java.lang.Object v, v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: org.apache.activemq.transport.Transport; v := @parameter: java.io.IOException; v = v.; if v == 0 goto label; return; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u handleTransportFailure: \u0001"); interfaceinvoke v.(v, v); label: v = null; v = v.; v = virtualinvoke v.(v, null); if v == 0 goto label; v = v; if v == null goto label; virtualinvoke v.(v); label: v = v.; entermonitor v; label: if v == null goto label; v = v.; v = virtualinvoke v.(); if v != null goto label; v = 0; v = specialinvoke v.(); if v == 0 goto label; v = 1; label: v = ; v = newarray (java.lang.Object)[3]; v = v.; v[0] = v; if v == 0 goto label; v = ","; goto label; label: v = ", not"; label: v[1] = v; v[2] = v; interfaceinvoke v.("Transport ({}) failed{} attempting to automatically reconnect", v); v = v.; v. = v; v. = null; v. = 0; if v == 0 goto label; v = v.; if v == null goto label; v = v.; interfaceinvoke v.(); label: v = v.; interfaceinvoke v.(); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; specialinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } private boolean canReconnect() { int v; org.apache.activemq.transport.failover.FailoverTransport v; boolean v, v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; if v == 0 goto label; v = specialinvoke v.(); if 0 == v goto label; v = 1; goto label; label: v = 0; label: return v; } public final void handleConnectionControl(org.apache.activemq.command.ConnectionControl) { org.apache.activemq.command.ConnectionControl v; int v; java.lang.String v, v, v, v, v; java.net.URI v; boolean v, v, v; org.slf4j.Logger v, v, v, v; java.lang.Exception v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: org.apache.activemq.command.ConnectionControl; v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Received ConnectionControl: {}", v); label: if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; label: v = new java.net.URI; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Reconnected to: \u0001"); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to handle ConnectionControl reconnect to \u0001"); interfaceinvoke v.(v, v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v); return; catch java.lang.Exception from label to label with label; } private final void processNewTransports(boolean, java.lang.String) { java.lang.Object[] v; java.util.ArrayList v; java.net.URI[] v; java.util.StringTokenizer v; int v, v; java.lang.String v, v, v, v, v; java.net.URI v; boolean v, v, v, v; org.slf4j.Logger v, v; java.io.IOException v; java.lang.Exception v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v := @parameter: java.lang.String; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.StringTokenizer; specialinvoke v.(java.lang.String,java.lang.String)>(v, ","); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); label: v = new java.net.URI; specialinvoke v.(java.lang.String)>(v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to parse broker address: \u0001"); interfaceinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(); if v != 0 goto label; label: v = interfaceinvoke v.(); v = newarray (java.net.URI)[v]; v = interfaceinvoke v.(v); virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to update transport URI\'s from: \u0001"); interfaceinvoke v.(v, v); label: return; catch java.lang.Exception from label to label with label; catch java.io.IOException from label to label with label; } public void start() throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.atomic.AtomicReference v, v; int v; boolean v, v, v; org.slf4j.Logger v; org.apache.activemq.state.ConnectionStateTracker v, v, v, v; java.lang.Object v, v, v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; entermonitor v; label: v = ; interfaceinvoke v.("Started {}", v); v = v.; if v == 0 goto label; exitmonitor v; label: return; label: v. = 1; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(0); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void stop() throws java.lang.Exception { org.apache.activemq.transport.TransportListener v; boolean v, v, v, v; org.apache.activemq.transport.Transport v; java.lang.Exception v; java.util.List v, v, v; org.apache.activemq.thread.TaskRunnerFactory v, v, v; java.lang.Throwable v, v, v, v; java.util.concurrent.atomic.AtomicReference v, v; java.util.ArrayList v; int v; org.slf4j.Logger v, v, v; java.util.Iterator v, v; org.apache.activemq.thread.TaskRunner v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = new java.util.ArrayList; v = v.; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); label: v = v.; entermonitor v; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Stopped {}", v); label: v = v.; if v != 0 goto label; exitmonitor v; label: v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); return; label: v. = 0; v. = 1; v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(null); label: v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; entermonitor v; label: v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); throw v; label: v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(1); v = virtualinvoke v.(); if v == null goto label; v = v.; interfaceinvoke v.(v); interfaceinvoke v.(v); goto label; label: v = v.; interfaceinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: v = ; interfaceinvoke v.("Stopped backup: {}", v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; goto label; label: if v == null goto label; interfaceinvoke 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; catch java.lang.Exception from label to label with label; } public long getInitialReconnectDelay() { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setInitialReconnectDelay(long) { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: long; v. = v; return; } public long getMaxReconnectDelay() { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setMaxReconnectDelay(long) { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: long; v. = v; return; } public long getReconnectDelay() { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setReconnectDelay(long) { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: long; v. = v; return; } public double getReconnectDelayExponent() { org.apache.activemq.transport.failover.FailoverTransport v; double v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setReconnectDelayExponent(double) { org.apache.activemq.transport.failover.FailoverTransport v; double v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: double; v. = v; return; } public org.apache.activemq.transport.Transport getConnectedTransport() { java.lang.Object v; org.apache.activemq.transport.failover.FailoverTransport v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; v = virtualinvoke v.(); return v; } public java.net.URI getConnectedTransportURI() { org.apache.activemq.transport.failover.FailoverTransport v; java.net.URI v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public int getMaxReconnectAttempts() { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setMaxReconnectAttempts(int) { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: int; v. = v; return; } public int getStartupMaxReconnectAttempts() { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setStartupMaxReconnectAttempts(int) { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: int; v. = v; return; } public long getTimeout() { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setTimeout(long) { long v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: long; v. = v; return; } public boolean isRandomize() { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setRandomize(boolean) { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v. = v; return; } public boolean isBackup() { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setBackup(boolean) { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v. = v; return; } public int getBackupPoolSize() { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setBackupPoolSize(int) { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: int; v. = v; return; } public int getCurrentBackups() { int v; java.util.List v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; v = interfaceinvoke v.(); return v; } public boolean isTrackMessages() { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setTrackMessages(boolean) { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v. = v; return; } public boolean isTrackTransactionProducers() { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setTrackTransactionProducers(boolean) { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v. = v; return; } public int getMaxCacheSize() { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setMaxCacheSize(int) { int v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: int; v. = v; return; } public boolean isPriorityBackup() { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; return v; } public void setPriorityBackup(boolean) { org.apache.activemq.transport.failover.FailoverTransport v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v. = v; return; } public void setPriorityURIs(java.lang.String) { org.slf4j.Logger v; java.lang.Exception v; java.util.ArrayList v; java.util.StringTokenizer v; org.apache.activemq.transport.failover.FailoverTransport v; java.lang.String v, v, v; java.net.URI v; boolean v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.lang.String; v = new java.util.StringTokenizer; specialinvoke v.(java.lang.String,java.lang.String)>(v, ","); label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); label: v = new java.net.URI; specialinvoke v.(java.lang.String)>(v); v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to parse broker address: \u0001"); interfaceinvoke v.(v, v); goto label; label: return; catch java.lang.Exception from label to label with label; } public void oneway(java.lang.Object) throws java.io.IOException { java.lang.Integer v, v, v, v, v; org.apache.activemq.command.ConsumerId v; byte v, v, v; java.lang.Long v; java.lang.Thread v, v, v; java.util.Map v, v, v, v; java.lang.Exception v, v, v; org.apache.activemq.state.Tracked v; java.lang.Throwable v, v; long v, v, v, v, v, v, v, v; java.io.InterruptedIOException v; java.lang.String v, v; java.io.IOException v, v, v, v, v, v, v, v; org.apache.activemq.command.MessageDispatch v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.state.ConnectionStateTracker v, v, v; org.apache.activemq.command.ActiveMQDestination v; org.apache.activemq.command.Response v; java.util.concurrent.atomic.AtomicReference v, v, v; org.apache.activemq.MaxFrameSizeExceededException v; int v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v; org.apache.activemq.command.Command v; java.lang.InterruptedException v, v; java.lang.Object v, v, v, v, v; org.apache.activemq.transport.failover.FailoverTransport v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.lang.Object; v = null; label: v = v.; entermonitor v; label: if v == null goto label; v = v.; v = virtualinvoke v.(); if v != null goto label; v = interfaceinvoke v.(); if v == 0 goto label; exitmonitor v; label: return; label: v = v instanceof org.apache.activemq.command.RemoveInfo; if v != 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; label: v = v.; virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.command.Response; specialinvoke v.()>(); v = interfaceinvoke v.(); virtualinvoke v.(v); specialinvoke v.(v); label: exitmonitor v; label: return; label: v = v instanceof org.apache.activemq.command.MessagePull; if v == 0 goto label; v = virtualinvoke v.(); v = v cmp 0L; if v == 0 goto label; v = new org.apache.activemq.command.MessageDispatch; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(v); label: exitmonitor v; label: return; label: v = 0; label: v = v.; if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (); v = 0; label: if v != null goto label; v = v.; if v != 0 goto label; v = v.; if v != null goto label; v = staticinvoke (); v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Waiting for transport to reconnect..: {}", v); v = staticinvoke (); v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = v cmp 0L; if v <= 0 goto label; v = v - v; v = v.; v = v cmp v; if v <= 0 goto label; v = 1; v = ; v = v - v; v = staticinvoke (v); interfaceinvoke v.("Failover timed out after {} ms", v); goto label; label: v = v.; virtualinvoke v.(100L); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = ; interfaceinvoke v.("Interupted:", v); label: v = v.; virtualinvoke v.(); goto label; label: if v != null goto label; v = v.; if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Transport disposed."); v = v; goto label; label: v = v.; if v == null goto label; v = v.; goto label; label: if v != 1 goto label; v = new java.io.IOException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failover timeout of \u ms reached."); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = specialinvoke v.(); if v != 0 goto label; v = new java.io.IOException; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Reconnect attempts of \u exceeded"); specialinvoke v.(java.lang.String)>(v); v = v; goto label; label: v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Unexpected failure."); v = v; label: goto label; label: v = null; label: v = v.; v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Cannot track the command {} {}", v, v); label: v = v.; entermonitor v; label: if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); goto label; label: if v != null goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: interfaceinvoke v.(v); v = v.; virtualinvoke v.(v); v = interfaceinvoke v.(); if v == 0 goto label; v. = 1; label: goto label; label: v := @caughtexception; if v != null goto label; v = specialinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); label: throw v; label: v = ; v = staticinvoke (v); interfaceinvoke v.("Send oneway attempt: {} failed for command: {}", v, v); virtualinvoke v.(v); label: exitmonitor v; label: return; label: v := @caughtexception; v = ; interfaceinvoke v.("MaxFrameSizeExceededException for command: {}", v); throw v; label: v := @caughtexception; v = ; v = staticinvoke (v); interfaceinvoke v.("Send oneway attempt: {} failed for command: {}", v, v); virtualinvoke v.(v); v = v + 1; goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); v = new java.io.InterruptedIOException; specialinvoke v.()>(); throw v; label: v = v.; if v != 0 goto label; if v == null goto label; v = v instanceof java.io.IOException; if v == 0 goto label; throw v; label: v = staticinvoke (v); throw v; label: return; catch java.lang.InterruptedException from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch org.apache.activemq.MaxFrameSizeExceededException from label to label with label; catch org.apache.activemq.MaxFrameSizeExceededException from label to label with label; catch java.io.IOException from label to label with label; catch java.io.IOException 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; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.InterruptedException from label to label with label; } private boolean willReconnect() { int v; org.apache.activemq.transport.failover.FailoverTransport v; boolean v, v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v = v.; if v != 0 goto label; v = specialinvoke v.(); if 0 == v goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.activemq.transport.FutureResponse asyncRequest(java.lang.Object, org.apache.activemq.transport.ResponseCallback) throws java.io.IOException { org.apache.activemq.transport.ResponseCallback v; java.lang.Object v; org.apache.activemq.transport.failover.FailoverTransport v; java.lang.AssertionError v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.lang.Object; v := @parameter: org.apache.activemq.transport.ResponseCallback; v = new java.lang.AssertionError; specialinvoke v.(java.lang.Object)>("Unsupported Method"); throw v; } public java.lang.Object request(java.lang.Object) throws java.io.IOException { java.lang.Object v; org.apache.activemq.transport.failover.FailoverTransport v; java.lang.AssertionError v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.lang.Object; v = new java.lang.AssertionError; specialinvoke v.(java.lang.Object)>("Unsupported Method"); throw v; } public java.lang.Object request(java.lang.Object, int) throws java.io.IOException { int v; java.lang.Object v; org.apache.activemq.transport.failover.FailoverTransport v; java.lang.AssertionError v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: java.lang.Object; v := @parameter: int; v = new java.lang.AssertionError; specialinvoke v.(java.lang.Object)>("Unsupported Method"); throw v; } public void add(boolean, java.net.URI[]) { java.net.URI[] v; int v, v; org.apache.activemq.transport.failover.FailoverTransport v; java.net.URI v; boolean v, v, v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v := @parameter: java.net.URI[]; v = 0; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = specialinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.(v); v = 1; label: v = v + 1; goto label; label: if v == 0 goto label; virtualinvoke v.(v); label: return; } public void remove(boolean, java.net.URI[]) { java.net.URI[] v; int v, v; org.apache.activemq.transport.failover.FailoverTransport v; java.net.URI v; boolean v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v := @parameter: java.net.URI[]; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; virtualinvoke v.(v); v = v + 1; goto label; label: return; } public void add(boolean, java.lang.String) { org.slf4j.Logger v; java.lang.Exception v; org.apache.activemq.transport.failover.FailoverTransport v; java.lang.String v; java.net.URI v; boolean v, v; java.util.concurrent.CopyOnWriteArrayList v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v := @parameter: java.lang.String; label: v = new java.net.URI; specialinvoke v.(java.lang.String)>(v); v = specialinvoke v.(v); if v != 0 goto label; v = v.; virtualinvoke v.(v); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to parse URI: {}", v); label: return; catch java.lang.Exception from label to label with label; } public void reconnect(boolean) { java.lang.Throwable v; org.slf4j.Logger v, v; org.apache.activemq.thread.TaskRunner v; java.lang.InterruptedException v; java.lang.Thread v; java.lang.Object v; org.apache.activemq.transport.failover.FailoverTransport v; boolean v, v; v := @this: org.apache.activemq.transport.failover.FailoverTransport; v := @parameter: boolean; v = v.; entermonitor v; label: v = v.; if v == 0 goto label; if v == 0 goto label; v. = 1; label: v = ; interfaceinvoke v.