com.atlassian.bamboo.amq
Class DisableClientSideExpiryBrokerPlugin

java.lang.Object
  org.apache.activemq.broker.MutableBrokerFilter
      org.apache.activemq.broker.BrokerPluginSupport
          com.atlassian.bamboo.amq.DisableClientSideExpiryBrokerPlugin

All Implemented Interfaces:

org.apache.activemq.broker.Broker, org.apache.activemq.broker.BrokerPlugin, org.apache.activemq.broker.region.Region, org.apache.activemq.Service

public class DisableClientSideExpiryBrokerPlugin
extends org.apache.activemq.broker.BrokerPluginSupport

This plugin disables client-side message expiry. Messages on the broker are still expired as usual.

Field Summary

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

next

Constructor Summary

DisableClientSideExpiryBrokerPlugin()

Method Summary

void	preProcessDispatch(org.apache.activemq.command.MessageDispatch messageDispatch)

Methods inherited from class org.apache.activemq.broker.BrokerPluginSupport

installPlugin, start, stop

Methods inherited from class org.apache.activemq.broker.MutableBrokerFilter

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, getNext, getPeerBrokerInfos, getPreparedTransactions, getRoot, getScheduler, getTempDataStore, getVmConnectorURI, isExpired, isFaultTolerantConfiguration, isFull, isStopped, messageConsumed, messageDelivered, messageDiscarded, messageExpired, messagePull, networkBridgeStarted, networkBridgeStopped, nowMasterBroker, postProcessDispatch, prepareTransaction, processConsumerControl, processDispatchNotification, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, send, sendToDeadLetterQueue, setAdminConnectionContext, setNext, slowConsumer

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DisableClientSideExpiryBrokerPlugin

public DisableClientSideExpiryBrokerPlugin()

Method Detail

preProcessDispatch

public void preProcessDispatch(org.apache.activemq.command.MessageDispatch messageDispatch)

Specified by:

preProcessDispatch in interface org.apache.activemq.broker.Broker

Overrides:

preProcessDispatch in class org.apache.activemq.broker.MutableBrokerFilter