public class DiscardingDLQBroker extends BrokerFilter
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
next
Constructor and Description |
---|
DiscardingDLQBroker(Broker next) |
Modifier and Type | Method and 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 DLQ
|
void |
setDestFilter(Pattern[] destFilter) |
void |
setDropAll(boolean dropAll) |
void |
setDropTemporaryQueues(boolean dropTemporaryQueues) |
void |
setDropTemporaryTopics(boolean dropTemporaryTopics) |
void |
setReportInterval(int reportInterval) |
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, 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
public static org.slf4j.Logger log
public DiscardingDLQBroker(Broker next)
public boolean sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription, Throwable poisonCause)
Broker
sendToDeadLetterQueue
in interface Broker
sendToDeadLetterQueue
in class BrokerFilter
poisonCause
- reason for dlq submission, may be nullpublic void setDropTemporaryTopics(boolean dropTemporaryTopics)
public void setDropTemporaryQueues(boolean dropTemporaryQueues)
public void setDropAll(boolean dropAll)
public void setDestFilter(Pattern[] destFilter)
public void setReportInterval(int reportInterval)
public boolean isDropTemporaryTopics()
public boolean isDropTemporaryQueues()
public boolean isDropAll()
public Pattern[] getDestFilter()
public int getReportInterval()
Copyright © 2005–2017 The Apache Software Foundation. All rights reserved.