public interface SendOperationsInterface
Modifier and Type | Method and Description |
---|---|
void |
flushEvents()
Wait for any outstanding events from previous
calls
sendEvents(Event...) or sendEvents(boolean, Event...) (where the boolean
is true) into the Engine, and then return. |
void |
sendEvents(boolean autoBatch,
Event... events)
Send events into the Engine, optionally not
performing rebatching the actual event sending.
|
void |
sendEvents(Event... events)
Send an array of Event objects to the engine (automatically rebatching the actual event sending for efficiency).
|
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.
|
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.
|
void |
sendEventsFromFile(java.util.List<java.lang.String> filenames,
int loop,
boolean utf8,
boolean autoBatch,
java.lang.String defaultChannel)
Send a number of events from a file or stdin, specifying the file
encoding detection mode and whether to auto-batch events or not.
|
void |
setCancelSendFileRead(boolean newCancelFileReadValue)
Setter for the cancelFileRead property for the Send operations.
|
void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop) throws EngineException
If a connection is not yet established, this method will request a connection.
The current implementation of this method does not perform automatic
batching of the events, but a future release may change this behaviour,
so please use the overloaded sendEventsFromFile(List, int, boolean, boolean)
method if you require control over this. Auto-batching will usually
provide better throughput.
NOTE: Change in behaviour at Apama 3.0 - previously we ignored any missing files, now an exception is thrown.
filenames
- Names of files to read event descriptions from. A file name "-" is taken to be stdin.loop
- Loop count for repeated reading of input data.EngineException
- Thrown if any exceptions occur in the Client SDK.void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop, boolean utf8) throws EngineException
If a connection is not yet established, this method will request a connection.
The current implementation of this method does not perform automatic
batching of the events, but a future release may change this behaviour,
so please use the overloaded sendEventsFromFile(List, int, boolean, boolean)
method if you require control over this. Auto-batching will usually
provide better throughput.
NOTE: Change in behaviour at Apama 3.0 - previously we ignored any missing files, now an exception is thrown.
filenames
- Names of files to read event descriptions from. A file name "-" is taken to be stdin.loop
- Loop count for repeated reading of input data.utf8
- If true
, the specified files will be read
as UTF-8; otherwise they will be read using the system default encoding
unless they begin with a unicode Byte Order Mark (BOM) character.EngineException
- Thrown if any exceptions occur in the Client SDK.void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop, boolean utf8, boolean autoBatch) throws EngineException
If a connection is not yet established, this method will request a connection.
NOTE: Change in behaviour at Apama 3.0 - previously we ignored any missing files, now an exception is thrown.
filenames
- Names of files to read event descriptions from. A file name "-" is taken to be stdin.loop
- Loop count for repeated reading of input data.utf8
- If true
, the specified files will be read
as UTF-8; otherwise they will be read using the system default encoding
unless they begin with a unicode Byte Order Mark (BOM) character.autoBatch
- If true
, events will be automatically
rebatched to improve throughputEngineException
- Thrown if any exceptions occur in the Client SDK.void sendEventsFromFile(java.util.List<java.lang.String> filenames, int loop, boolean utf8, boolean autoBatch, java.lang.String defaultChannel) throws EngineException
If a connection is not yet established, this method will request a connection.
NOTE: Change in behaviour at Apama 3.0 - previously we ignored any missing files, now an exception is thrown.
filenames
- Names of files to read event descriptions from. A file name "-" is taken to be stdin.loop
- Loop count for repeated reading of input data.utf8
- If true
, the specified files will be read
as UTF-8; otherwise they will be read using the system default encoding
unless they begin with a unicode Byte Order Mark (BOM) character.autoBatch
- If true
, events will be automatically
rebatched to improve throughputdefaultChannel
- Channel to use for events which aren't specified in the input fileEngineException
- Thrown if any exceptions occur in the Client SDK.void sendEvents(Event... events) throws EngineException
sendEvents(boolean, Event...)
method if you require control over the rebatching.
If a connection is not yet established, this method will request a connection.events
- An array with one or more Events to be sent.EngineException
- Thrown if any exceptions occur in the Client SDK.flushEvents()
void sendEvents(boolean autoBatch, Event... events) throws EngineException
autoBatch
- If true
, events will be automatically
rebatched to improve throughput (even across separate sendEvents calls)events
- The array of Events to be sent.EngineException
- Thrown if any exceptions occur in the Client SDK.flushEvents()
void flushEvents() throws EngineException, java.lang.InterruptedException
sendEvents(Event...)
or sendEvents(boolean, Event...)
(where the boolean
is true) into the Engine, and then return.EngineException
- Thrown if any exceptions occur in the Client SDK.java.lang.InterruptedException
- Thrown if this thread is interrupted
while waiting for outstanding events to be sent and acknowledged
(see Thread.interrupt()
.void setCancelSendFileRead(boolean newCancelFileReadValue)
newCancelFileReadValue
- New value for the cancelFileRead property.Submit a bug or feature
Copyright (c) 2013-2022 Software AG, Darmstadt, Germany and/or Software AG USA Inc., Reston, VA, USA, and/or its subsidiaries and/or its affiliates and/or their licensors. Use, reproduction, transfer, publication or disclosure is prohibited except as specifically provided for in your License Agreement with Software AG.