public class org.apache.activemq.command.MessageAck extends org.apache.activemq.command.BaseCommand
{
public static final byte DATA_STRUCTURE_TYPE;
public static final byte DELIVERED_ACK_TYPE;
public static final byte STANDARD_ACK_TYPE;
public static final byte POISON_ACK_TYPE;
public static final byte REDELIVERED_ACK_TYPE;
public static final byte INDIVIDUAL_ACK_TYPE;
public static final byte UNMATCHED_ACK_TYPE;
public static final byte EXPIRED_ACK_TYPE;
protected byte ackType;
protected org.apache.activemq.command.ConsumerId consumerId;
protected org.apache.activemq.command.MessageId firstMessageId;
protected org.apache.activemq.command.MessageId lastMessageId;
protected org.apache.activemq.command.ActiveMQDestination destination;
protected org.apache.activemq.command.TransactionId transactionId;
protected int messageCount;
protected java.lang.Throwable poisonCause;
protected transient java.lang.String consumerKey;
public void <init>()
{
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void <init>()>();
return;
}
public void <init>(org.apache.activemq.command.MessageDispatch, byte, int)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.command.ActiveMQDestination v;
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageDispatch v;
byte v;
int v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.MessageDispatch;
v := @parameter: byte;
v := @parameter: int;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void <init>()>();
v.<org.apache.activemq.command.MessageAck: byte ackType> = v;
v = virtualinvoke v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.ConsumerId getConsumerId()>();
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ConsumerId consumerId> = v;
v = virtualinvoke v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ActiveMQDestination destination> = v;
v = virtualinvoke v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.Message getMessage()>();
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId getMessageId()>();
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId lastMessageId> = v;
v.<org.apache.activemq.command.MessageAck: int messageCount> = v;
return;
}
public void <init>(org.apache.activemq.command.Message, byte, int)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageAck v;
byte v;
org.apache.activemq.command.MessageId v;
int v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.Message;
v := @parameter: byte;
v := @parameter: int;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void <init>()>();
v.<org.apache.activemq.command.MessageAck: byte ackType> = v;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.ActiveMQDestination getDestination()>();
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ActiveMQDestination destination> = v;
v = virtualinvoke v.<org.apache.activemq.command.Message: org.apache.activemq.command.MessageId getMessageId()>();
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId lastMessageId> = v;
v.<org.apache.activemq.command.MessageAck: int messageCount> = v;
return;
}
public void copy(org.apache.activemq.command.MessageAck)
{
org.apache.activemq.command.MessageAck v, v;
org.apache.activemq.command.MessageId v, v;
org.apache.activemq.command.ConsumerId v;
org.apache.activemq.command.ActiveMQDestination v;
byte v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.MessageAck;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void copy(org.apache.activemq.command.BaseCommand)>(v);
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId firstMessageId>;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId firstMessageId> = v;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId lastMessageId>;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId lastMessageId> = v;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ActiveMQDestination destination>;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ActiveMQDestination destination> = v;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId transactionId>;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId transactionId> = v;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
v.<org.apache.activemq.command.MessageAck: byte ackType> = v;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ConsumerId consumerId>;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ConsumerId consumerId> = v;
return;
}
public byte getDataStructureType()
{
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
return 22;
}
public boolean isMessageAck()
{
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
return 1;
}
public boolean isPoisonAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isStandardAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 2 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isDeliveredAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isRedeliveredAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 3 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isIndividualAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 4 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isUnmatchedAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 5 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isExpiredAck()
{
org.apache.activemq.command.MessageAck v;
byte v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
if v != 6 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public org.apache.activemq.command.ActiveMQDestination getDestination()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ActiveMQDestination destination>;
return v;
}
public void setDestination(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ActiveMQDestination destination> = v;
return;
}
public org.apache.activemq.command.TransactionId getTransactionId()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId transactionId>;
return v;
}
public void setTransactionId(org.apache.activemq.command.TransactionId)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.TransactionId;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.TransactionId transactionId> = v;
return;
}
public boolean isInTransaction()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.TransactionId v;
boolean v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: 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.ConsumerId getConsumerId()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ConsumerId consumerId>;
return v;
}
public void setConsumerId(org.apache.activemq.command.ConsumerId)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.ConsumerId;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.ConsumerId consumerId> = v;
return;
}
public byte getAckType()
{
org.apache.activemq.command.MessageAck v;
byte v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: byte ackType>;
return v;
}
public void setAckType(byte)
{
org.apache.activemq.command.MessageAck v;
byte v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: byte;
v.<org.apache.activemq.command.MessageAck: byte ackType> = v;
return;
}
public org.apache.activemq.command.MessageId getFirstMessageId()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId firstMessageId>;
return v;
}
public void setFirstMessageId(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.MessageId;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId firstMessageId> = v;
return;
}
public org.apache.activemq.command.MessageId getLastMessageId()
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId lastMessageId>;
return v;
}
public void setLastMessageId(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.MessageId;
v.<org.apache.activemq.command.MessageAck: org.apache.activemq.command.MessageId lastMessageId> = v;
return;
}
public int getMessageCount()
{
int v;
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: int messageCount>;
return v;
}
public void setMessageCount(int)
{
int v;
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: int;
v.<org.apache.activemq.command.MessageAck: int messageCount> = v;
return;
}
public java.lang.Throwable getPoisonCause()
{
java.lang.Throwable v;
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
v = v.<org.apache.activemq.command.MessageAck: java.lang.Throwable poisonCause>;
return v;
}
public void setPoisonCause(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: java.lang.Throwable;
v.<org.apache.activemq.command.MessageAck: java.lang.Throwable poisonCause> = v;
return;
}
public org.apache.activemq.command.Response visit(org.apache.activemq.state.CommandVisitor) throws java.lang.Exception
{
org.apache.activemq.command.Response v;
org.apache.activemq.command.MessageAck v;
org.apache.activemq.state.CommandVisitor v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.state.CommandVisitor;
v = interfaceinvoke v.<org.apache.activemq.state.CommandVisitor: org.apache.activemq.command.Response processMessageAck(org.apache.activemq.command.MessageAck)>(v);
return v;
}
public void setMessageID(org.apache.activemq.command.MessageId)
{
org.apache.activemq.command.MessageAck v;
org.apache.activemq.command.MessageId v;
v := @this: org.apache.activemq.command.MessageAck;
v := @parameter: org.apache.activemq.command.MessageId;
virtualinvoke v.<org.apache.activemq.command.MessageAck: void setFirstMessageId(org.apache.activemq.command.MessageId)>(v);
virtualinvoke v.<org.apache.activemq.command.MessageAck: void setLastMessageId(org.apache.activemq.command.MessageId)>(v);
virtualinvoke v.<org.apache.activemq.command.MessageAck: void setMessageCount(int)>(1);
return;
}
}