Package com.predic8.membrane.core.exchangestore

Class ForgetfulExchangeStore

java.lang.Object

com.predic8.membrane.core.exchangestore.ForgetfulExchangeStore

All Implemented Interfaces:

ExchangeStore

public class ForgetfulExchangeStore
extends Object
implements ExchangeStore

Constructor Summary

Constructors

Constructor	Description
ForgetfulExchangeStore()

Method Summary

Modifier and Type	Method	Description
void	addExchangesStoreListener(IExchangesStoreListener viewer)
void	collect(ExchangeCollector collector)
Object[]	getAllExchanges()
List<AbstractExchange>	getAllExchangesAsList()
List<? extends ClientStatistics>	getClientStatistics()
AbstractExchange	getExchangeById(long intParam)
AbstractExchange[]	getExchanges(RuleKey ruleKey)
ExchangeQueryResult	getFilteredSortedPaged(QueryParameter params, boolean useXForwardedForAsClientAddr)
long	getLastModified()
Object[]	getLatExchanges(int count)
int	getNumberOfExchanges(RuleKey ruleKey)
StatisticCollector	getStatistics(RuleKey ruleKey)
void	init(Router router)
void	notifyListenersOnExchangeAdd(Rule rule, AbstractExchange exchange)
void	notifyListenersOnExchangeRemoval(AbstractExchange exchange)
void	notifyListenersOnRuleAdd(Rule rule)
void	notifyListenersOnRuleRemoval(Rule rule, int rulesLeft)
void	refreshExchangeStoreListeners()
void	remove(AbstractExchange exchange)
void	removeAllExchanges(AbstractExchange[] exchanges)
void	removeAllExchanges(Rule rule)
void	removeExchangesStoreListener(IExchangesStoreListener viewer)
void	snap(AbstractExchange exchange, Interceptor.Flow flow)	Adds the current state of the exchange to the store.
void	waitForModification(long lastKnownModification)	Returns immediately if lastKnownModification is smaller than last known modification.

Methods inherited from class java.lang.Object

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

Constructor Details

ForgetfulExchangeStore

public ForgetfulExchangeStore()

Method Details

snap

public void snap(AbstractExchange exchange,
 Interceptor.Flow flow)

Description copied from interface: ExchangeStore

Adds the current state of the exchange to the store.

Implementations should take a snapshot of the current state of the request (or response) headers and register a body observer in which they will be called back as soon as the body has fully been received.

If flow==REQUEST, the request is added. Elsewise, the response is added (if present).

Specified by:

snap in interface ExchangeStore

addExchangesStoreListener

public void addExchangesStoreListener(IExchangesStoreListener viewer)

Specified by:

addExchangesStoreListener in interface ExchangeStore

getExchanges

public AbstractExchange[] getExchanges(RuleKey ruleKey)

Specified by:

getExchanges in interface ExchangeStore

getNumberOfExchanges

public int getNumberOfExchanges(RuleKey ruleKey)

Specified by:

getNumberOfExchanges in interface ExchangeStore

getStatistics

public StatisticCollector getStatistics(RuleKey ruleKey)

Specified by:

getStatistics in interface ExchangeStore

notifyListenersOnExchangeAdd

public void notifyListenersOnExchangeAdd(Rule rule,
 AbstractExchange exchange)

Specified by:

notifyListenersOnExchangeAdd in interface ExchangeStore

notifyListenersOnExchangeRemoval

public void notifyListenersOnExchangeRemoval(AbstractExchange exchange)

Specified by:

notifyListenersOnExchangeRemoval in interface ExchangeStore

notifyListenersOnRuleAdd

public void notifyListenersOnRuleAdd(Rule rule)

notifyListenersOnRuleRemoval

public void notifyListenersOnRuleRemoval(Rule rule,
 int rulesLeft)

refreshExchangeStoreListeners

public void refreshExchangeStoreListeners()

Specified by:

refreshExchangeStoreListeners in interface ExchangeStore

remove

public void remove(AbstractExchange exchange)

Specified by:

remove in interface ExchangeStore

removeAllExchanges

public void removeAllExchanges(Rule rule)

Specified by:

removeAllExchanges in interface ExchangeStore

removeExchangesStoreListener

public void removeExchangesStoreListener(IExchangesStoreListener viewer)

Specified by:

removeExchangesStoreListener in interface ExchangeStore

getAllExchanges

public Object[] getAllExchanges()

Specified by:

getAllExchanges in interface ExchangeStore

getLatExchanges

public Object[] getLatExchanges(int count)

getAllExchangesAsList

public List<AbstractExchange> getAllExchangesAsList()

Specified by:

getAllExchangesAsList in interface ExchangeStore

removeAllExchanges

public void removeAllExchanges(AbstractExchange[] exchanges)

Specified by:

removeAllExchanges in interface ExchangeStore

getExchangeById

public AbstractExchange getExchangeById(long intParam)

Specified by:

getExchangeById in interface ExchangeStore

init

public void init(Router router)
          throws Exception

Specified by:

init in interface ExchangeStore

Throws:

Exception

getClientStatistics

public List<? extends ClientStatistics> getClientStatistics()

Specified by:

getClientStatistics in interface ExchangeStore

collect

public void collect(ExchangeCollector collector)

Specified by:

collect in interface ExchangeStore

getLastModified

public long getLastModified()

Specified by:

getLastModified in interface ExchangeStore

waitForModification

public void waitForModification(long lastKnownModification)

Description copied from interface: ExchangeStore

Returns immediately if lastKnownModification is smaller than last known modification. Otherwise it waits until a modification occurs.

Specified by:

waitForModification in interface ExchangeStore

getFilteredSortedPaged

public ExchangeQueryResult getFilteredSortedPaged(QueryParameter params,
 boolean useXForwardedForAsClientAddr)
                                           throws Exception

Specified by:

getFilteredSortedPaged in interface ExchangeStore

Throws:

Exception