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

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	log

Fields inherited from class org.apache.activemq.broker.BrokerFilter

next

Constructor Summary

Constructors

Constructor and Description
DiscardingDLQBroker(Broker next)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.regex.Pattern[]	getDestFilter()
int	getReportInterval()
boolean	isDropAll()
boolean	isDropTemporaryQueues()
boolean	isDropTemporaryTopics()
boolean	matches(java.lang.String destName)
void	sendToDeadLetterQueue(ConnectionContext ctx, MessageReference msgRef, Subscription subscription) A message needs to go the a DLQ
void	setDestFilter(java.util.regex.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, 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

Field Detail

log

public static org.slf4j.Logger log

Constructor Detail

DiscardingDLQBroker

public DiscardingDLQBroker(Broker next)

Method Detail

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()