Package com.predic8.membrane.core.exchangestore

Class AbstractExchangeStore

java.lang.Object

com.predic8.membrane.core.exchangestore.AbstractExchangeStore

All Implemented Interfaces:

ExchangeStore

Direct Known Subclasses:

ElasticSearchExchangeStore, FileExchangeStore, LimitedMemoryExchangeStore, MemoryExchangeStore

public abstract class AbstractExchangeStore
extends Object
implements ExchangeStore

Field Summary

Fields

Modifier and Type	Field	Description
protected Set<IExchangesStoreListener>	exchangesStoreListeners

Constructor Summary

Constructors

Constructor	Description
AbstractExchangeStore()

Method Summary

Modifier and Type	Method	Description
void	addExchangesStoreListener(IExchangesStoreListener viewer)
void	collect(ExchangeCollector collector)
List<? extends ClientStatistics>	getClientStatistics()
AbstractExchange	getExchangeById(long id)
ExchangeQueryResult	getFilteredSortedPaged(QueryParameter params, boolean useXForwardedForAsClientAddr)
long	getLastModified()
protected static int	getMax(QueryParameter params, List<AbstractExchange> exchanges)
void	init(Router router)
void	notifyListenersOnExchangeAdd(Rule rule, AbstractExchange exchange)
void	notifyListenersOnExchangeRemoval(AbstractExchange exchange)
protected static boolean	pathContains(String search, AbstractExchange e)
void	refreshExchangeStoreListeners()
void	removeExchangesStoreListener(IExchangesStoreListener viewer)
protected static boolean	requestHeaderContains(String search, AbstractExchange e)
protected static boolean	responseHeaderContains(String search, AbstractExchange e)
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

Methods inherited from interface com.predic8.membrane.core.exchangestore.ExchangeStore

getAllExchanges, getAllExchangesAsList, getExchanges, getNumberOfExchanges, getStatistics, remove, removeAllExchanges, removeAllExchanges, snap

Field Details

exchangesStoreListeners

protected Set<IExchangesStoreListener> exchangesStoreListeners

Constructor Details

AbstractExchangeStore

public AbstractExchangeStore()

Method Details

addExchangesStoreListener

public void addExchangesStoreListener(IExchangesStoreListener viewer)

Specified by:

addExchangesStoreListener in interface ExchangeStore

removeExchangesStoreListener

public void removeExchangesStoreListener(IExchangesStoreListener viewer)

Specified by:

removeExchangesStoreListener in interface ExchangeStore

refreshExchangeStoreListeners

public void refreshExchangeStoreListeners()

Specified by:

refreshExchangeStoreListeners 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

getExchangeById

public AbstractExchange getExchangeById(long id)

Specified by:

getExchangeById in interface ExchangeStore

getClientStatistics

public List<? extends ClientStatistics> getClientStatistics()

Specified by:

getClientStatistics in interface ExchangeStore

init

public void init(Router router)

Specified by:

init 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)
                         throws InterruptedException

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

Throws:

InterruptedException

getFilteredSortedPaged

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

Specified by:

getFilteredSortedPaged in interface ExchangeStore

Throws:

Exception

getMax

protected static int getMax(QueryParameter params,
 List<AbstractExchange> exchanges)

pathContains

protected static boolean pathContains(String search,
 AbstractExchange e)

requestHeaderContains

protected static boolean requestHeaderContains(String search,
 AbstractExchange e)

responseHeaderContains

protected static boolean responseHeaderContains(String search,
 AbstractExchange e)