public class org.apache.activemq.state.ConnectionState extends java.lang.Object
{
org.apache.activemq.command.ConnectionInfo info;
private final java.util.concurrent.ConcurrentMap transactions;
private final java.util.concurrent.ConcurrentMap sessions;
private final java.util.List tempDestinations;
private final java.util.concurrent.atomic.AtomicBoolean shutdown;
private boolean connectionInterruptProcessingComplete;
private java.util.concurrent.ConcurrentMap recoveringPullConsumers;
public void <init>(org.apache.activemq.command.ConnectionInfo)
{
java.util.concurrent.ConcurrentHashMap v, v;
org.apache.activemq.state.ConnectionState v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.ArrayList v;
java.util.List v;
org.apache.activemq.command.ConnectionInfo v;
org.apache.activemq.command.SessionInfo v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.ConnectionInfo;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap transactions> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List synchronizedList(java.util.List)>(v);
v.<org.apache.activemq.state.ConnectionState: java.util.List tempDestinations> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.atomic.AtomicBoolean shutdown> = v;
v.<org.apache.activemq.state.ConnectionState: boolean connectionInterruptProcessingComplete> = 1;
v.<org.apache.activemq.state.ConnectionState: org.apache.activemq.command.ConnectionInfo info> = v;
v = new org.apache.activemq.command.SessionInfo;
specialinvoke v.<org.apache.activemq.command.SessionInfo: void <init>(org.apache.activemq.command.ConnectionInfo,long)>(v, -1L);
virtualinvoke v.<org.apache.activemq.state.ConnectionState: void addSession(org.apache.activemq.command.SessionInfo)>(v);
return;
}
public java.lang.String toString()
{
org.apache.activemq.state.ConnectionState v;
java.lang.String v;
org.apache.activemq.command.ConnectionInfo v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: org.apache.activemq.command.ConnectionInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: java.lang.String toString()>();
return v;
}
public void reset(org.apache.activemq.command.ConnectionInfo)
{
java.util.List v;
org.apache.activemq.command.ConnectionInfo v;
org.apache.activemq.command.SessionInfo v;
org.apache.activemq.state.ConnectionState v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.ConcurrentMap v, v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.ConnectionInfo;
v.<org.apache.activemq.state.ConnectionState: org.apache.activemq.command.ConnectionInfo info> = v;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap transactions>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: void clear()>();
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: void clear()>();
v = v.<org.apache.activemq.state.ConnectionState: java.util.List tempDestinations>;
interfaceinvoke v.<java.util.List: void clear()>();
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.atomic.AtomicBoolean shutdown>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
v = new org.apache.activemq.command.SessionInfo;
specialinvoke v.<org.apache.activemq.command.SessionInfo: void <init>(org.apache.activemq.command.ConnectionInfo,long)>(v, -1L);
virtualinvoke v.<org.apache.activemq.state.ConnectionState: void addSession(org.apache.activemq.command.SessionInfo)>(v);
return;
}
public void addTempDestination(org.apache.activemq.command.DestinationInfo)
{
org.apache.activemq.state.ConnectionState v;
java.util.List v;
org.apache.activemq.command.DestinationInfo v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.DestinationInfo;
specialinvoke v.<org.apache.activemq.state.ConnectionState: void checkShutdown()>();
v = v.<org.apache.activemq.state.ConnectionState: java.util.List tempDestinations>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public void removeTempDestination(org.apache.activemq.command.ActiveMQDestination)
{
java.util.Iterator v;
org.apache.activemq.state.ConnectionState v;
org.apache.activemq.command.ActiveMQDestination v, v;
java.util.List v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v = v.<org.apache.activemq.state.ConnectionState: java.util.List tempDestinations>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.activemq.command.DestinationInfo: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v = virtualinvoke v.<org.apache.activemq.command.ActiveMQDestination: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
interfaceinvoke v.<java.util.Iterator: void remove()>();
goto label;
label:
return;
}
public void addTransactionState(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.state.TransactionState v;
org.apache.activemq.state.ConnectionState v;
org.apache.activemq.command.TransactionId v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.TransactionId;
specialinvoke v.<org.apache.activemq.state.ConnectionState: void checkShutdown()>();
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap transactions>;
v = new org.apache.activemq.state.TransactionState;
specialinvoke v.<org.apache.activemq.state.TransactionState: void <init>(org.apache.activemq.command.TransactionId)>(v);
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public org.apache.activemq.state.TransactionState getTransactionState(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.state.ConnectionState v;
java.lang.Object v;
org.apache.activemq.command.TransactionId v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap transactions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public java.util.Collection getTransactionStates()
{
org.apache.activemq.state.ConnectionState v;
java.util.Collection v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap transactions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Collection values()>();
return v;
}
public org.apache.activemq.state.TransactionState removeTransactionState(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.state.ConnectionState v;
java.lang.Object v;
org.apache.activemq.command.TransactionId v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.TransactionId;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap transactions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
return v;
}
public void addSession(org.apache.activemq.command.SessionInfo)
{
org.apache.activemq.state.SessionState v;
org.apache.activemq.command.SessionId v;
org.apache.activemq.command.SessionInfo v;
org.apache.activemq.state.ConnectionState v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.SessionInfo;
specialinvoke v.<org.apache.activemq.state.ConnectionState: void checkShutdown()>();
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
v = virtualinvoke v.<org.apache.activemq.command.SessionInfo: org.apache.activemq.command.SessionId getSessionId()>();
v = new org.apache.activemq.state.SessionState;
specialinvoke v.<org.apache.activemq.state.SessionState: void <init>(org.apache.activemq.command.SessionInfo)>(v);
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public org.apache.activemq.state.SessionState removeSession(org.apache.activemq.command.SessionId)
{
org.apache.activemq.command.SessionId v;
org.apache.activemq.state.ConnectionState v;
java.lang.Object v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.SessionId;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
return v;
}
public org.apache.activemq.state.SessionState getSessionState(org.apache.activemq.command.SessionId)
{
org.apache.activemq.command.SessionId v;
org.apache.activemq.state.ConnectionState v;
java.lang.Object v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: org.apache.activemq.command.SessionId;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.activemq.command.ConnectionInfo getInfo()
{
org.apache.activemq.state.ConnectionState v;
org.apache.activemq.command.ConnectionInfo v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: org.apache.activemq.command.ConnectionInfo info>;
return v;
}
public java.util.Set getSessionIds()
{
org.apache.activemq.state.ConnectionState v;
java.util.Set v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Set keySet()>();
return v;
}
public java.util.List getTempDestinations()
{
org.apache.activemq.state.ConnectionState v;
java.util.List v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.List tempDestinations>;
return v;
}
public java.util.Collection getSessionStates()
{
org.apache.activemq.state.ConnectionState v;
java.util.Collection v;
java.util.concurrent.ConcurrentMap v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Collection values()>();
return v;
}
private void checkShutdown()
{
java.lang.IllegalStateException v;
org.apache.activemq.state.ConnectionState v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.atomic.AtomicBoolean shutdown>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("Disposed");
throw v;
label:
return;
}
public void shutdown()
{
java.util.Iterator v;
java.util.Collection v;
org.apache.activemq.state.ConnectionState v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.concurrent.ConcurrentMap v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.atomic.AtomicBoolean shutdown>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
if v == 0 goto label;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap sessions>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.state.SessionState: void shutdown()>();
goto label;
label:
return;
}
public java.util.Map getRecoveringPullConsumers()
{
java.util.concurrent.ConcurrentHashMap v;
org.apache.activemq.state.ConnectionState v;
java.util.concurrent.ConcurrentMap v, v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap recoveringPullConsumers>;
if v != null goto label;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap recoveringPullConsumers> = v;
label:
v = v.<org.apache.activemq.state.ConnectionState: java.util.concurrent.ConcurrentMap recoveringPullConsumers>;
return v;
}
public void setConnectionInterruptProcessingComplete(boolean)
{
org.apache.activemq.state.ConnectionState v;
boolean v;
v := @this: org.apache.activemq.state.ConnectionState;
v := @parameter: boolean;
v.<org.apache.activemq.state.ConnectionState: boolean connectionInterruptProcessingComplete> = v;
return;
}
public boolean isConnectionInterruptProcessingComplete()
{
org.apache.activemq.state.ConnectionState v;
boolean v;
v := @this: org.apache.activemq.state.ConnectionState;
v = v.<org.apache.activemq.state.ConnectionState: boolean connectionInterruptProcessingComplete>;
return v;
}
}