com.espertech.esper.runtime.client.scopetest

Class SupportUpdateListener

java.lang.Object

com.espertech.esper.runtime.client.scopetest.SupportUpdateListener

All Implemented Interfaces:

SupportListener, UpdateListener

public class SupportUpdateListener
extends Object
implements UpdateListener, SupportListener

Update listener that retains the events it receives for use in assertions.

Constructor Summary

Constructors

Constructor and Description
SupportUpdateListener() Ctor.

Method Summary

Modifier and Type	Method and Description
com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean>	assertGetAndResetIRPair() Asserts that there is exactly one insert-stream event and one remove-stream event available and resets.
com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]>	assertInvokedAndReset() Returns a pair of insert and remove stream event arrays considering the last invocation only, asserting that only a single invocation occured, and resetting the listener.
void	assertInvokedFlagAndReset(boolean expected) Assert the invoked-flag against the expected value and reset the flag
void	assertNewOldData(Object[][] nameAndValuePairsIStream, Object[][] nameAndValuePairsRStream) Asserts name-value pairs of insert and remove stream events
void	assertNotInvoked() Assert not invoked.
com.espertech.esper.common.client.EventBean	assertOneGetNew() Asserts that exactly one insert stream event was received not checking remove stream data, and returns the received event.
com.espertech.esper.common.client.EventBean	assertOneGetNewAndReset() Asserts that exactly one insert stream event was received and no remove stream events, resets the listener clearing all state and returns the received event.
com.espertech.esper.common.client.EventBean	assertOneGetOld() Asserts that exactly one remove stream event was received not checking insert stream data, and returns the received event.
com.espertech.esper.common.client.EventBean	assertOneGetOldAndReset() Asserts that exactly one remove stream event was received and no insert stream events, resets the listener clearing all state and returns the received event.
com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean>	assertPairGetIRAndReset() Asserts that exactly one insert stream event and exactly one remove stream event was received, resets the listener clearing all state and returns the received events as a pair.
boolean	getAndClearIsInvoked() Returns true if the listener was invoked at least once and clears the invocation flag.
com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]>	getAndResetDataListsFlattened() Returns a pair of insert and remove stream event arrays considering the all invocations, and resets the listener.
com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]>	getAndResetIRPair() Returns a pair of last-invocation insert and remove stream events and resets
com.espertech.esper.common.client.EventBean[]	getAndResetLastNewData() Returns the last array of events (insert stream) that were received and resets the listener.
com.espertech.esper.common.client.EventBean[]	getAndResetLastOldData() Returns the last array of events (insert stream) that were received and resets the listener.
com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]>	getDataListsFlattened() Returns a pair of insert and remove stream event arrays considering the all invocations.
static boolean[]	getInvokedFlagsAndReset(SupportUpdateListener[] listeners) For multiple listeners, return the invoked flags and reset each listener
boolean	getIsInvokedAndReset() Returns true if the listener was invoked at least once and clears the invocation flag.
com.espertech.esper.common.client.EventBean[]	getLastNewData() Returns the last array of events (insert stream) that were received.
com.espertech.esper.common.client.EventBean[]	getLastOldData() Returns the last array of remove-stream events that were received.
List<com.espertech.esper.common.client.EventBean[]>	getNewDataList() Get a list of all insert-stream event arrays received.
com.espertech.esper.common.client.EventBean[]	getNewDataListFlattened() Returns an event array that represents all insert-stream events received so far.
List<com.espertech.esper.common.client.EventBean[]>	getOldDataList() Get a list of all remove-stream event arrays received.
com.espertech.esper.common.client.EventBean[]	getOldDataListFlattened() Returns an event array that represents all remove-stream events received so far.
boolean	isInvoked() Returns true if the listener was invoked at least once.
static SupportUpdateListener[]	makeListeners(int size) Produce an array of listeners
void	reset() Reset listener, clearing all associated state.
void	setLastNewData(com.espertech.esper.common.client.EventBean[] lastNewData) Set an array of events as the last insert-stream events received.
void	setLastOldData(com.espertech.esper.common.client.EventBean[] lastOldData) Set an array of events as the last remove-stream events received.
void	update(com.espertech.esper.common.client.EventBean[] newData, com.espertech.esper.common.client.EventBean[] oldData, EPStatement statement, EPRuntime runtime) Notify that new events are available or old events are removed.
void	waitForInvocation(long msecWait) Wait for an invocation up to the given milliseconds
void	waitForInvocation(long msecWait, int numberOfNewEvents) Wait for the listener invocation for up to the given number of milliseconds.

Methods inherited from class java.lang.Object

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

Constructor Detail

SupportUpdateListener

public SupportUpdateListener()

Ctor.

Method Detail

waitForInvocation

