Package org.apache.activemq.plugin
Class DiscardingDLQBroker
- java.lang.Object
-
- org.apache.activemq.broker.BrokerFilter
-
- org.apache.activemq.plugin.DiscardingDLQBroker
-
public class DiscardingDLQBroker extends BrokerFilter
-
-
Field Summary
Fields Modifier and Type Field Description static org.slf4j.Logger
log
-
Fields inherited from class org.apache.activemq.broker.BrokerFilter
next
-
-
Constructor Summary
Constructors Constructor Description DiscardingDLQBroker(Broker next)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Pattern[]
getDestFilter()
int
getReportInterval()
boolean
isDropAll()
boolean
isDropTemporaryQueues()
boolean
isDropTemporaryTopics()
boolean
matches(String destName)
boolean
sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription, Throwable poisonCause)
A message needs to go the a DLQvoid
setDestFilter(Pattern[] destFilter)
void
setDropAll(boolean dropAll)
void
setDropTemporaryQueues(boolean dropTemporaryQueues)
void
setDropTemporaryTopics(boolean dropTemporaryTopics)
void
setReportInterval(int reportInterval)
-
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, getDestinationMap, getDestinations, getDestinations, getDurableDestinations, getExecutor, getNext, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, setAdminConnectionContext, slowConsumer, start, stop, virtualDestinationAdded, virtualDestinationRemoved
-
-
-
-
Constructor Detail
-
DiscardingDLQBroker
public DiscardingDLQBroker(Broker next)
-
-
Method Detail
-
sendToDeadLetterQueue
public boolean sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription, Throwable poisonCause)
Description copied from interface:Broker
A message needs to go the a DLQ- Specified by:
sendToDeadLetterQueue
in interfaceBroker
- Overrides:
sendToDeadLetterQueue
in classBrokerFilter
poisonCause
- reason for dlq submission, may be null- Returns:
- true if Message was placed in a DLQ false if discarded.
-
matches
public boolean matches(String destName)
-
setDropTemporaryTopics
public void setDropTemporaryTopics(boolean dropTemporaryTopics)
-
setDropTemporaryQueues
public void setDropTemporaryQueues(boolean dropTemporaryQueues)
-
setDropAll
public void setDropAll(boolean dropAll)
-
setDestFilter
public void setDestFilter(Pattern[] destFilter)
-
setReportInterval
public void setReportInterval(int reportInterval)
-
isDropTemporaryTopics
public boolean isDropTemporaryTopics()
-
isDropTemporaryQueues
public boolean isDropTemporaryQueues()
-
isDropAll
public boolean isDropAll()
-
getDestFilter
public Pattern[] getDestFilter()
-
getReportInterval
public int getReportInterval()
-
-