|
||||||||||
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
org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor
public class StoreDurableSubscriberCursor
perist pending messages pending message (messages awaiting disptach to a consumer) cursor
Field Summary |
---|
Fields inherited from class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor |
---|
maxBatchSize |
Constructor Summary | |
---|---|
StoreDurableSubscriberCursor(String clientId,
String subscriberName,
Store store,
int maxBatchSize)
|
Method Summary | |
---|---|
void |
add(ConnectionContext context,
Destination destination)
Add a destination |
void |
addMessageLast(MessageReference node)
add message to await dispatch |
void |
clear()
clear all pending messages |
protected PendingMessageCursor |
getNextCursor()
|
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 |
int |
size()
|
void |
start()
|
void |
stop()
|
Methods inherited from class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor |
---|
addMessageFirst, fillBatch, getMaxBatchSize, resetForGC, setMaxBatchSize |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public StoreDurableSubscriberCursor(String clientId, String subscriberName, Store store, int maxBatchSize)
topic
- clientId
- subscriberName
-
IOException
Method Detail |
---|
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 add(ConnectionContext context, Destination destination) throws Exception
add
in interface PendingMessageCursor
add
in class AbstractPendingMessageCursor
context
- destination
-
Exception
public void remove(ConnectionContext context, Destination destination) throws Exception
remove
in interface PendingMessageCursor
remove
in class AbstractPendingMessageCursor
context
- destination
-
Exception
public boolean isEmpty()
isEmpty
in interface PendingMessageCursor
isEmpty
in class AbstractPendingMessageCursor
public boolean isRecoveryRequired()
isRecoveryRequired
in interface PendingMessageCursor
isRecoveryRequired
in class AbstractPendingMessageCursor
org.apache.activemq.region.cursors.PendingMessageCursor
public void addMessageLast(MessageReference node) throws Exception
PendingMessageCursor
addMessageLast
in interface PendingMessageCursor
addMessageLast
in class AbstractPendingMessageCursor
IOException
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 reset()
PendingMessageCursor
reset
in interface PendingMessageCursor
reset
in class AbstractPendingMessageCursor
public int size()
size
in interface PendingMessageCursor
size
in class AbstractPendingMessageCursor
protected PendingMessageCursor getNextCursor() throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |