public class org.apache.activemq.ActiveMQMessageAuditNoSync extends java.lang.Object implements java.io.Serializable
{
private static final long serialVersionUID;
public static final int DEFAULT_WINDOW_SIZE;
public static final int MAXIMUM_PRODUCER_COUNT;
private int auditDepth;
private int maximumNumberOfProducersToTrack;
private final org.apache.activemq.util.LRUCache map;
private transient boolean modified;
public void <init>()
{
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
specialinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: void <init>(int,int)>(2048, 64);
return;
}
public void <init>(int, int)
{
int v, v;
org.apache.activemq.util.LRUCache v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int auditDepth> = v;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int maximumNumberOfProducersToTrack> = v;
v = new org.apache.activemq.util.LRUCache;
specialinvoke v.<org.apache.activemq.util.LRUCache: void <init>(int,int,float,boolean)>(0, v, 0.75F, 1);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map> = v;
return;
}
public int getAuditDepth()
{
int v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int auditDepth>;
return v;
}
public void setAuditDepth(int)
{
int v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: int;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int auditDepth> = v;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
return;
}
public int getMaximumNumberOfProducersToTrack()
{
int v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int maximumNumberOfProducersToTrack>;
return v;
}
public void setMaximumNumberOfProducersToTrack(int)
{
org.apache.activemq.ActiveMQMessageAuditNoSync v;
int v, v;
org.apache.activemq.util.LRUCache v, v, v, v, v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: int;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int maximumNumberOfProducersToTrack>;
if v >= v goto label;
v = new org.apache.activemq.util.LRUCache;
specialinvoke v.<org.apache.activemq.util.LRUCache: void <init>(int,int,float,boolean)>(0, v, 0.75F, 1);
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: void putAll(java.util.Map)>(v);
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: void clear()>();
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: void putAll(java.util.Map)>(v);
label:
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: void setMaxCacheSize(int)>(v);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int maximumNumberOfProducersToTrack> = v;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
return;
}
public boolean isDuplicate(javax.jms.Message) throws javax.jms.JMSException
{
java.lang.String v;
javax.jms.Message v;
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: javax.jms.Message;
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean isDuplicate(java.lang.String)>(v);
return v;
}
public boolean isDuplicate(java.lang.String)
{
long v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
org.apache.activemq.util.BitArrayBin v;
byte v;
int v;
java.lang.Object v;
java.lang.String v, v;
org.apache.activemq.util.LRUCache v, v;
boolean v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: java.lang.String;
v = 0;
v = staticinvoke <org.apache.activemq.util.IdGenerator: java.lang.String getSeedFromId(java.lang.String)>(v);
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.activemq.util.BitArrayBin;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int auditDepth>;
specialinvoke v.<org.apache.activemq.util.BitArrayBin: void <init>(int)>(v);
v = v;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
v = staticinvoke <org.apache.activemq.util.IdGenerator: long getSequenceFromId(java.lang.String)>(v);
v = v cmp 0L;
if v < 0 goto label;
v = virtualinvoke v.<org.apache.activemq.util.BitArrayBin: boolean setBit(long,boolean)>(v, 1);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
return v;
}
public boolean isDuplicate(org.apache.activemq.broker.region.MessageReference)
{
org.apache.activemq.broker.region.MessageReference v;
org.apache.activemq.command.MessageId v;
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.broker.region.MessageReference;
v = interfaceinvoke v.<org.apache.activemq.broker.region.MessageReference: org.apache.activemq.command.MessageId getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean isDuplicate(org.apache.activemq.command.MessageId)>(v);
return v;
}
public boolean isDuplicate(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageId v;
long v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
org.apache.activemq.command.ProducerId v;
org.apache.activemq.util.BitArrayBin v;
int v;
java.lang.Object v;
java.lang.String v, v;
org.apache.activemq.util.LRUCache v, v;
boolean v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.command.MessageId;
v = 0;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: org.apache.activemq.command.ProducerId getProducerId()>();
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.activemq.util.BitArrayBin;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int auditDepth>;
specialinvoke v.<org.apache.activemq.util.BitArrayBin: void <init>(int)>(v);
v = v;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageId: long getProducerSequenceId()>();
v = virtualinvoke v.<org.apache.activemq.util.BitArrayBin: boolean setBit(long,boolean)>(v, 1);
label:
return v;
}
public void rollback(org.apache.activemq.broker.region.MessageReference)
{
org.apache.activemq.broker.region.MessageReference v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.broker.region.MessageReference;
v = interfaceinvoke v.<org.apache.activemq.broker.region.MessageReference: org.apache.activemq.command.MessageId getMessageId()>();
virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: void rollback(org.apache.activemq.command.MessageId)>(v);
return;
}
public void rollback(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.command.MessageId v;
java.lang.Object v;
long v;
java.lang.String v;
org.apache.activemq.util.LRUCache v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.command.MessageId;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: org.apache.activemq.command.ProducerId getProducerId()>();
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: long getProducerSequenceId()>();
virtualinvoke v.<org.apache.activemq.util.BitArrayBin: boolean setBit(long,boolean)>(v, 0);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
return;
}
public void rollback(java.lang.String)
{
java.lang.Object v;
long v;
java.lang.String v, v;
org.apache.activemq.util.LRUCache v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.activemq.util.IdGenerator: java.lang.String getSeedFromId(java.lang.String)>(v);
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = staticinvoke <org.apache.activemq.util.IdGenerator: long getSequenceFromId(java.lang.String)>(v);
virtualinvoke v.<org.apache.activemq.util.BitArrayBin: boolean setBit(long,boolean)>(v, 0);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
return;
}
public boolean isInOrder(javax.jms.Message) throws javax.jms.JMSException
{
java.lang.String v;
javax.jms.Message v;
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: javax.jms.Message;
v = interfaceinvoke v.<javax.jms.Message: java.lang.String getJMSMessageID()>();
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean isInOrder(java.lang.String)>(v);
return v;
}
public boolean isInOrder(java.lang.String)
{
java.lang.Object v;
long v;
java.lang.String v, v;
org.apache.activemq.util.LRUCache v;
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: java.lang.String;
v = 1;
if v == null goto label;
v = staticinvoke <org.apache.activemq.util.IdGenerator: java.lang.String getSeedFromId(java.lang.String)>(v);
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = staticinvoke <org.apache.activemq.util.IdGenerator: long getSequenceFromId(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.activemq.util.BitArrayBin: boolean isInOrder(long)>(v);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
return v;
}
public boolean isInOrder(org.apache.activemq.broker.region.MessageReference)
{
org.apache.activemq.broker.region.MessageReference v;
org.apache.activemq.command.MessageId v;
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.broker.region.MessageReference;
v = interfaceinvoke v.<org.apache.activemq.broker.region.MessageReference: org.apache.activemq.command.MessageId getMessageId()>();
v = virtualinvoke v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean isInOrder(org.apache.activemq.command.MessageId)>(v);
return v;
}
public boolean isInOrder(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageId v;
long v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
org.apache.activemq.command.ProducerId v;
org.apache.activemq.util.BitArrayBin v;
int v;
java.lang.Object v;
java.lang.String v, v;
org.apache.activemq.util.LRUCache v, v;
boolean v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.command.MessageId;
v = 0;
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: org.apache.activemq.command.ProducerId getProducerId()>();
if v == null goto label;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.activemq.util.BitArrayBin;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: int auditDepth>;
specialinvoke v.<org.apache.activemq.util.BitArrayBin: void <init>(int)>(v);
v = v;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 1;
label:
v = virtualinvoke v.<org.apache.activemq.command.MessageId: long getProducerSequenceId()>();
v = virtualinvoke v.<org.apache.activemq.util.BitArrayBin: boolean isInOrder(long)>(v);
label:
return v;
}
public long getLastSeqId(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.command.ProducerId v;
java.lang.Object v;
long v;
java.lang.String v;
org.apache.activemq.util.LRUCache v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: org.apache.activemq.command.ProducerId;
v = -1L;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
v = virtualinvoke v.<org.apache.activemq.command.ProducerId: java.lang.String toString()>();
v = virtualinvoke v.<org.apache.activemq.util.LRUCache: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.util.BitArrayBin: long getLastSetIndex()>();
label:
return v;
}
public void clear()
{
org.apache.activemq.util.LRUCache v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: org.apache.activemq.util.LRUCache map>;
virtualinvoke v.<org.apache.activemq.util.LRUCache: void clear()>();
return;
}
public boolean isModified()
{
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified>;
return v;
}
public void setModified(boolean)
{
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v := @parameter: boolean;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = v;
return;
}
public boolean modified()
{
boolean v;
org.apache.activemq.ActiveMQMessageAuditNoSync v;
v := @this: org.apache.activemq.ActiveMQMessageAuditNoSync;
v = v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified>;
if v == 0 goto label;
v.<org.apache.activemq.ActiveMQMessageAuditNoSync: boolean modified> = 0;
return 1;
label:
return 0;
}
}