public class ForcePersistencyModeBroker extends BrokerFilter
Modifier and Type | Field and Description |
---|---|
static org.slf4j.Logger |
log |
next
Constructor and Description |
---|
ForcePersistencyModeBroker(Broker next)
Constructor
|
Modifier and Type | Method and Description |
---|---|
boolean |
isPersistent() |
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode
|
void |
setPersistenceFlag(boolean mode) |
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, sendToDeadLetterQueue, setAdminConnectionContext, slowConsumer, start, stop
public ForcePersistencyModeBroker(Broker next)
next
- public boolean isPersistent()
public void setPersistenceFlag(boolean mode)
persistenceFlag
- the persistenceFlag to setpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws Exception
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.Exception
- TODOBrokerFilter.send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)
Copyright © 2005–2016 The Apache Software Foundation. All rights reserved.