|
||||||||||
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 Exception
start
in interface Service
Exception
public void stop() throws Exception
stop
in interface Service
Exception
public void add(ConnectionContext context, Destination destination) throws Exception
PendingMessageCursor
add
in interface PendingMessageCursor
Exception
public void remove(ConnectionContext context, Destination destination) throws Exception
PendingMessageCursor
remove
in interface PendingMessageCursor
Exception
public boolean isRecoveryRequired()
PendingMessageCursor
isRecoveryRequired
in interface PendingMessageCursor
public void addMessageFirst(MessageReference node) throws Exception
PendingMessageCursor
addMessageFirst
in interface PendingMessageCursor
Exception
public void addMessageLast(MessageReference node) throws Exception
PendingMessageCursor
addMessageLast
in interface PendingMessageCursor
IOException
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 Exception
Exception
public void resetForGC()
resetForGC
in interface PendingMessageCursor
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |