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.
Copyright © 2013
Software AG, Darmstadt, Germany and/or Software AG USA Inc., Reston, VA, USA, and/or Terracotta Inc., San Francisco, CA, USA, and/or Software AG (Canada) Inc., Cambridge, Ontario, Canada, and/or, Software AG (UK) Ltd., Derby, United Kingdom, and/or Software A.G. (Israel) Ltd., Or-Yehuda, Israel and/or their licensors.