Send operations
The send operations are defined in the interface com.apama.engine.beans.interfaces.SendOperationsInterface.
These are implemented in com.apama.engine.beans.EngineClientBean.
The send operations are:
void sendEvents(Event[] events) - Send an array of
Event objects to the remote correlator. An
Event object represents an event instance. The events are automatically rebatched with this method.
void sendEvents(boolean autoBatch, Event... events) - Send events into the Engine (inherited from
EventConsumer), optionally performing auto-batching. If
autoBatch is true, events will be automatically rebatched to improve throughput (even across separate
sendEvents calls). The
events parameter is the array of Events to be sent.
void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop) - Send a number of events from a file or
stdin.
void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop,boolean utf8) - Send a number of events from a file or
stdin. If a connection is not yet established, this method will request a connection.
This method will not perform auto-batching. For higher performance, use sendEventsFromFile(List, int, boolean, boolean).
void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop, boolean utf8, boolean autoBatch) - Send a number of events from a file or
stdin, specifying the file encoding detection mode and whether to auto-batch events or not. If a connection is not yet established, this method will request a connection.
void flushEvents() - Wait for any outstanding events from previous
SendOperationsInterface#sendEvents(Event...) calls into the Engine, and then return.
void setCancelSendFileRead(boolean newCancelFileReadValue) - Setter for the “
cancelFileRead” property for the Send operations. The purpose of the “
cancelFileRead” property is to provide a mechanism to cleanly terminate the processing of events from file, when the
sendEventsFromFile method is in progress. When “
cancelFileRead” is set to true, the event sending loop will terminate at the next iteration.