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

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

public class StorePendingQueueMessageStoragePolicy
extends Object
implements PendingQueueMessageStoragePolicy

Creates a StoreQueueCursor *


Constructor Summary
StorePendingQueueMessageStoragePolicy()
           
 
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

StorePendingQueueMessageStoragePolicy

public StorePendingQueueMessageStoragePolicy()
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.