org.apache.activemq.broker.region.policy
Class FilePendingQueueMessageStoragePolicy

java.lang.Object
  org.apache.activemq.broker.region.policy.FilePendingQueueMessageStoragePolicy

All Implemented Interfaces:

PendingQueueMessageStoragePolicy

public class FilePendingQueueMessageStoragePolicy
extends java.lang.Object
implements PendingQueueMessageStoragePolicy

Creates a FilePendingMessageCursor *

Constructor Summary

FilePendingQueueMessageStoragePolicy()

Method Summary

PendingMessageCursor

getQueuePendingMessageCursor(Broker broker, Queue queue) Retrieve the configured pending message storage cursor;

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FilePendingQueueMessageStoragePolicy

public FilePendingQueueMessageStoragePolicy()

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 interface PendingQueueMessageStoragePolicy

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)