1 14 15 package org.apache.activemq.broker.region.policy; 16 17 import org.apache.activemq.broker.region.Queue; 18 import org.apache.activemq.broker.region.cursors.PendingMessageCursor; 19 import org.apache.activemq.broker.region.cursors.StoreQueueCursor; 20 import org.apache.activemq.kaha.Store; 21 22 23 30 public class StorePendingQueueMessageStoragePolicy implements PendingQueueMessageStoragePolicy{ 31 32 38 public PendingMessageCursor getQueuePendingMessageCursor(Queue queue,Store tmpStore){ 39 return new StoreQueueCursor(queue,tmpStore); 40 } 41 42 43 } 44 | Popular Tags |