public class org.apache.activemq.command.MessageDispatch extends org.apache.activemq.command.BaseCommand
{
public static final byte DATA_STRUCTURE_TYPE;
protected org.apache.activemq.command.ConsumerId consumerId;
protected org.apache.activemq.command.ActiveMQDestination destination;
protected org.apache.activemq.command.Message message;
protected int redeliveryCounter;
protected transient long deliverySequenceId;
protected transient java.lang.Object consumer;
protected transient org.apache.activemq.transport.TransmitCallback transmitCallback;
protected transient java.lang.Throwable rollbackCause;
public void <init>()
{
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
specialinvoke v.<org.apache.activemq.command.BaseCommand: void <init>()>();
return;
}
public byte getDataStructureType()
{
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
return 21;
}
public boolean isMessageDispatch()
{
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
return 1;
}
public org.apache.activemq.command.ConsumerId getConsumerId()
{
org.apache.activemq.command.MessageDispatch v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.ConsumerId consumerId>;
return v;
}
public void setConsumerId(org.apache.activemq.command.ConsumerId)
{
org.apache.activemq.command.MessageDispatch v;
org.apache.activemq.command.ConsumerId v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: org.apache.activemq.command.ConsumerId;
v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.ConsumerId consumerId> = v;
return;
}
public org.apache.activemq.command.ActiveMQDestination getDestination()
{
org.apache.activemq.command.MessageDispatch v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.ActiveMQDestination destination>;
return v;
}
public void setDestination(org.apache.activemq.command.ActiveMQDestination)
{
org.apache.activemq.command.MessageDispatch v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.ActiveMQDestination destination> = v;
return;
}
public org.apache.activemq.command.Message getMessage()
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.Message message>;
return v;
}
public void setMessage(org.apache.activemq.command.Message)
{
org.apache.activemq.command.Message v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: org.apache.activemq.command.Message;
v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.command.Message message> = v;
return;
}
public long getDeliverySequenceId()
{
long v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: long deliverySequenceId>;
return v;
}
public void setDeliverySequenceId(long)
{
long v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: long;
v.<org.apache.activemq.command.MessageDispatch: long deliverySequenceId> = v;
return;
}
public int getRedeliveryCounter()
{
int v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: int redeliveryCounter>;
return v;
}
public void setRedeliveryCounter(int)
{
int v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: int;
v.<org.apache.activemq.command.MessageDispatch: int redeliveryCounter> = v;
return;
}
public java.lang.Object getConsumer()
{
java.lang.Object v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: java.lang.Object consumer>;
return v;
}
public void setConsumer(java.lang.Object)
{
java.lang.Object v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: java.lang.Object;
v.<org.apache.activemq.command.MessageDispatch: java.lang.Object consumer> = 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.MessageDispatch v;
org.apache.activemq.state.CommandVisitor v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: org.apache.activemq.state.CommandVisitor;
v = interfaceinvoke v.<org.apache.activemq.state.CommandVisitor: org.apache.activemq.command.Response processMessageDispatch(org.apache.activemq.command.MessageDispatch)>(v);
return v;
}
public org.apache.activemq.transport.TransmitCallback getTransmitCallback()
{
org.apache.activemq.transport.TransmitCallback v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.transport.TransmitCallback transmitCallback>;
return v;
}
public void setTransmitCallback(org.apache.activemq.transport.TransmitCallback)
{
org.apache.activemq.transport.TransmitCallback v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: org.apache.activemq.transport.TransmitCallback;
v.<org.apache.activemq.command.MessageDispatch: org.apache.activemq.transport.TransmitCallback transmitCallback> = v;
return;
}
public java.lang.Throwable getRollbackCause()
{
java.lang.Throwable v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v = v.<org.apache.activemq.command.MessageDispatch: java.lang.Throwable rollbackCause>;
return v;
}
public void setRollbackCause(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.command.MessageDispatch;
v := @parameter: java.lang.Throwable;
v.<org.apache.activemq.command.MessageDispatch: java.lang.Throwable rollbackCause> = v;
return;
}
}