org.apache.activemq.plugin
Class ForcePersistencyModeBrokerPlugin

java.lang.Object
  extended by org.apache.activemq.plugin.ForcePersistencyModeBrokerPlugin
All Implemented Interfaces:
BrokerPlugin

public class ForcePersistencyModeBrokerPlugin
extends Object
implements BrokerPlugin

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.


Constructor Summary
ForcePersistencyModeBrokerPlugin()
          Constructor
 
Method Summary
 Broker installPlugin(Broker broker)
          Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.
 boolean isPersistenceForced()
           
 void setPersistenceFlag(boolean persistenceFlag)
          Sets the persistency mode.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ForcePersistencyModeBrokerPlugin

public ForcePersistencyModeBrokerPlugin()
Constructor

Method Detail

installPlugin

public Broker installPlugin(Broker broker)
                     throws Exception
Description copied from interface: BrokerPlugin
Installs the plugin into the interceptor chain of the broker, returning the new intercepted broker to use.

Specified by:
installPlugin in interface BrokerPlugin
Parameters:
broker -
Returns:
the Broker
Throws:
Exception
See Also:
BrokerPlugin.installPlugin(org.apache.activemq.broker.Broker)

setPersistenceFlag

public void setPersistenceFlag(boolean persistenceFlag)
Sets the persistency mode.

Parameters:
persistenceFlag -

isPersistenceForced

public final boolean isPersistenceForced()
Returns:
the mode the (activated) plugin will set the message delivery mode


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.