org.apache.activemq.plugin
Class DiscardingDLQBroker
java.lang.Object
org.apache.activemq.broker.BrokerFilter
org.apache.activemq.plugin.DiscardingDLQBroker
- All Implemented Interfaces:
- Broker, Region, Service
public class DiscardingDLQBroker
- extends BrokerFilter
- Version:
- 1.0
- Author:
- Filip Hanik
Field Summary |
static org.slf4j.Logger |
log
|
Methods inherited from class org.apache.activemq.broker.BrokerFilter |
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, setAdminConnectionContext, slowConsumer, start, stop |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
public static org.slf4j.Logger log
DiscardingDLQBroker
public DiscardingDLQBroker(Broker next)
sendToDeadLetterQueue
public void sendToDeadLetterQueue(ConnectionContext ctx,
MessageReference msgRef,
Subscription subscription)
- Description copied from interface:
Broker
- A message needs to go the a DLQ
- Specified by:
sendToDeadLetterQueue
in interface Broker
- Overrides:
sendToDeadLetterQueue
in class BrokerFilter
matches
public boolean matches(java.lang.String destName)
setDropTemporaryTopics
public void setDropTemporaryTopics(boolean dropTemporaryTopics)
setDropTemporaryQueues
public void setDropTemporaryQueues(boolean dropTemporaryQueues)
setDropAll
public void setDropAll(boolean dropAll)
setDestFilter
public void setDestFilter(java.util.regex.Pattern[] destFilter)
setReportInterval
public void setReportInterval(int reportInterval)
isDropTemporaryTopics
public boolean isDropTemporaryTopics()
isDropTemporaryQueues
public boolean isDropTemporaryQueues()
isDropAll
public boolean isDropAll()
getDestFilter
public java.util.regex.Pattern[] getDestFilter()
getReportInterval
public int getReportInterval()
Copyright © 2005-2016. All Rights Reserved.