public class TimeStampingBrokerPlugin extends BrokerPluginSupport
next
Constructor and Description |
---|
TimeStampingBrokerPlugin() |
Modifier and Type | Method and Description |
---|---|
void |
send(ProducerBrokerExchange producerExchange,
Message message)
Send a message to the broker to using the specified destination.
|
void |
setFutureOnly(boolean futureOnly) |
void |
setProcessNetworkMessages(Boolean processNetworkMessages) |
void |
setTtlCeiling(long ttlCeiling)
setter method for ttlCeiling
|
void |
setZeroExpirationOverride(long ttl)
setter method for zeroExpirationOverride
|
installPlugin, start, stop
acknowledge, addBroker, addConnection, addConsumer, addDestination, addDestinationInfo, addProducer, addSession, beginTransaction, brokerServiceStarted, commitTransaction, fastProducer, forgetTransaction, gc, getAdaptor, getAdminConnectionContext, getBrokerId, getBrokerName, getBrokerSequenceId, getBrokerService, getClients, getDestinationMap, 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, preProcessDispatch, processConsumerControl, processDispatchNotification, reapplyInterceptor, removeBroker, removeConnection, removeConsumer, removeDestination, removeDestinationInfo, removeProducer, removeSession, removeSubscription, rollbackTransaction, sendToDeadLetterQueue, setAdminConnectionContext, setNext, slowConsumer, virtualDestinationAdded, virtualDestinationRemoved
public TimeStampingBrokerPlugin()
public void setZeroExpirationOverride(long ttl)
public void setTtlCeiling(long ttlCeiling)
public void setFutureOnly(boolean futureOnly)
public void setProcessNetworkMessages(Boolean processNetworkMessages)
public void send(ProducerBrokerExchange producerExchange, Message message) throws Exception
Region
send
in interface Region
send
in class MutableBrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOCopyright © 2005–2020 The Apache Software Foundation. All rights reserved.