com.caucho.message.nautilus
Class NautilusRingItem
java.lang.Object
com.caucho.util.RingItem
com.caucho.message.journal.JournalRingItem
com.caucho.message.nautilus.NautilusRingItem
public class NautilusRingItem
- extends JournalRingItem
Interface for the transaction log.
MQueueJournal is not thread safe. It is intended to be used by a
single thread.
Method Summary |
void |
clear()
|
int |
getCredit()
|
long |
getDeliveryCount()
|
NautilusBrokerSubscriber |
getSubscriber()
|
void |
initAck(long xid,
long qid,
long mid,
NautilusBrokerSubscriber sub)
|
void |
initFlow(long qid,
NautilusBrokerSubscriber subscriber,
long deliveryCount,
int credit)
|
void |
initMessage(long xid,
long qid,
long mid,
boolean isDurable,
int priority,
long expireTime,
byte[] buffer,
int offset,
int length,
TempBuffer tBuf)
|
void |
initSubscribe(long qid,
NautilusBrokerSubscriber subscriber)
|
void |
initUnsubscribe(long qid,
NautilusBrokerSubscriber subscriber)
|
Methods inherited from class com.caucho.message.journal.JournalRingItem |
freeTempBuffer, getBlockAddr, getBuffer, getCode, getLength, getMid, getOffset, getQid, getResult, getXid, init, init, initCheckpoint, isData, isFin, isInit, setCode, toString |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
JE_CHECKPOINT
public static final int JE_CHECKPOINT
- See Also:
- Constant Field Values
JE_MESSAGE
public static final int JE_MESSAGE
- See Also:
- Constant Field Values
JE_FLOW
public static final int JE_FLOW
- See Also:
- Constant Field Values
JE_SUBSCRIBE
public static final int JE_SUBSCRIBE
- See Also:
- Constant Field Values
JE_UNSUBSCRIBE
public static final int JE_UNSUBSCRIBE
- See Also:
- Constant Field Values
JE_ACCEPTED
public static final int JE_ACCEPTED
- See Also:
- Constant Field Values
initAck
public void initAck(long xid,
long qid,
long mid,
NautilusBrokerSubscriber sub)
initSubscribe
public void initSubscribe(long qid,
NautilusBrokerSubscriber subscriber)
initUnsubscribe
public void initUnsubscribe(long qid,
NautilusBrokerSubscriber subscriber)
initFlow
public void initFlow(long qid,
NautilusBrokerSubscriber subscriber,
long deliveryCount,
int credit)
getSubscriber
public NautilusBrokerSubscriber getSubscriber()
getDeliveryCount
public long getDeliveryCount()
getCredit
public int getCredit()
clear
public void clear()
initMessage
public void initMessage(long xid,
long qid,
long mid,
boolean isDurable,
int priority,
long expireTime,
byte[] buffer,
int offset,
int length,
TempBuffer tBuf)