1 14 15 package org.apache.activemq.broker.region.policy; 16 17 import org.apache.activemq.broker.region.cursors.FilePendingMessageCursor; 18 import org.apache.activemq.broker.region.cursors.PendingMessageCursor; 19 import org.apache.activemq.kaha.Store; 20 21 29 public class FilePendingDurableSubscriberMessageStoragePolicy implements PendingDurableSubscriberMessageStoragePolicy{ 30 31 40 public PendingMessageCursor getSubscriberPendingMessageCursor(String clientId,String name,Store tmpStorage, 41 int maxBatchSize){ 42 return new FilePendingMessageCursor(name,tmpStorage); 43 } 44 } 45 | Popular Tags |