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.kaha.Store; 20 21 22 27 public interface PendingQueueMessageStoragePolicy{ 28 29 36 public PendingMessageCursor getQueuePendingMessageCursor(Queue queue, Store tmpStore); 37 } 38 | Popular Tags |