public void waitForInvocation(long msecWait)

Wait for an invocation up to the given milliseconds

Parameters:

msecWait - wait time

waitForInvocation

public void waitForInvocation(long msecWait,
                              int numberOfNewEvents)

Wait for the listener invocation for up to the given number of milliseconds.

Specified by:

waitForInvocation in interface SupportListener

Parameters:

msecWait - to wait

numberOfNewEvents - in any number of separate invocations required before returning

Throws:

RuntimeException - when no results or insufficient number of events were received

update

public void update(com.espertech.esper.common.client.EventBean[] newData,
                   com.espertech.esper.common.client.EventBean[] oldData,
                   EPStatement statement,
                   EPRuntime runtime)

Description copied from interface: UpdateListener

Notify that new events are available or old events are removed.

If the call to update contains new (inserted) events, then the first argument will be a non-empty list and the second will be empty. Similarly, if the call is a notification of deleted events, then the first argument will be empty and the second will be non-empty.

Either the newEvents or oldEvents will be non-null. This method won't be called with both arguments being null (unless using output rate limiting or force-output options), but either one could be null. The same is true for zero-length arrays. Either newEvents or oldEvents will be non-empty. If both are non-empty, then the update is a modification notification.

Specified by:

update in interface UpdateListener

Parameters:

newData - is any new events. This will be null or empty if the update is for old events only.

oldData - is any old events. This will be null or empty if the update is for new events only.

statement - is the statement producing the result

runtime - is the runtime

assertInvokedFlagAndReset

public void assertInvokedFlagAndReset(boolean expected)

Description copied from interface: SupportListener

Assert the invoked-flag against the expected value and reset the flag

Specified by:

assertInvokedFlagAndReset in interface SupportListener

Parameters:

expected - expected value

reset

public void reset()

Reset listener, clearing all associated state.

Specified by:

reset in interface SupportListener

getLastNewData

public com.espertech.esper.common.client.EventBean[] getLastNewData()

Description copied from interface: SupportListener

Returns the last array of events (insert stream) that were received.

Specified by:

getLastNewData in interface SupportListener

Returns:

insert stream events or null if either a null value was received or when no events have been received since the last reset

getLastOldData

public com.espertech.esper.common.client.EventBean[] getLastOldData()

Description copied from interface: SupportListener

Returns the last array of remove-stream events that were received.

Specified by:

getLastOldData in interface SupportListener

Returns:

remove stream events or null if either a null value was received or when no events have been received since the last reset

getAndResetLastNewData

public com.espertech.esper.common.client.EventBean[] getAndResetLastNewData()

Description copied from interface: SupportListener

Returns the last array of events (insert stream) that were received and resets the listener.

Specified by:

getAndResetLastNewData in interface SupportListener

Returns:

insert stream events or null if either a null value was received or when no events have been received since the last reset

getAndResetLastOldData

public com.espertech.esper.common.client.EventBean[] getAndResetLastOldData()

Description copied from interface: SupportListener

Returns the last array of events (insert stream) that were received and resets the listener.

Specified by:

getAndResetLastOldData in interface SupportListener

Returns:

insert stream events or null if either a null value was received or when no events have been received since the last reset

assertOneGetNewAndReset

public com.espertech.esper.common.client.EventBean assertOneGetNewAndReset()

Description copied from interface: SupportListener

Asserts that exactly one insert stream event was received and no remove stream events, resets the listener clearing all state and returns the received event.

Specified by:

assertOneGetNewAndReset in interface SupportListener

Returns:

single insert-stream event

assertOneGetOldAndReset

public com.espertech.esper.common.client.EventBean assertOneGetOldAndReset()

Description copied from interface: SupportListener

Asserts that exactly one remove stream event was received and no insert stream events, resets the listener clearing all state and returns the received event.

Specified by:

assertOneGetOldAndReset in interface SupportListener

Returns:

single remove-stream event

assertPairGetIRAndReset

public com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean> assertPairGetIRAndReset()

Description copied from interface: SupportListener

Asserts that exactly one insert stream event and exactly one remove stream event was received, resets the listener clearing all state and returns the received events as a pair.

Specified by:

assertPairGetIRAndReset in interface SupportListener

Returns:

pair of insert-stream and remove-stream events

assertOneGetNew

public com.espertech.esper.common.client.EventBean assertOneGetNew()

Description copied from interface: SupportListener

Asserts that exactly one insert stream event was received not checking remove stream data, and returns the received event.

Specified by:

assertOneGetNew in interface SupportListener

Returns:

single insert-stream event

assertOneGetOld

public com.espertech.esper.common.client.EventBean assertOneGetOld()

Description copied from interface: SupportListener

Asserts that exactly one remove stream event was received not checking insert stream data, and returns the received event.

Specified by:

