org.apache.activemq.plugin
Class SubQueueSelectorCacheBrokerPlugin

java.lang.Object
  extended by org.apache.activemq.plugin.SubQueueSelectorCacheBrokerPlugin
All Implemented Interfaces:
BrokerPlugin

public class SubQueueSelectorCacheBrokerPlugin
extends Object
implements BrokerPlugin

A plugin which allows the caching of the selector from a subscription queue.

This stops the build-up of unwanted messages, especially when consumers may disconnect from time to time when using virtual destinations.

This is influenced by code snippets developed by Maciej Rakowicz

Author:
Roelof Naude roelof(dot)naude(at)gmail.com

Constructor Summary
SubQueueSelectorCacheBrokerPlugin()
           
 
Method Summary
 File getPersistFile()
           
 Broker installPlugin(Broker broker)
          Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
 void setPersistFile(File persistFile)
          Sets the location of the persistent cache
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SubQueueSelectorCacheBrokerPlugin

public SubQueueSelectorCacheBrokerPlugin()
Method Detail

installPlugin

public Broker installPlugin(Broker broker)
                     throws Exception
Description copied from interface: BrokerPlugin
Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.

Specified by:
installPlugin in interface BrokerPlugin
Throws:
Exception

setPersistFile

public void setPersistFile(File persistFile)
Sets the location of the persistent cache


getPersistFile

public File getPersistFile()


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.