public class StorePendingQueueMessageStoragePolicy extends Object implements PendingQueueMessageStoragePolicy
Constructor and Description |
---|
StorePendingQueueMessageStoragePolicy() |
Modifier and Type | Method and Description |
---|---|
PendingMessageCursor |
getQueuePendingMessageCursor(Broker broker,
Queue queue)
Retrieve the configured pending message storage cursor;
|
public StorePendingQueueMessageStoragePolicy()
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker, Queue queue)
PendingQueueMessageStoragePolicy
getQueuePendingMessageCursor
in interface PendingQueueMessageStoragePolicy
broker
- queue
- 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.