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 PendingMessageCursor
getQueuePendingMessageCursor(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:PendingQueueMessageStoragePolicy
Retrieve the configured pending message storage cursor;- Specified by:
getQueuePendingMessageCursor
in 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)
-
-