1 14 package org.apache.activemq.broker.region.policy; 15 16 import org.apache.activemq.broker.region.cursors.PendingMessageCursor; 17 import org.apache.activemq.broker.region.cursors.VMPendingMessageCursor; 18 import org.apache.activemq.kaha.Store; 19 20 21 28 public class VMPendingSubscriberMessageStoragePolicy implements PendingSubscriberMessageStoragePolicy{ 29 30 37 public PendingMessageCursor getSubscriberPendingMessageCursor(String name,Store tmpStorage,int maxBatchSize){ 38 return new VMPendingMessageCursor(); 39 } 40 } 41 | Popular Tags |