com.caucho.message.nautilus
Class NautilusRingItem

java.lang.Object
  extended by com.caucho.util.RingItem
      extended by com.caucho.message.journal.JournalRingItem
          extended by 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.


Field Summary
static int JE_ACCEPTED
           
static int JE_CHECKPOINT
           
static int JE_FLOW
           
static int JE_MESSAGE
           
static int JE_SUBSCRIBE
           
static int JE_UNSUBSCRIBE
           
 
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 com.caucho.util.RingItem
clearRingValue, getIndex, getRingValue, isRingValue, nextRingValue, setRingValue
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

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
Method Detail

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)