org.apache.activemq.plugin
Class DiscardingDLQBroker

java.lang.Object
  extended by org.apache.activemq.broker.BrokerFilter
      extended by org.apache.activemq.plugin.DiscardingDLQBroker
All Implemented Interfaces:
Broker, Region, Service

public class DiscardingDLQBroker
extends BrokerFilter


Field Summary
static Logger log
           
 
Fields inherited from class org.apache.activemq.broker.BrokerFilter
next
 
Constructor Summary
DiscardingDLQBroker(Broker next)
           
 
Method Summary
 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)
           
 
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 Logger log
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 interface Broker
Overrides:
sendToDeadLetterQueue in class BrokerFilter
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()


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.