public class org.apache.activemq.state.TransactionState extends java.lang.Object
{
private final java.util.List commands;
private final org.apache.activemq.command.TransactionId id;
private final java.util.concurrent.atomic.AtomicBoolean shutdown;
private boolean prepared;
private int preparedResult;
private final java.util.Map producers;
private final long createdAt;
public void <init>(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.state.TransactionState v;
java.util.concurrent.ConcurrentHashMap v;
java.util.concurrent.atomic.AtomicBoolean v;
long v;
org.apache.activemq.command.TransactionId v;
java.util.ArrayList v;
v := @this: org.apache.activemq.state.TransactionState;
v := @parameter: org.apache.activemq.command.TransactionId;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.activemq.state.TransactionState: java.util.List commands> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.state.TransactionState: java.util.concurrent.atomic.AtomicBoolean shutdown> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.activemq.state.TransactionState: java.util.Map producers> = v;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v.<org.apache.activemq.state.TransactionState: long createdAt> = v;
v.<org.apache.activemq.state.TransactionState: org.apache.activemq.command.TransactionId id> = v;
return;
}
public java.lang.String toString()
{
java.lang.String v;
org.apache.activemq.state.TransactionState v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: org.apache.activemq.command.TransactionId id>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
return v;
}
public void addCommand(org.apache.activemq.command.Command)
{
java.util.List v;
org.apache.activemq.state.TransactionState v;
org.apache.activemq.command.Command v;
v := @this: org.apache.activemq.state.TransactionState;
v := @parameter: org.apache.activemq.command.Command;
specialinvoke v.<org.apache.activemq.state.TransactionState: void checkShutdown()>();
v = v.<org.apache.activemq.state.TransactionState: java.util.List commands>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public java.util.List getCommands()
{
java.util.List v;
org.apache.activemq.state.TransactionState v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: java.util.List commands>;
return v;
}
private void checkShutdown()
{
java.lang.IllegalStateException v;
org.apache.activemq.state.TransactionState v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: 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.TransactionState v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: java.util.concurrent.atomic.AtomicBoolean shutdown>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
return;
}
public org.apache.activemq.command.TransactionId getId()
{
org.apache.activemq.state.TransactionState v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: org.apache.activemq.command.TransactionId id>;
return v;
}
public void setPrepared(boolean)
{
org.apache.activemq.state.TransactionState v;
boolean v;
v := @this: org.apache.activemq.state.TransactionState;
v := @parameter: boolean;
v.<org.apache.activemq.state.TransactionState: boolean prepared> = v;
return;
}
public boolean isPrepared()
{
org.apache.activemq.state.TransactionState v;
boolean v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: boolean prepared>;
return v;
}
public void setPreparedResult(int)
{
int v;
org.apache.activemq.state.TransactionState v;
v := @this: org.apache.activemq.state.TransactionState;
v := @parameter: int;
v.<org.apache.activemq.state.TransactionState: int preparedResult> = v;
return;
}
public int getPreparedResult()
{
int v;
org.apache.activemq.state.TransactionState v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: int preparedResult>;
return v;
}
public void addProducerState(org.apache.activemq.state.ProducerState)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.state.ProducerState v;
org.apache.activemq.state.TransactionState v;
org.apache.activemq.command.ProducerInfo v;
java.util.Map v;
v := @this: org.apache.activemq.state.TransactionState;
v := @parameter: org.apache.activemq.state.ProducerState;
if v == null goto label;
v = v.<org.apache.activemq.state.TransactionState: java.util.Map producers>;
v = virtualinvoke v.<org.apache.activemq.state.ProducerState: org.apache.activemq.command.ProducerInfo getInfo()>();
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.ProducerId getProducerId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
}
public java.util.Map getProducerStates()
{
org.apache.activemq.state.TransactionState v;
java.util.Map v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: java.util.Map producers>;
return v;
}
public long getCreatedAt()
{
long v;
org.apache.activemq.state.TransactionState v;
v := @this: org.apache.activemq.state.TransactionState;
v = v.<org.apache.activemq.state.TransactionState: long createdAt>;
return v;
}
}