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.broker.region.cursors.VMPendingMessageCursor; 19 import org.apache.activemq.kaha.Store; 20 21 28 public class VMPendingDurableSubscriberMessageStoragePolicy implements PendingDurableSubscriberMessageStoragePolicy{ 29 30 39 public PendingMessageCursor getSubscriberPendingMessageCursor(String clientId,String name,Store tmpStorage, 40 int maxBatchSize){ 41 return new VMPendingMessageCursor(); 42 } 43 } 44 | Popular Tags |