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

java.lang.Object
  extended by org.apache.activemq.broker.region.policy.FilePendingQueueMessageStoragePolicy
All Implemented Interfaces:
PendingQueueMessageStoragePolicy

public class FilePendingQueueMessageStoragePolicy
extends 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)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.