Package com.espertech.esper.runtime.client.scopetest

Class SupportSubscriberMRD

java.lang.Object

com.espertech.esper.runtime.client.scopetest.SupportSubscriberMRD

public class SupportSubscriberMRD
extends Object

Subscriber for multi-row delivery that retains the events it receives for use in assertions.

Constructor Summary

Constructors

Constructor	Description
SupportSubscriberMRD()

Method Summary

Modifier and Type	Method	Description
boolean	getAndClearIsInvoked()	Returns true if the subscriber was invoked at least once and clears the invocation flag.
List<Object[][]>	getInsertStreamList()	Returns all insert-stream events received so far.
List<Object[][]>	getRemoveStreamList()	Returns all removed-stream events received so far.
boolean	isInvoked()	Returns true if the subscriber was invoked at least once.
void	reset()	Reset subscriber, clearing all associated state.
void	update(Object[][] insertStream, Object[][] removeStream)	Receive multi-row subscriber data through this methods.

Methods inherited from class java.lang.Object

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

Constructor Details

SupportSubscriberMRD

public SupportSubscriberMRD()

Method Details

update

public void update(Object[][] insertStream,
 Object[][] removeStream)

Receive multi-row subscriber data through this methods.

Parameters:

insertStream - new data

removeStream - removed data

getInsertStreamList

public List<Object[][]> getInsertStreamList()

Returns all insert-stream events received so far.

The list contains an item for each delivery. Each item contains a row with the event and each event is itself a tuple (object array).

Returns:

list of Object array-array

getRemoveStreamList

public List<Object[][]> getRemoveStreamList()

Returns all removed-stream events received so far.

The list contains an item for each delivery. Each item contains a row with the event and each event is itself a tuple (object array).

Returns:

list of Object array-array

reset

public void reset()

Reset subscriber, clearing all associated state.

isInvoked

public boolean isInvoked()

Returns true if the subscriber was invoked at least once.

Returns:

invoked flag

getAndClearIsInvoked

public boolean getAndClearIsInvoked()

Returns true if the subscriber was invoked at least once and clears the invocation flag.

Returns:

invoked flag