Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » policy » [javadoc | source]
org.apache.activemq.broker.region.policy
public class: FixedSizedSubscriptionRecoveryPolicy [javadoc | source]
java.lang.Object
   org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy

All Implemented Interfaces:
    SubscriptionRecoveryPolicy

This implementation of SubscriptionRecoveryPolicy will keep a fixed amount of memory available in RAM for message history which is evicted in time order.
Constructor:
 public FixedSizedSubscriptionRecoveryPolicy() 
Method from org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy Summary:
add,   browse,   copy,   createMessageList,   getBuffer,   getMaximumSize,   isUseSharedBuffer,   recover,   setBuffer,   setMaximumSize,   setUseSharedBuffer,   start,   stop
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy Detail:
 public boolean add(ConnectionContext context,
    MessageReference message) throws Exception 
 public Message[] browse(ActiveMQDestination destination) throws Exception 
 public SubscriptionRecoveryPolicy copy() 
 protected MessageList createMessageList() 
 public MessageList getBuffer() 
 public int getMaximumSize() 
 public boolean isUseSharedBuffer() 
 public  void recover(ConnectionContext context,
    Topic topic,
    SubscriptionRecovery sub) throws Exception 
 public  void setBuffer(MessageList buffer) 
 public  void setMaximumSize(int maximumSize) 
    Sets the maximum amount of RAM in bytes that this buffer can hold in RAM
 public  void setUseSharedBuffer(boolean useSharedBuffer) 
 public  void start() throws Exception 
 public  void stop() throws Exception