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) |
void |
sendToDeadLetterQueue(ConnectionContext ctx,
MessageReference msgRef,
Subscription subscription)
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, 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
public static org.slf4j.Logger log
public DiscardingDLQBroker(Broker next)
public void sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription)
Broker
sendToDeadLetterQueue
in interface Broker
sendToDeadLetterQueue
in class BrokerFilter
public 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–2015. All rights reserved.