public final class ComposFmlTcb extends tcb
Modifier and Type | Field and Description |
---|---|
private TypedFML |
mybuf |
private static int |
TPQBEFOREMSGID |
private static int |
TPQCORRID |
private static int |
TPQDELIVERYQOS |
private static int |
TPQEXPTIME_ABS |
private static int |
TPQEXPTIME_NONE |
private static int |
TPQEXPTIME_REL |
private static int |
TPQFAILUREQ |
private static int |
TPQGETBYCORRID |
private static int |
TPQGETBYCORRIDOLD |
private static int |
TPQGETBYMSGID |
private static int |
TPQGETBYMSGIDOLD |
private static int |
TPQMSGID |
private static int |
TPQPEEK |
private static int |
TPQPRIORITY |
private static int |
TPQREPLYQ |
private static int |
TPQREPLYQOS |
private static int |
TPQTIME_ABS |
private static int |
TPQTIME_REL |
private static int |
TPQTOP |
private static int |
TPQWAIT |
Constructor and Description |
---|
ComposFmlTcb() |
ComposFmlTcb(java.lang.String qname,
byte[] msgid,
byte[] corrid,
boolean doWait,
boolean doPeek) |
ComposFmlTcb(java.lang.String qname,
EnqueueRequest ctl) |
Modifier and Type | Method and Description |
---|---|
int |
_tmpostrecv(java.io.DataInputStream decoder,
int recv_size,
int hint_index) |
int |
_tmpostrecv65(java.io.DataInputStream decoder) |
void |
_tmpresend(java.io.DataOutputStream encoder,
tch myheader) |
protected void |
_tmpresend65(java.io.DataOutputStream encoder) |
byte[] |
getCoorid() |
int |
getDeliveryQualityOfService() |
java.lang.Integer |
getDiagnostic() |
java.lang.String |
getFailureQueue() |
byte[] |
getMsgid() |
java.lang.Integer |
getPriority() |
int |
getR65size() |
int |
getReplyQualityOfService() |
java.lang.String |
getReplyQueue() |
boolean |
prepareForCache() |
private TypedFML mybuf
private static final int TPQCORRID
private static final int TPQFAILUREQ
private static final int TPQBEFOREMSGID
private static final int TPQGETBYMSGIDOLD
private static final int TPQMSGID
private static final int TPQPRIORITY
private static final int TPQTOP
private static final int TPQWAIT
private static final int TPQREPLYQ
private static final int TPQTIME_ABS
private static final int TPQTIME_REL
private static final int TPQGETBYCORRIDOLD
private static final int TPQPEEK
private static final int TPQDELIVERYQOS
private static final int TPQREPLYQOS
private static final int TPQEXPTIME_ABS
private static final int TPQEXPTIME_REL
private static final int TPQEXPTIME_NONE
private static final int TPQGETBYMSGID
private static final int TPQGETBYCORRID
public ComposFmlTcb()
public ComposFmlTcb(java.lang.String qname, EnqueueRequest ctl) throws TPException
TPException
public ComposFmlTcb(java.lang.String qname, byte[] msgid, byte[] corrid, boolean doWait, boolean doPeek) throws TPException
TPException
public byte[] getMsgid()
public byte[] getCoorid()
public java.lang.String getReplyQueue()
public java.lang.String getFailureQueue()
public java.lang.Integer getPriority()
public int getDeliveryQualityOfService()
public int getReplyQualityOfService()
public java.lang.Integer getDiagnostic()
public int getR65size()
public boolean prepareForCache()
prepareForCache
in class tcb
public void _tmpresend(java.io.DataOutputStream encoder, tch myheader) throws TPException, java.io.IOException
_tmpresend
in class tcb
encoder
- The stream object to use to encode this TCBTPException
- If there was a Tuxedo error while encodingjava.io.IOException
- if there was an error using the encoderpublic int _tmpostrecv(java.io.DataInputStream decoder, int recv_size, int hint_index) throws java.io.IOException
_tmpostrecv
in class tcb
decoder
- The input stream pointing to the start of the TCBrecv_size
- The total size of this TCB, unpaddedjava.io.IOException
- if there was an error reading the input stream
protected void _tmpresend65(java.io.DataOutputStream encoder) throws java.io.IOException
encoder
- The object to encode this FML buffer tojava.io.IOException
public int _tmpostrecv65(java.io.DataInputStream decoder) throws java.io.IOException
decoder
- The stream to decode fromjava.io.IOException
- if there is an error reading from the stream