org.apache.activemq.plugin

Class SubQueueSelectorCacheBrokerPlugin

java.lang.Object

org.apache.activemq.plugin.SubQueueSelectorCacheBrokerPlugin

All Implemented Interfaces:

BrokerPlugin

public class SubQueueSelectorCacheBrokerPlugin
extends java.lang.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

Constructors

Constructor and Description
SubQueueSelectorCacheBrokerPlugin()

Method Summary

Methods

Modifier and Type	Method and Description
java.io.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(java.io.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 java.lang.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:

java.lang.Exception

setPersistFile

public void setPersistFile(java.io.File persistFile)

Sets the location of the persistent cache

getPersistFile

public java.io.File getPersistFile()