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 25 public interface PendingDurableSubscriberMessageStoragePolicy{ 26 27 36 public PendingMessageCursor getSubscriberPendingMessageCursor(String clientId,String name,Store tmpStorage, 37 int maxBatchSize); 38 } 39 | Popular Tags |