Skip navigation links

com.bea.wlevs.ede.api
Interface StreamSender

All Known Subinterfaces:

BatchRelationSender, BatchStreamSender, BoundStatement, EventChannel, com.bea.wlevs.ede.api.EventSinkManager, PreparedStatement, RelationSender, Statement, Stream

public interface StreamSender

A StreamSender sends events emitted by an StreamSource to StreamSink listeners.

See Also:

StreamSource, StreamSink

Method Summary

void	sendHeartbeat(long timestamp) Send an event of type heart-beat downstream to StreamSink listeners in the EPN.
void	sendInsertEvent(java.lang.Object event) Send an event of type insert downstream to StreamSink listeners in the EPN.

Method Detail

sendInsertEvent

public void sendInsertEvent(java.lang.Object event)
                     throws EventRejectedException

Send an event of type insert downstream to StreamSink listeners in the EPN. Events of type insert are used to model streams.

Parameters:

event - Object

Throws:

EventRejectedException -

sendHeartbeat

public void sendHeartbeat(long timestamp)

Send an event of type heart-beat downstream to StreamSink listeners in the EPN. Events of type heart-beat are used to model the advance of time. The parameter timestamp should specify the new value of time.

Sending of heart-beat only applies to application-timestamped channels.

For system-timestamped channels, the infrastructure will assign a new time from the CPU clock in two conditions: when a new event arrives, and when the configurable heart-beat timeout expires, see EventChannelMBean

Parameters:

timestamp - time-stamp value in the application's time domain when the heart-beat was generated