Package org.apache.activemq.plugin
Class DiscardingDLQBrokerPlugin
- java.lang.Object
-
- org.apache.activemq.plugin.DiscardingDLQBrokerPlugin
-
- All Implemented Interfaces:
BrokerPlugin
public class DiscardingDLQBrokerPlugin extends Object implements BrokerPlugin
- Version:
- 1.0
-
-
Field Summary
Fields Modifier and Type Field Description static org.slf4j.Logger
log
-
Constructor Summary
Constructors Constructor Description DiscardingDLQBrokerPlugin()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Pattern[]
getDestFilter()
String
getDropOnly()
int
getReportInterval()
Broker
installPlugin(Broker broker)
Installs the plugin into the intercepter chain of the broker, returning the new intercepted broker to use.boolean
isDropAll()
boolean
isDropTemporaryQueues()
boolean
isDropTemporaryTopics()
void
setDropAll(boolean dropAll)
void
setDropOnly(String dropOnly)
void
setDropTemporaryQueues(boolean dropTemporaryQueues)
void
setDropTemporaryTopics(boolean dropTemporaryTopics)
void
setReportInterval(int reportInterval)
-
-
-
Method Detail
-
installPlugin
public Broker installPlugin(Broker broker) throws Exception
Installs the plugin into the intercepter chain of the broker, returning the new intercepted broker to use.- Specified by:
installPlugin
in interfaceBrokerPlugin
- Parameters:
broker
- Broker- Returns:
- Broker
- Throws:
Exception
-
isDropAll
public boolean isDropAll()
-
isDropTemporaryQueues
public boolean isDropTemporaryQueues()
-
isDropTemporaryTopics
public boolean isDropTemporaryTopics()
-
getDropOnly
public String getDropOnly()
-
getReportInterval
public int getReportInterval()
-
setDropTemporaryTopics
public void setDropTemporaryTopics(boolean dropTemporaryTopics)
-
setDropTemporaryQueues
public void setDropTemporaryQueues(boolean dropTemporaryQueues)
-
setDropAll
public void setDropAll(boolean dropAll)
-
setDropOnly
public void setDropOnly(String dropOnly)
-
setReportInterval
public void setReportInterval(int reportInterval)
-
getDestFilter
public Pattern[] getDestFilter()
-
-