public class StoreQueueCursor extends AbstractPendingMessageCursor
audit, enableAudit, last, maxAuditDepth, maxBatchSize, maxProducersToAudit, memoryUsageHighWaterMark, prioritizedMessages, systemUsage, useCache
Constructor and Description |
---|
StoreQueueCursor(Broker broker,
Queue queue)
Construct
|
Modifier and Type | Method and Description |
---|---|
void |
addMessageFirst(MessageReference node)
add message to await dispatch
|
void |
addMessageLast(MessageReference node)
add message to await dispatch
|
void |
clear()
clear all pending messages
|
void |
gc()
free up any internal buffers
|
protected PendingMessageCursor |
getNextCursor() |
PendingMessageCursor |
getNonPersistent() |
boolean |
hasNext() |
boolean |
isCacheEnabled() |
boolean |
isEmpty() |
boolean |
isRecoveryRequired()
Informs the Broker if the subscription needs to intervention to recover
it's state e.g.
|
MessageReference |
next() |
void |
release()
hint to the cursor to release any locks it might have grabbed after a
reset
|
void |
remove()
remove the message at the cursor position
|
void |
remove(MessageReference node)
remove a node
|
void |
reset()
reset the cursor
|
void |
setEnableAudit(boolean enableAudit) |
void |
setMaxAuditDepth(int maxAuditDepth)
Set the maximum depth of message ids to track
|
void |
setMaxBatchSize(int maxBatchSize)
Set the max batch size
|
void |
setMaxProducersToAudit(int maxProducersToAudit)
set the maximum number of producers to track at one time
|
void |
setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark) |
void |
setNonPersistent(PendingMessageCursor nonPersistent) |
void |
setSystemUsage(SystemUsage usageManager)
Set the UsageManager
|
void |
setUseCache(boolean useCache)
use a cache to improve performance
|
int |
size() |
void |
start() |
void |
stop() |
add, addRecoveredMessage, destroy, fillBatch, getMaxAuditDepth, getMaxBatchSize, getMaxProducersToAudit, getMemoryUsageHighWaterMark, getMessageAudit, getSystemUsage, hasMessagesBufferedToDeliver, hasSpace, isDuplicate, isEmpty, isEnableAudit, isFull, isPrioritizedMessageSubscriber, isStarted, isTransient, isUseCache, pageInList, recordUniqueId, remove, resetForGC, rollback, setCacheEnabled, setMessageAudit, tryAddMessageLast
public StoreQueueCursor(Broker broker, Queue queue)
broker
- queue
- public void start() throws Exception
start
in interface Service
start
in class AbstractPendingMessageCursor
Exception
public void stop() throws Exception
stop
in interface Service
stop
in class AbstractPendingMessageCursor
Exception
public void addMessageLast(MessageReference node) throws Exception
PendingMessageCursor
addMessageLast
in interface PendingMessageCursor
addMessageLast
in class AbstractPendingMessageCursor
IOException
Exception
public void addMessageFirst(MessageReference node) throws Exception
PendingMessageCursor
addMessageFirst
in interface PendingMessageCursor
addMessageFirst
in class AbstractPendingMessageCursor
Exception
public void clear()
PendingMessageCursor
clear
in interface PendingMessageCursor
clear
in class AbstractPendingMessageCursor
public boolean hasNext()
hasNext
in interface PendingMessageCursor
hasNext
in class AbstractPendingMessageCursor
public MessageReference next()
next
in interface PendingMessageCursor
next
in class AbstractPendingMessageCursor
public void remove()
PendingMessageCursor
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
public void remove(MessageReference node)
PendingMessageCursor
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
public void reset()
PendingMessageCursor
reset
in interface PendingMessageCursor
reset
in class AbstractPendingMessageCursor
public void release()
PendingMessageCursor
release
in interface PendingMessageCursor
release
in class AbstractPendingMessageCursor
public int size()
size
in interface PendingMessageCursor
size
in class AbstractPendingMessageCursor
public boolean isEmpty()
isEmpty
in interface PendingMessageCursor
isEmpty
in class AbstractPendingMessageCursor
public boolean isRecoveryRequired()
isRecoveryRequired
in interface PendingMessageCursor
isRecoveryRequired
in class AbstractPendingMessageCursor
PendingMessageCursor
public PendingMessageCursor getNonPersistent()
public void setNonPersistent(PendingMessageCursor nonPersistent)
nonPersistent
- cursor to setpublic void setMaxBatchSize(int maxBatchSize)
PendingMessageCursor
setMaxBatchSize
in interface PendingMessageCursor
setMaxBatchSize
in class AbstractPendingMessageCursor
public void setMaxProducersToAudit(int maxProducersToAudit)
PendingMessageCursor
setMaxProducersToAudit
in interface PendingMessageCursor
setMaxProducersToAudit
in class AbstractPendingMessageCursor
maxProducersToAudit
- the maxProducersToAudit to setpublic void setMaxAuditDepth(int maxAuditDepth)
PendingMessageCursor
setMaxAuditDepth
in interface PendingMessageCursor
setMaxAuditDepth
in class AbstractPendingMessageCursor
maxAuditDepth
- the maxAuditDepth to setpublic void setEnableAudit(boolean enableAudit)
setEnableAudit
in interface PendingMessageCursor
setEnableAudit
in class AbstractPendingMessageCursor
enableAudit
- the enableAudit to setpublic void setUseCache(boolean useCache)
PendingMessageCursor
setUseCache
in interface PendingMessageCursor
setUseCache
in class AbstractPendingMessageCursor
public void setMemoryUsageHighWaterMark(int memoryUsageHighWaterMark)
setMemoryUsageHighWaterMark
in interface PendingMessageCursor
setMemoryUsageHighWaterMark
in class AbstractPendingMessageCursor
memoryUsageHighWaterMark
- the memoryUsageHighWaterMark to setpublic void gc()
PendingMessageCursor
gc
in interface PendingMessageCursor
gc
in class AbstractPendingMessageCursor
public void setSystemUsage(SystemUsage usageManager)
PendingMessageCursor
setSystemUsage
in interface PendingMessageCursor
setSystemUsage
in class AbstractPendingMessageCursor
SystemUsage
protected PendingMessageCursor getNextCursor() throws Exception
Exception
public boolean isCacheEnabled()
isCacheEnabled
in interface PendingMessageCursor
isCacheEnabled
in class AbstractPendingMessageCursor
Copyright © 2005–2017. All rights reserved.