Class FilePendingQueueMessageStoragePolicy
- java.lang.Object
-
- org.apache.activemq.broker.region.policy.FilePendingQueueMessageStoragePolicy
-
- All Implemented Interfaces:
PendingQueueMessageStoragePolicy
public class FilePendingQueueMessageStoragePolicy extends Object implements PendingQueueMessageStoragePolicy
Creates a FilePendingMessageCursor *
-
-
Constructor Summary
Constructors Constructor Description FilePendingQueueMessageStoragePolicy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description PendingMessageCursorgetQueuePendingMessageCursor(Broker broker, Queue queue)Retrieve the configured pending message storage cursor;
-
-
-
Method Detail
-
getQueuePendingMessageCursor
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker, Queue queue)
Description copied from interface:PendingQueueMessageStoragePolicyRetrieve the configured pending message storage cursor;- Specified by:
getQueuePendingMessageCursorin interfacePendingQueueMessageStoragePolicy- Parameters:
broker-queue-- Returns:
- the cursor
- See Also:
org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue, org.apache.activemq.kaha.Store)
-
-