|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.broker.BrokerFilter
org.apache.activemq.plugin.ForcePersistencyModeBroker
public class ForcePersistencyModeBroker
A Plugin which allows to force every incoming message to be PERSISTENT or NON-PERSISTENT. Useful, if you have set the broker usage policy to process ONLY persistent or ONLY non-persistent messages.
Field Summary | |
---|---|
static org.slf4j.Logger |
log
|
Fields inherited from class org.apache.activemq.broker.BrokerFilter |
---|
next |
Constructor Summary | |
---|---|
ForcePersistencyModeBroker(Broker next)
Constructor |
Method Summary | |
---|---|
boolean |
isPersistent()
|
void |
send(ProducerBrokerExchange producerExchange,
Message messageSend)
Sets the persistence mode |
void |
setPersistenceFlag(boolean mode)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static org.slf4j.Logger log
Constructor Detail |
---|
public ForcePersistencyModeBroker(Broker next)
next
- Method Detail |
---|
public boolean isPersistent()
public void setPersistenceFlag(boolean mode)
persistenceFlag
- the persistenceFlag to setpublic void send(ProducerBrokerExchange producerExchange, Message messageSend) throws java.lang.Exception
send
in interface Region
send
in class BrokerFilter
producerExchange
- the environment the operation is being executed under.
java.lang.Exception
- TODOBrokerFilter.send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |