public class org.apache.activemq.state.SessionState extends java.lang.Object
{
final org.apache.activemq.command.SessionInfo info;
private final java.util.Map producers;
private final java.util.Map consumers;
private final java.util.concurrent.atomic.AtomicBoolean shutdown;
public void <init>(org.apache.activemq.command.SessionInfo)
{
org.apache.activemq.state.SessionState v;
org.apache.activemq.command.SessionInfo v;
java.util.concurrent.ConcurrentHashMap v, v;
java.util.concurrent.atomic.AtomicBoolean v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.SessionInfo;
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.SessionState: java.util.Map producers> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.state.SessionState: java.util.Map consumers> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.state.SessionState: java.util.concurrent.atomic.AtomicBoolean shutdown> = v;
v.<org.apache.activemq.state.SessionState: org.apache.activemq.command.SessionInfo info> = v;
return;
}
public java.lang.String toString()
{
java.lang.String v;
org.apache.activemq.state.SessionState v;
org.apache.activemq.command.SessionInfo v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: org.apache.activemq.command.SessionInfo info>;
v = virtualinvoke v.<org.apache.activemq.command.SessionInfo: java.lang.String toString()>();
return v;
}
public void addProducer(org.apache.activemq.command.ProducerInfo)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.state.ProducerState v;
org.apache.activemq.state.SessionState v;
org.apache.activemq.command.ProducerInfo v;
java.util.Map v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.ProducerInfo;
specialinvoke v.<org.apache.activemq.state.SessionState: void checkShutdown()>();
v = v.<org.apache.activemq.state.SessionState: java.util.Map producers>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
v = new org.apache.activemq.state.ProducerState;
specialinvoke v.<org.apache.activemq.state.ProducerState: void <init>(org.apache.activemq.command.ProducerInfo)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public org.apache.activemq.state.ProducerState removeProducer(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.state.TransactionState v, v;
org.apache.activemq.state.SessionState v;
java.util.Map v;
java.lang.Object v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.ProducerId;
v = v.<org.apache.activemq.state.SessionState: java.util.Map producers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.state.ProducerState: org.apache.activemq.state.TransactionState getTransactionState()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.state.ProducerState: org.apache.activemq.state.TransactionState getTransactionState()>();
virtualinvoke v.<org.apache.activemq.state.TransactionState: void addProducerState(org.apache.activemq.state.ProducerState)>(v);
label:
return v;
}
public void addConsumer(org.apache.activemq.command.ConsumerInfo)
{
org.apache.activemq.state.SessionState v;
java.util.Map v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.command.ConsumerInfo v;
org.apache.activemq.state.ConsumerState v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.ConsumerInfo;
specialinvoke v.<org.apache.activemq.state.SessionState: void checkShutdown()>();
v = v.<org.apache.activemq.state.SessionState: java.util.Map consumers>;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.ConsumerId getConsumerId()>();
v = new org.apache.activemq.state.ConsumerState;
specialinvoke v.<org.apache.activemq.state.ConsumerState: void <init>(org.apache.activemq.command.ConsumerInfo)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public org.apache.activemq.state.ConsumerState removeConsumer(org.apache.activemq.command.ConsumerId)
{
org.apache.activemq.state.SessionState v;
java.util.Map v;
java.lang.Object v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.ConsumerId;
v = v.<org.apache.activemq.state.SessionState: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return v;
}
public org.apache.activemq.command.SessionInfo getInfo()
{
org.apache.activemq.state.SessionState v;
org.apache.activemq.command.SessionInfo v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: org.apache.activemq.command.SessionInfo info>;
return v;
}
public java.util.Set getConsumerIds()
{
java.util.Set v;
org.apache.activemq.state.SessionState v;
java.util.Map v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
return v;
}
public java.util.Set getProducerIds()
{
java.util.Set v;
org.apache.activemq.state.SessionState v;
java.util.Map v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: java.util.Map producers>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
return v;
}
public java.util.Collection getProducerStates()
{
org.apache.activemq.state.SessionState v;
java.util.Collection v;
java.util.Map v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: java.util.Map producers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
return v;
}
public org.apache.activemq.state.ProducerState getProducerState(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.state.SessionState v;
java.util.Map v;
java.lang.Object v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.ProducerId;
v = v.<org.apache.activemq.state.SessionState: java.util.Map producers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public java.util.Collection getConsumerStates()
{
org.apache.activemq.state.SessionState v;
java.util.Collection v;
java.util.Map v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
return v;
}
public org.apache.activemq.state.ConsumerState getConsumerState(org.apache.activemq.command.ConsumerId)
{
org.apache.activemq.state.SessionState v;
java.util.Map v;
java.lang.Object v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.state.SessionState;
v := @parameter: org.apache.activemq.command.ConsumerId;
v = v.<org.apache.activemq.state.SessionState: java.util.Map consumers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
private void checkShutdown()
{
java.lang.IllegalStateException v;
org.apache.activemq.state.SessionState v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: 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.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.state.SessionState v;
v := @this: org.apache.activemq.state.SessionState;
v = v.<org.apache.activemq.state.SessionState: java.util.concurrent.atomic.AtomicBoolean shutdown>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
return;
}
}