1 14 15 package org.apache.activemq.broker.region.policy; 16 17 import org.apache.activemq.broker.region.cursors.PendingMessageCursor; 18 import org.apache.activemq.kaha.Store; 19 20 21 26 public interface PendingSubscriberMessageStoragePolicy{ 27 28 36 public PendingMessageCursor getSubscriberPendingMessageCursor(String name,Store tmpStorage, 37 int maxBatchSize); 38 } 39 | Popular Tags |