public class DiscardingDLQBrokerPlugin extends Object implements BrokerPlugin
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
Constructor and Description |
---|
DiscardingDLQBrokerPlugin() |
Modifier and Type | Method and 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) |
public static org.slf4j.Logger log
public DiscardingDLQBrokerPlugin()
public Broker installPlugin(Broker broker) throws Exception
installPlugin
in interface BrokerPlugin
broker
- BrokerException
public boolean isDropAll()
public boolean isDropTemporaryQueues()
public boolean isDropTemporaryTopics()
public String getDropOnly()
public int getReportInterval()
public void setDropTemporaryTopics(boolean dropTemporaryTopics)
public void setDropTemporaryQueues(boolean dropTemporaryQueues)
public void setDropAll(boolean dropAll)
public void setDropOnly(String dropOnly)
public void setReportInterval(int reportInterval)
public Pattern[] getDestFilter()
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.