|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
public class AbstractPendingMessageCursor
Abstract method holder for pending message (messages awaiting disptach to a consumer) cursor
Field Summary | |
---|---|
protected int |
maxBatchSize
|
Constructor Summary | |
---|---|
AbstractPendingMessageCursor()
|
Method Summary | |
---|---|
void |
add(ConnectionContext context,
Destination destination)
Add a destination |
void |
addMessageFirst(MessageReference node)
add message to await dispatch |
void |
addMessageLast(MessageReference node)
add message to await dispatch |
void |
clear()
clear all pending messages |
protected void |
fillBatch()
|
int |
getMaxBatchSize()
|
boolean |
hasNext()
|
boolean |
isEmpty()
|
boolean |
isRecoveryRequired()
Informs the Broker if the subscription needs to intervention to recover it's state e.g. |
MessageReference |
next()
|
void |
remove()
remove the message at the cursor position |
void |
remove(ConnectionContext context,
Destination destination)
remove a destination |
void |
reset()
reset the cursor |
void |
resetForGC()
Give the cursor a hint that we are about to remove messages from memory only |
void |
setMaxBatchSize(int maxBatchSize)
Set the max batch size |
int |
size()
|
void |
start()
|
void |
stop()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected int maxBatchSize
Constructor Detail |
---|
public AbstractPendingMessageCursor()
Method Detail |
---|
public void start() throws java.lang.Exception
start
in interface Service
java.lang.Exception
public void stop() throws java.lang.Exception
stop
in interface Service
java.lang.Exception
public void add(ConnectionContext context, Destination destination) throws java.lang.Exception
PendingMessageCursor
add
in interface PendingMessageCursor
java.lang.Exception
public void remove(ConnectionContext context, Destination destination) throws java.lang.Exception
PendingMessageCursor
remove
in interface PendingMessageCursor
java.lang.Exception
public boolean isRecoveryRequired()
PendingMessageCursor
isRecoveryRequired
in interface PendingMessageCursor
public void addMessageFirst(MessageReference node) throws java.lang.Exception
PendingMessageCursor
addMessageFirst
in interface PendingMessageCursor
java.lang.Exception
public void addMessageLast(MessageReference node) throws java.lang.Exception
PendingMessageCursor
addMessageLast
in interface PendingMessageCursor
java.io.IOException
java.lang.Exception
public void clear()
PendingMessageCursor
clear
in interface PendingMessageCursor
public boolean hasNext()
hasNext
in interface PendingMessageCursor
public boolean isEmpty()
isEmpty
in interface PendingMessageCursor
public MessageReference next()
next
in interface PendingMessageCursor
public void remove()
PendingMessageCursor
remove
in interface PendingMessageCursor
public void reset()
PendingMessageCursor
reset
in interface PendingMessageCursor
public int size()
size
in interface PendingMessageCursor
public int getMaxBatchSize()
getMaxBatchSize
in interface PendingMessageCursor
public void setMaxBatchSize(int maxBatchSize)
PendingMessageCursor
setMaxBatchSize
in interface PendingMessageCursor
protected void fillBatch() throws java.lang.Exception
java.lang.Exception
public void resetForGC()
resetForGC
in interface PendingMessageCursor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |