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.

Field Summary

Fields

Modifier and Type	Field and Description
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

Modifier and Type	Method and Description
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)