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

Version:
1.0
Author:
Filip Hanik

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)
           
 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)
           
 
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 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(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-2012 The Apache Software Foundation. All Rights Reserved.