public class org.apache.activemq.network.jms.ReconnectionPolicy extends java.lang.Object
{
public static final int INFINITE;
private int maxSendRetries;
private long sendRetryDelay;
private int maxReconnectAttempts;
private int maxInitialConnectAttempts;
private long maximumReconnectDelay;
private long initialReconnectDelay;
private boolean useExponentialBackOff;
private double backOffMultiplier;
public void <init>()
{
int v, v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxSendRetries> = 10;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long sendRetryDelay> = 1000L;
v = (int) -1;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxReconnectAttempts> = v;
v = (int) -1;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxInitialConnectAttempts> = v;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long maximumReconnectDelay> = 30000L;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long initialReconnectDelay> = 1000L;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: boolean useExponentialBackOff> = 0;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: double backOffMultiplier> = 2.0;
return;
}
public int getMaxSendRetries()
{
int v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxSendRetries>;
return v;
}
public void setMaxSendRetries(int)
{
int v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: int;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxSendRetries> = v;
return;
}
public long getSendRetryDelay()
{
long v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long sendRetryDelay>;
return v;
}
public void setSendRetyDelay(long)
{
long v;
byte v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: long;
v = v cmp 1000L;
if v >= 0 goto label;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long sendRetryDelay> = 1000L;
label:
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long sendRetryDelay> = v;
return;
}
public int getMaxReconnectAttempts()
{
int v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxReconnectAttempts>;
return v;
}
public void setMaxReconnectAttempts(int)
{
int v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: int;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxReconnectAttempts> = v;
return;
}
public int getMaxInitialConnectAttempts()
{
int v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxInitialConnectAttempts>;
return v;
}
public void setMaxInitialConnectAttempts(int)
{
int v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: int;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: int maxInitialConnectAttempts> = v;
return;
}
public long getMaximumReconnectDelay()
{
long v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long maximumReconnectDelay>;
return v;
}
public void setMaximumReconnectDelay(long)
{
long v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: long;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long maximumReconnectDelay> = v;
return;
}
public long getInitialReconnectDelay()
{
long v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long initialReconnectDelay>;
return v;
}
public void setInitialReconnectDelay(long)
{
long v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: long;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: long initialReconnectDelay> = v;
return;
}
public boolean isUseExponentialBackOff()
{
org.apache.activemq.network.jms.ReconnectionPolicy v;
boolean v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: boolean useExponentialBackOff>;
return v;
}
public void setUseExponentialBackOff(boolean)
{
org.apache.activemq.network.jms.ReconnectionPolicy v;
boolean v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: boolean;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: boolean useExponentialBackOff> = v;
return;
}
public double getBackOffMultiplier()
{
org.apache.activemq.network.jms.ReconnectionPolicy v;
double v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: double backOffMultiplier>;
return v;
}
public void setBackOffMultiplier(double)
{
org.apache.activemq.network.jms.ReconnectionPolicy v;
double v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: double;
v.<org.apache.activemq.network.jms.ReconnectionPolicy: double backOffMultiplier> = v;
return;
}
public long getNextDelay(int)
{
long v, v, v, v, v;
byte v, v;
org.apache.activemq.network.jms.ReconnectionPolicy v;
int v, v;
boolean v;
double v, v;
v := @this: org.apache.activemq.network.jms.ReconnectionPolicy;
v := @parameter: int;
if v != 0 goto label;
return 0L;
label:
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long initialReconnectDelay>;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: boolean useExponentialBackOff>;
if v == 0 goto label;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long initialReconnectDelay>;
v = v - 1;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: double backOffMultiplier>;
v = v * v;
v = v * v;
v = staticinvoke <java.lang.Math: long max(long,long)>(v, v);
label:
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long maximumReconnectDelay>;
v = v cmp 0L;
if v <= 0 goto label;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long maximumReconnectDelay>;
v = v cmp v;
if v <= 0 goto label;
v = v.<org.apache.activemq.network.jms.ReconnectionPolicy: long maximumReconnectDelay>;
label:
return v;
}
}