public abstract class org.apache.activemq.command.Message extends org.apache.activemq.command.BaseCommand implements org.apache.activemq.command.MarshallAware, org.apache.activemq.broker.region.MessageReference
{
public static final java.lang.String ORIGINAL_EXPIRATION;
public static final int DEFAULT_MINIMUM_MESSAGE_SIZE;
protected org.apache.activemq.command.MessageId messageId;
protected org.apache.activemq.command.ActiveMQDestination originalDestination;
protected org.apache.activemq.command.TransactionId originalTransactionId;
protected org.apache.activemq.command.ProducerId producerId;
protected org.apache.activemq.command.ActiveMQDestination destination;
protected org.apache.activemq.command.TransactionId transactionId;
protected long expiration;
protected long timestamp;
protected long arrival;
protected long brokerInTime;
protected long brokerOutTime;
protected java.lang.String correlationId;
protected org.apache.activemq.command.ActiveMQDestination replyTo;
protected boolean persistent;
protected java.lang.String type;
protected byte priority;
protected java.lang.String groupID;
protected int groupSequence;
protected org.apache.activemq.command.ConsumerId targetConsumerId;
protected boolean compressed;
protected java.lang.String userID;
protected org.apache.activemq.util.ByteSequence content;
protected volatile org.apache.activemq.util.ByteSequence marshalledProperties;
protected org.apache.activemq.command.DataStructure dataStructure;
protected int redeliveryCounter;
protected int size;
protected java.util.Map properties;
protected boolean readOnlyProperties;
protected boolean readOnlyBody;
protected transient boolean recievedByDFBridge;
protected boolean droppable;
protected boolean jmsXGroupFirstForConsumer;
private transient short referenceCount;
private transient org.apache.activemq.ActiveMQConnection connection;
transient org.apache.activemq.command.Message$MessageDestination regionDestination;
transient org.apache.activemq.usage.MemoryUsage memoryUsage;
transient java.util.concurrent.atomic.AtomicBoolean processAsExpired;
private org.apache.activemq.command.BrokerId[] brokerPath;
private org.apache.activemq.command.BrokerId[] cluster;
public void <init>()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void <init>()>();
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.activemq.command.Message: java.util.concurrent.atomic.AtomicBoolean processAsExpired> = v;
return;
}
public abstract org.apache.activemq.command.Message copy();
public abstract void clearBody() throws javax.jms.JMSException;
public abstract void storeContent();
public abstract void storeContentAndClear();
public void clearMarshalledState() throws javax.jms.JMSException
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
virtualinvoke v.<org.apache.activemq.command.Message: void clearUnMarshalledState()>();
return;
}
public void clearUnMarshalledState() throws javax.jms.JMSException
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v.<org.apache.activemq.command.Message: java.util.Map properties> = null;
return;
}
public boolean isMarshalled()
{
org.apache.activemq.command.Message v;
boolean v, v, v;
v := @this: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isContentMarshalled()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isPropertiesMarshalled()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected boolean isPropertiesMarshalled()
{
org.apache.activemq.command.Message v;
java.util.Map v;
org.apache.activemq.util.ByteSequence v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
if v != null goto label;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
if v != null goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected boolean isContentMarshalled()
{
org.apache.activemq.command.Message v;
org.apache.activemq.util.ByteSequence v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected void copy(org.apache.activemq.command.Message)
{
org.apache.activemq.command.Message v, v;
byte v;
java.util.Map v, v, v, v;
org.apache.activemq.usage.MemoryUsage v;
org.apache.activemq.util.ByteSequence v, v, v, v;
boolean v, v, v, v, v, v;
org.apache.activemq.command.MessageId v, v, v;
org.apache.activemq.ActiveMQConnection v;
org.apache.activemq.command.ActiveMQDestination v, v, v;
org.apache.activemq.command.DataStructure v;
org.apache.activemq.command.Message$MessageDestination v;
java.util.HashMap v;
long v, v, v, v, v;
int v, v, v;
java.lang.String v, v, v, v;
org.apache.activemq.command.TransactionId v, v;
org.apache.activemq.command.BrokerId[] v;
org.apache.activemq.command.ProducerId v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.Message;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void copy(org.apache.activemq.command.BaseCommand)>(v);
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ProducerId producerId>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ProducerId producerId> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId transactionId>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId transactionId> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination destination>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination destination> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId messageId>;
if v == null goto label;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId messageId>;
v = virtualinvoke v.<org.apache.activemq.command.MessageId: org.apache.activemq.command.MessageId copy()>();
goto label;
label:
v = null;
label:
v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId messageId> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination originalDestination>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination originalDestination> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId originalTransactionId>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId originalTransactionId> = v;
v = v.<org.apache.activemq.command.Message: long expiration>;
v.<org.apache.activemq.command.Message: long expiration> = v;
v = v.<org.apache.activemq.command.Message: long timestamp>;
v.<org.apache.activemq.command.Message: long timestamp> = v;
v = v.<org.apache.activemq.command.Message: java.lang.String correlationId>;
v.<org.apache.activemq.command.Message: java.lang.String correlationId> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination replyTo>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination replyTo> = v;
v = v.<org.apache.activemq.command.Message: boolean persistent>;
v.<org.apache.activemq.command.Message: boolean persistent> = v;
v = v.<org.apache.activemq.command.Message: int redeliveryCounter>;
v.<org.apache.activemq.command.Message: int redeliveryCounter> = v;
v = v.<org.apache.activemq.command.Message: java.lang.String type>;
v.<org.apache.activemq.command.Message: java.lang.String type> = v;
v = v.<org.apache.activemq.command.Message: byte priority>;
v.<org.apache.activemq.command.Message: byte priority> = v;
v = v.<org.apache.activemq.command.Message: int size>;
v.<org.apache.activemq.command.Message: int size> = v;
v = v.<org.apache.activemq.command.Message: java.lang.String groupID>;
v.<org.apache.activemq.command.Message: java.lang.String groupID> = v;
v = v.<org.apache.activemq.command.Message: java.lang.String userID>;
v.<org.apache.activemq.command.Message: java.lang.String userID> = v;
v = v.<org.apache.activemq.command.Message: int groupSequence>;
v.<org.apache.activemq.command.Message: int groupSequence> = v;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
if v == null goto label;
v = new java.util.HashMap;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v.<org.apache.activemq.command.Message: java.util.Map properties> = v;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>("originalExpiration");
goto label;
label:
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
v.<org.apache.activemq.command.Message: java.util.Map properties> = v;
label:
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content>;
v = specialinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence copyByteSequence(org.apache.activemq.util.ByteSequence)>(v);
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
v = specialinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence copyByteSequence(org.apache.activemq.util.ByteSequence)>(v);
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.DataStructure dataStructure>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.DataStructure dataStructure> = v;
v = v.<org.apache.activemq.command.Message: boolean readOnlyProperties>;
v.<org.apache.activemq.command.Message: boolean readOnlyProperties> = v;
v = v.<org.apache.activemq.command.Message: boolean readOnlyBody>;
v.<org.apache.activemq.command.Message: boolean readOnlyBody> = v;
v = v.<org.apache.activemq.command.Message: boolean compressed>;
v.<org.apache.activemq.command.Message: boolean compressed> = v;
v = v.<org.apache.activemq.command.Message: boolean recievedByDFBridge>;
v.<org.apache.activemq.command.Message: boolean recievedByDFBridge> = v;
v = v.<org.apache.activemq.command.Message: long arrival>;
v.<org.apache.activemq.command.Message: long arrival> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.ActiveMQConnection connection>;
v.<org.apache.activemq.command.Message: org.apache.activemq.ActiveMQConnection connection> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.Message$MessageDestination regionDestination>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.Message$MessageDestination regionDestination> = v;
v = v.<org.apache.activemq.command.Message: long brokerInTime>;
v.<org.apache.activemq.command.Message: long brokerInTime> = v;
v = v.<org.apache.activemq.command.Message: long brokerOutTime>;
v.<org.apache.activemq.command.Message: long brokerOutTime> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage memoryUsage>;
v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage memoryUsage> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.BrokerId[] brokerPath>;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.BrokerId[] brokerPath> = v;
v = v.<org.apache.activemq.command.Message: boolean jmsXGroupFirstForConsumer>;
v.<org.apache.activemq.command.Message: boolean jmsXGroupFirstForConsumer> = v;
return;
}
private org.apache.activemq.util.ByteSequence copyByteSequence(org.apache.activemq.util.ByteSequence)
{
byte[] v;
org.apache.activemq.command.Message v;
int v, v;
org.apache.activemq.util.ByteSequence v, v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.util.ByteSequence;
if v == null goto label;
v = new org.apache.activemq.util.ByteSequence;
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: byte[] getData()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: int getOffset()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: int getLength()>();
specialinvoke v.<org.apache.activemq.util.ByteSequence: void <init>(byte[],int,int)>(v, v, v);
return v;
label:
return null;
}
public java.lang.Object getProperty(java.lang.String) throws java.io.IOException
{
org.apache.activemq.command.Message v;
java.util.Map v, v, v;
java.lang.Object v;
java.lang.String v;
org.apache.activemq.util.ByteSequence v, v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
if v != null goto label;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
if v != null goto label;
return null;
label:
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
v = specialinvoke v.<org.apache.activemq.command.Message: java.util.Map unmarsallProperties(org.apache.activemq.util.ByteSequence)>(v);
v.<org.apache.activemq.command.Message: java.util.Map properties> = v;
label:
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = v instanceof org.fusesource.hawtbuf.UTF8Buffer;
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
label:
return v;
}
public java.util.Map getProperties() throws java.io.IOException
{
org.apache.activemq.command.Message v;
java.util.Map v, v, v, v, v;
org.apache.activemq.util.ByteSequence v, v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
if v != null goto label;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
if v != null goto label;
v = <java.util.Collections: java.util.Map EMPTY_MAP>;
return v;
label:
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
v = specialinvoke v.<org.apache.activemq.command.Message: java.util.Map unmarsallProperties(org.apache.activemq.util.ByteSequence)>(v);
v.<org.apache.activemq.command.Message: java.util.Map properties> = v;
label:
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
v = staticinvoke <java.util.Collections: java.util.Map unmodifiableMap(java.util.Map)>(v);
return v;
}
public void clearProperties()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties> = null;
v.<org.apache.activemq.command.Message: java.util.Map properties> = null;
return;
}
public void setProperty(java.lang.String, java.lang.Object) throws java.io.IOException
{
org.apache.activemq.command.Message v;
java.util.Map v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
virtualinvoke v.<org.apache.activemq.command.Message: void lazyCreateProperties()>();
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void removeProperty(java.lang.String) throws java.io.IOException
{
org.apache.activemq.command.Message v;
java.lang.String v;
java.util.Map v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
virtualinvoke v.<org.apache.activemq.command.Message: void lazyCreateProperties()>();
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return;
}
protected void lazyCreateProperties() throws java.io.IOException
{
org.apache.activemq.command.Message v;
java.util.Map v, v;
java.util.HashMap v;
org.apache.activemq.util.ByteSequence v, v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
if v != null goto label;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
if v != null goto label;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.command.Message: java.util.Map properties> = v;
goto label;
label:
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
v = specialinvoke v.<org.apache.activemq.command.Message: java.util.Map unmarsallProperties(org.apache.activemq.util.ByteSequence)>(v);
v.<org.apache.activemq.command.Message: java.util.Map properties> = v;
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties> = null;
goto label;
label:
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties> = null;
label:
return;
}
private java.util.Map unmarsallProperties(org.apache.activemq.util.ByteSequence) throws java.io.IOException
{
java.io.DataInputStream v;
org.apache.activemq.command.Message v;
java.util.Map v;
org.apache.activemq.util.ByteArrayInputStream v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.util.ByteSequence;
v = new java.io.DataInputStream;
v = new org.apache.activemq.util.ByteArrayInputStream;
specialinvoke v.<org.apache.activemq.util.ByteArrayInputStream: void <init>(org.apache.activemq.util.ByteSequence)>(v);
specialinvoke v.<java.io.DataInputStream: void <init>(java.io.InputStream)>(v);
v = staticinvoke <org.apache.activemq.util.MarshallingSupport: java.util.Map unmarshalPrimitiveMap(java.io.DataInputStream)>(v);
return v;
}
public void beforeMarshall(org.apache.activemq.wireformat.WireFormat) throws java.io.IOException
{
org.apache.activemq.util.ByteArrayOutputStream v;
org.apache.activemq.wireformat.WireFormat v;
org.apache.activemq.command.Message v;
java.io.DataOutputStream v;
java.util.Map v, v;
org.apache.activemq.util.ByteSequence v, v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
if v != null goto label;
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
if v == null goto label;
v = new org.apache.activemq.util.ByteArrayOutputStream;
specialinvoke v.<org.apache.activemq.util.ByteArrayOutputStream: void <init>()>();
v = new java.io.DataOutputStream;
specialinvoke v.<java.io.DataOutputStream: void <init>(java.io.OutputStream)>(v);
v = v.<org.apache.activemq.command.Message: java.util.Map properties>;
staticinvoke <org.apache.activemq.util.MarshallingSupport: void marshalPrimitiveMap(java.util.Map,java.io.DataOutputStream)>(v, v);
virtualinvoke v.<java.io.DataOutputStream: void close()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteArrayOutputStream: org.apache.activemq.util.ByteSequence toByteSequence()>();
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties> = v;
label:
return;
}
public void afterMarshall(org.apache.activemq.wireformat.WireFormat) throws java.io.IOException
{
org.apache.activemq.command.Message v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
return;
}
public void beforeUnmarshall(org.apache.activemq.wireformat.WireFormat) throws java.io.IOException
{
org.apache.activemq.command.Message v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
return;
}
public void afterUnmarshall(org.apache.activemq.wireformat.WireFormat) throws java.io.IOException
{
org.apache.activemq.command.Message v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
return;
}
public org.apache.activemq.command.ProducerId getProducerId()
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ProducerId producerId>;
return v;
}
public void setProducerId(org.apache.activemq.command.ProducerId)
{
org.apache.activemq.command.ProducerId v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.ProducerId;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ProducerId producerId> = v;
return;
}
public org.apache.activemq.command.ActiveMQDestination getDestination()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination destination>;
return v;
}
public void setDestination(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination destination> = v;
return;
}
public org.apache.activemq.command.TransactionId getTransactionId()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId transactionId>;
return v;
}
public void setTransactionId(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.TransactionId;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId transactionId> = v;
return;
}
public boolean isInTransaction()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.TransactionId v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId transactionId>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.activemq.command.ActiveMQDestination getOriginalDestination()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination originalDestination>;
return v;
}
public void setOriginalDestination(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination originalDestination> = v;
return;
}
public org.apache.activemq.command.MessageId getMessageId()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId messageId>;
return v;
}
public void setMessageId(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.MessageId;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId messageId> = v;
return;
}
public org.apache.activemq.command.TransactionId getOriginalTransactionId()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId originalTransactionId>;
return v;
}
public void setOriginalTransactionId(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.TransactionId;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.TransactionId originalTransactionId> = v;
return;
}
public java.lang.String getGroupID()
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.lang.String groupID>;
return v;
}
public void setGroupID(java.lang.String)
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.Message: java.lang.String groupID> = v;
return;
}
public int getGroupSequence()
{
int v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: int groupSequence>;
return v;
}
public void setGroupSequence(int)
{
int v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: int;
v.<org.apache.activemq.command.Message: int groupSequence> = v;
return;
}
public java.lang.String getCorrelationId()
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.lang.String correlationId>;
return v;
}
public void setCorrelationId(java.lang.String)
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.Message: java.lang.String correlationId> = v;
return;
}
public boolean isPersistent()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean persistent>;
return v;
}
public void setPersistent(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean persistent> = v;
return;
}
public long getExpiration()
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: long expiration>;
return v;
}
public void setExpiration(long)
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: long;
v.<org.apache.activemq.command.Message: long expiration> = v;
return;
}
public byte getPriority()
{
org.apache.activemq.command.Message v;
byte v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: byte priority>;
return v;
}
public void setPriority(byte)
{
org.apache.activemq.command.Message v;
byte v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: byte;
if v >= 0 goto label;
v.<org.apache.activemq.command.Message: byte priority> = 0;
goto label;
label:
if v <= 9 goto label;
v.<org.apache.activemq.command.Message: byte priority> = 9;
goto label;
label:
v.<org.apache.activemq.command.Message: byte priority> = v;
label:
return;
}
public org.apache.activemq.command.ActiveMQDestination getReplyTo()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination replyTo>;
return v;
}
public void setReplyTo(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination replyTo> = v;
return;
}
public long getTimestamp()
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: long timestamp>;
return v;
}
public void setTimestamp(long)
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: long;
v.<org.apache.activemq.command.Message: long timestamp> = v;
return;
}
public java.lang.String getType()
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.lang.String type>;
return v;
}
public void setType(java.lang.String)
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.Message: java.lang.String type> = v;
return;
}
public org.apache.activemq.util.ByteSequence getContent()
{
org.apache.activemq.command.Message v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content>;
return v;
}
public void setContent(org.apache.activemq.util.ByteSequence)
{
org.apache.activemq.command.Message v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.util.ByteSequence;
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content> = v;
return;
}
public org.apache.activemq.util.ByteSequence getMarshalledProperties()
{
org.apache.activemq.command.Message v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
return v;
}
public void setMarshalledProperties(org.apache.activemq.util.ByteSequence)
{
org.apache.activemq.command.Message v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.util.ByteSequence;
v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties> = v;
return;
}
public org.apache.activemq.command.DataStructure getDataStructure()
{
org.apache.activemq.command.DataStructure v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.DataStructure dataStructure>;
return v;
}
public void setDataStructure(org.apache.activemq.command.DataStructure)
{
org.apache.activemq.command.DataStructure v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.DataStructure;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.DataStructure dataStructure> = v;
return;
}
public org.apache.activemq.command.ConsumerId getTargetConsumerId()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.ConsumerId targetConsumerId>;
return v;
}
public void setTargetConsumerId(org.apache.activemq.command.ConsumerId)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.ConsumerId;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.ConsumerId targetConsumerId> = v;
return;
}
public boolean isExpired()
{
org.apache.activemq.command.Message v;
byte v, v;
long v, v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: long getExpiration()>();
v = v cmp 0L;
if v <= 0 goto label;
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isAdvisory()
{
org.apache.activemq.command.Message v;
java.lang.String v, v;
boolean v, v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.lang.String type>;
if v == null goto label;
v = v.<org.apache.activemq.command.Message: java.lang.String type>;
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("Advisory");
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isCompressed()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean compressed>;
return v;
}
public void setCompressed(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean compressed> = v;
return;
}
public boolean isRedelivered()
{
int v;
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: int redeliveryCounter>;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void setRedelivered(boolean)
{
org.apache.activemq.command.Message v;
boolean v, v, v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isRedelivered()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.command.Message: void setRedeliveryCounter(int)>(1);
goto label;
label:
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isRedelivered()>();
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.command.Message: void setRedeliveryCounter(int)>(0);
label:
return;
}
public void incrementRedeliveryCounter()
{
int v, v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: int redeliveryCounter>;
v = v + 1;
v.<org.apache.activemq.command.Message: int redeliveryCounter> = v;
return;
}
public int getRedeliveryCounter()
{
int v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: int redeliveryCounter>;
return v;
}
public void setRedeliveryCounter(int)
{
int v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: int;
v.<org.apache.activemq.command.Message: int redeliveryCounter> = v;
return;
}
public org.apache.activemq.command.BrokerId[] getBrokerPath()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.BrokerId[] v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.BrokerId[] brokerPath>;
return v;
}
public void setBrokerPath(org.apache.activemq.command.BrokerId[])
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.BrokerId[] v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.BrokerId[];
v.<org.apache.activemq.command.Message: org.apache.activemq.command.BrokerId[] brokerPath> = v;
return;
}
public boolean isReadOnlyProperties()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean readOnlyProperties>;
return v;
}
public void setReadOnlyProperties(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean readOnlyProperties> = v;
return;
}
public boolean isReadOnlyBody()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean readOnlyBody>;
return v;
}
public void setReadOnlyBody(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean readOnlyBody> = v;
return;
}
public org.apache.activemq.ActiveMQConnection getConnection()
{
org.apache.activemq.command.Message v;
org.apache.activemq.ActiveMQConnection v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.ActiveMQConnection connection>;
return v;
}
public void setConnection(org.apache.activemq.ActiveMQConnection)
{
org.apache.activemq.command.Message v;
org.apache.activemq.ActiveMQConnection v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.ActiveMQConnection;
v.<org.apache.activemq.command.Message: org.apache.activemq.ActiveMQConnection connection> = v;
return;
}
public long getArrival()
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: long arrival>;
return v;
}
public void setArrival(long)
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: long;
v.<org.apache.activemq.command.Message: long arrival> = v;
return;
}
public java.lang.String getUserID()
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.lang.String userID>;
return v;
}
public void setUserID(java.lang.String)
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.lang.String;
v.<org.apache.activemq.command.Message: java.lang.String userID> = v;
return;
}
public int getReferenceCount()
{
org.apache.activemq.command.Message v;
short v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: short referenceCount>;
return v;
}
public org.apache.activemq.command.Message getMessageHardRef()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
return v;
}
public org.apache.activemq.command.Message getMessage()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
return v;
}
public void setRegionDestination(org.apache.activemq.command.Message$MessageDestination)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.Message$MessageDestination v;
org.apache.activemq.usage.MemoryUsage v, v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.Message$MessageDestination;
v.<org.apache.activemq.command.Message: org.apache.activemq.command.Message$MessageDestination regionDestination> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage memoryUsage>;
if v != null goto label;
v = interfaceinvoke v.<org.apache.activemq.command.Message$MessageDestination: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage memoryUsage> = v;
label:
return;
}
public org.apache.activemq.command.Message$MessageDestination getRegionDestination()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.Message$MessageDestination v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.Message$MessageDestination regionDestination>;
return v;
}
public org.apache.activemq.usage.MemoryUsage getMemoryUsage()
{
org.apache.activemq.command.Message v;
org.apache.activemq.usage.MemoryUsage v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage memoryUsage>;
return v;
}
public void setMemoryUsage(org.apache.activemq.usage.MemoryUsage)
{
org.apache.activemq.command.Message v;
org.apache.activemq.usage.MemoryUsage v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.usage.MemoryUsage;
v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage memoryUsage> = v;
return;
}
public boolean isMarshallAware()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
return 1;
}
public int incrementReferenceCount()
{
java.lang.Throwable v;
org.apache.activemq.command.Message v;
short v;
int v, v;
org.apache.activemq.usage.MemoryUsage v, v;
v := @this: org.apache.activemq.command.Message;
entermonitor v;
label:
v = v.<org.apache.activemq.command.Message: short referenceCount>;
v = v + 1;
v.<org.apache.activemq.command.Message: short referenceCount> = v;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getSize()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v != 1 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void increaseUsage(long)>(v);
label:
return v;
catch java.lang.Throwable from label to label with label;
}
public int decrementReferenceCount()
{
java.lang.Throwable v;
org.apache.activemq.command.Message v;
short v;
int v, v;
org.apache.activemq.usage.MemoryUsage v, v;
v := @this: org.apache.activemq.command.Message;
entermonitor v;
label:
v = v.<org.apache.activemq.command.Message: short referenceCount>;
v = v - 1;
v.<org.apache.activemq.command.Message: short referenceCount> = v;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getSize()>();
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.usage.MemoryUsage getMemoryUsage()>();
virtualinvoke v.<org.apache.activemq.usage.MemoryUsage: void decreaseUsage(long)>(v);
label:
return v;
catch java.lang.Throwable from label to label with label;
}
public int getSize()
{
org.apache.activemq.command.Message v;
int v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.util.ByteSequence v, v, v, v;
v := @this: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: int getMinimumMessageSize()>();
v = v.<org.apache.activemq.command.Message: int size>;
if v < v goto label;
v = v.<org.apache.activemq.command.Message: int size>;
if v != 0 goto label;
label:
v.<org.apache.activemq.command.Message: int size> = v;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
if v == null goto label;
v = v.<org.apache.activemq.command.Message: int size>;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence marshalledProperties>;
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: int getLength()>();
v = v + v;
v.<org.apache.activemq.command.Message: int size> = v;
label:
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content>;
if v == null goto label;
v = v.<org.apache.activemq.command.Message: int size>;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence content>;
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: int getLength()>();
v = v + v;
v.<org.apache.activemq.command.Message: int size> = v;
label:
v = v.<org.apache.activemq.command.Message: int size>;
return v;
}
protected int getMinimumMessageSize()
{
int v;
org.apache.activemq.command.Message v;
org.apache.activemq.command.Message$MessageDestination v;
v := @this: org.apache.activemq.command.Message;
v = 1024;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.Message$MessageDestination regionDestination>;
if v == null goto label;
v = interfaceinvoke v.<org.apache.activemq.command.Message$MessageDestination: int getMinimumMessageSize()>();
label:
return v;
}
public boolean isRecievedByDFBridge()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean recievedByDFBridge>;
return v;
}
public void setRecievedByDFBridge(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean recievedByDFBridge> = v;
return;
}
public void onMessageRolledBack()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
virtualinvoke v.<org.apache.activemq.command.Message: void incrementRedeliveryCounter()>();
return;
}
public boolean isDroppable()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean droppable>;
return v;
}
public void setDroppable(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean droppable> = v;
return;
}
public org.apache.activemq.command.BrokerId[] getCluster()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.BrokerId[] v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: org.apache.activemq.command.BrokerId[] cluster>;
return v;
}
public void setCluster(org.apache.activemq.command.BrokerId[])
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.BrokerId[] v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: org.apache.activemq.command.BrokerId[];
v.<org.apache.activemq.command.Message: org.apache.activemq.command.BrokerId[] cluster> = v;
return;
}
public boolean isMessage()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
return 1;
}
public long getBrokerInTime()
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: long brokerInTime>;
return v;
}
public void setBrokerInTime(long)
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: long;
v.<org.apache.activemq.command.Message: long brokerInTime> = v;
return;
}
public long getBrokerOutTime()
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: long brokerOutTime>;
return v;
}
public void setBrokerOutTime(long)
{
long v;
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: long;
v.<org.apache.activemq.command.Message: long brokerOutTime> = v;
return;
}
public boolean isDropped()
{
org.apache.activemq.command.Message v;
v := @this: org.apache.activemq.command.Message;
return 0;
}
public boolean isJMSXGroupFirstForConsumer()
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: boolean jmsXGroupFirstForConsumer>;
return v;
}
public void setJMSXGroupFirstForConsumer(boolean)
{
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: boolean;
v.<org.apache.activemq.command.Message: boolean jmsXGroupFirstForConsumer> = v;
return;
}
public void compress() throws java.io.IOException
{
org.apache.activemq.command.Message v;
org.apache.activemq.util.ByteSequence v;
boolean v, v;
v := @this: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isCompressed()>();
if v != 0 goto label;
virtualinvoke v.<org.apache.activemq.command.Message: void storeContent()>();
v = virtualinvoke v.<org.apache.activemq.command.Message: boolean isCompressed()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence getContent()>();
if v == null goto label;
virtualinvoke v.<org.apache.activemq.command.Message: void doCompress()>();
label:
return;
}
protected void doCompress() throws java.io.IOException
{
org.apache.activemq.util.ByteArrayOutputStream v;
byte[] v;
java.util.zip.DeflaterOutputStream v;
org.apache.activemq.command.Message v;
int v, v;
org.apache.activemq.util.ByteSequence v, v;
v := @this: org.apache.activemq.command.Message;
v.<org.apache.activemq.command.Message: boolean compressed> = 1;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.util.ByteSequence getContent()>();
v = new org.apache.activemq.util.ByteArrayOutputStream;
specialinvoke v.<org.apache.activemq.util.ByteArrayOutputStream: void <init>()>();
v = new java.util.zip.DeflaterOutputStream;
specialinvoke v.<java.util.zip.DeflaterOutputStream: void <init>(java.io.OutputStream)>(v);
v = v.<org.apache.activemq.util.ByteSequence: byte[] data>;
v = v.<org.apache.activemq.util.ByteSequence: int offset>;
v = v.<org.apache.activemq.util.ByteSequence: int length>;
virtualinvoke v.<java.io.OutputStream: void write(byte[],int,int)>(v, v, v);
virtualinvoke v.<java.io.OutputStream: void close()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteArrayOutputStream: org.apache.activemq.util.ByteSequence toByteSequence()>();
virtualinvoke v.<org.apache.activemq.command.Message: void setContent(org.apache.activemq.util.ByteSequence)>(v);
return;
}
public java.lang.String toString()
{
org.apache.activemq.command.Message v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v = virtualinvoke v.<org.apache.activemq.command.Message: java.lang.String toString(java.util.Map)>(null);
return v;
}
public java.lang.String toString(java.util.Map)
{
org.apache.activemq.command.Message v;
java.util.Map v;
java.io.IOException v;
java.lang.String v;
v := @this: org.apache.activemq.command.Message;
v := @parameter: java.util.Map;
label:
virtualinvoke v.<org.apache.activemq.command.Message: java.util.Map getProperties()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = specialinvoke v.<org.apache.activemq.command.BaseCommand: java.lang.String toString(java.util.Map)>(v);
return v;
catch java.io.IOException from label to label with label;
}
public boolean canProcessAsExpired()
{
java.util.concurrent.atomic.AtomicBoolean v;
org.apache.activemq.command.Message v;
boolean v;
v := @this: org.apache.activemq.command.Message;
v = v.<org.apache.activemq.command.Message: java.util.concurrent.atomic.AtomicBoolean processAsExpired>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean compareAndSet(boolean,boolean)>(0, 1);
return v;
}
}