assertOneGetOld in interface SupportListener

Returns:

single remove-stream event

getNewDataList

public List<com.espertech.esper.common.client.EventBean[]> getNewDataList()

Description copied from interface: SupportListener

Get a list of all insert-stream event arrays received.

Specified by:

getNewDataList in interface SupportListener

Returns:

list of event arrays

getOldDataList

public List<com.espertech.esper.common.client.EventBean[]> getOldDataList()

Description copied from interface: SupportListener

Get a list of all remove-stream event arrays received.

Specified by:

getOldDataList in interface SupportListener

Returns:

list of event arrays

isInvoked

public boolean isInvoked()

Description copied from interface: SupportListener

Returns true if the listener was invoked at least once.

Specified by:

isInvoked in interface SupportListener

Returns:

invoked flag

getAndClearIsInvoked

public boolean getAndClearIsInvoked()

Description copied from interface: SupportListener

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

Specified by:

getAndClearIsInvoked in interface SupportListener

Returns:

invoked flag

getIsInvokedAndReset

public boolean getIsInvokedAndReset()

Description copied from interface: SupportListener

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

Specified by:

getIsInvokedAndReset in interface SupportListener

Returns:

invoked flag

setLastNewData

public void setLastNewData(com.espertech.esper.common.client.EventBean[] lastNewData)

Set an array of events as the last insert-stream events received.

Parameters:

lastNewData - to store

setLastOldData

public void setLastOldData(com.espertech.esper.common.client.EventBean[] lastOldData)

Set an array of events as the last remove-stream events received.

Parameters:

lastOldData - to store

getNewDataListFlattened

public com.espertech.esper.common.client.EventBean[] getNewDataListFlattened()

Description copied from interface: SupportListener

Returns an event array that represents all insert-stream events received so far.

Specified by:

getNewDataListFlattened in interface SupportListener

Returns:

event array

getOldDataListFlattened

public com.espertech.esper.common.client.EventBean[] getOldDataListFlattened()

Returns an event array that represents all remove-stream events received so far.

Specified by:

getOldDataListFlattened in interface SupportListener

Returns:

event array

assertInvokedAndReset

public com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> assertInvokedAndReset()

Description copied from interface: SupportListener

Returns a pair of insert and remove stream event arrays considering the last invocation only, asserting that only a single invocation occured, and resetting the listener.

Specified by:

assertInvokedAndReset in interface SupportListener

Returns:

pair of event arrays, the first in the pair is the insert stream data, the second in the pair is the remove stream data

assertNotInvoked

public void assertNotInvoked()

Assert not invoked.

getDataListsFlattened

public com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> getDataListsFlattened()

Description copied from interface: SupportListener

Returns a pair of insert and remove stream event arrays considering the all invocations.

Specified by:

getDataListsFlattened in interface SupportListener

Returns:

pair of event arrays, the first in the pair is the insert stream data, the second in the pair is the remove stream data

getAndResetDataListsFlattened

public com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> getAndResetDataListsFlattened()

Description copied from interface: SupportListener

Returns a pair of insert and remove stream event arrays considering the all invocations, and resets the listener.

Specified by:

getAndResetDataListsFlattened in interface SupportListener

Returns:

pair of event arrays, the first in the pair is the insert stream data, the second in the pair is the remove stream data

getInvokedFlagsAndReset

public static boolean[] getInvokedFlagsAndReset(SupportUpdateListener[] listeners)

For multiple listeners, return the invoked flags and reset each listener

Parameters:

listeners - listeners

Returns:

invoked flags

makeListeners

public static SupportUpdateListener[] makeListeners(int size)

Produce an array of listeners

Parameters:

size - of array

Returns:

array of listeners

assertNewOldData

public void assertNewOldData(Object[][] nameAndValuePairsIStream,
                             Object[][] nameAndValuePairsRStream)

Description copied from interface: SupportListener

Asserts name-value pairs of insert and remove stream events

Specified by:

assertNewOldData in interface SupportListener

Parameters:

nameAndValuePairsIStream - insert-stream assertions

nameAndValuePairsRStream - remove-stream assertions

assertGetAndResetIRPair

public com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean> assertGetAndResetIRPair()

Description copied from interface: SupportListener

Asserts that there is exactly one insert-stream event and one remove-stream event available and resets.

Specified by:

assertGetAndResetIRPair in interface SupportListener

Returns:

pair of insert-stream event and remove-stream event

getAndResetIRPair

public com.espertech.esper.common.internal.collection.UniformPair<com.espertech.esper.common.client.EventBean[]> getAndResetIRPair()

Description copied from interface: SupportListener

Returns a pair of last-invocation insert and remove stream events and resets

Specified by:

getAndResetIRPair in interface SupportListener

Returns:

pair of events