MemoryExchangeStore (service-proxy-core 5.8.3 API)

java.lang.Object

com.predic8.membrane.core.exchangestore.AbstractExchangeStore

com.predic8.membrane.core.exchangestore.MemoryExchangeStore

All Implemented Interfaces:: ExchangeStore

public class MemoryExchangeStore extends AbstractExchangeStore

TODO: thread-safety

Description: Stores all exchanges in-memory. The Java heap will overflow if this store is used to store too many Exchanges. Use for Membrane Monitor only.

Field Summary

Fields inherited from class com.predic8.membrane.core.exchangestore.AbstractExchangeStore
exchangesStoreListeners
Constructor Summary

Constructors

Constructor

Description

MemoryExchangeStore()
Method Summary

Modifier and Type

Method

Description

Object[]

getAllExchanges()

List<AbstractExchange>

getAllExchangesAsList()

AbstractExchange[]

getExchanges(RuleKey ruleKey)

int

getNumberOfExchanges(RuleKey ruleKey)

StatisticCollector

getStatistics(RuleKey key)

void

remove(AbstractExchange exc)

void

removeAllExchanges(AbstractExchange[] exchanges)

void

removeAllExchanges(Rule rule)

void

snap(AbstractExchange exc, Interceptor.Flow flow)

Adds the current state of the exchange to the store.

Methods inherited from class com.predic8.membrane.core.exchangestore.AbstractExchangeStore
addExchangesStoreListener, collect, getClientStatistics, getExchangeById, getFilteredSortedPaged, getLastModified, getMax, init, notifyListenersOnExchangeAdd, notifyListenersOnExchangeRemoval, pathContains, refreshExchangeStoreListeners, removeExchangesStoreListener, requestHeaderContains, responseHeaderContains, waitForModification

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- MemoryExchangeStore
  
  public MemoryExchangeStore()
Method Details
- snap
  
  public void snap(AbstractExchange exc, 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).
- remove
  
  public void remove(AbstractExchange exc)
- removeAllExchanges
  
  public void removeAllExchanges(Rule rule)
- getExchanges
  
  public AbstractExchange[] getExchanges(RuleKey ruleKey)
- getNumberOfExchanges
  
  public int getNumberOfExchanges(RuleKey ruleKey)
- getStatistics
  
  public StatisticCollector getStatistics(RuleKey key)
- getAllExchanges
  
  public Object[] getAllExchanges()
- getAllExchangesAsList
  
  public List<AbstractExchange> getAllExchangesAsList()
- removeAllExchanges
  
  public void removeAllExchanges(AbstractExchange[] exchanges)