...
Code Block | ||||||
---|---|---|---|---|---|---|
| ||||||
• // THIS IS A SAMPLE OF THE REQUEST EXECUTION. REQUESTS CAN BE EXECUTED ONLY AFTER THE eaglemlApi.start() is called.
Map<String, String> parameters = new HashMap<String, String>();
// Add the parameters required to build an URI
// Generate a unique correlationId
// Add the attachments for the POST request
eaglemlApi.executeRestRequestAsync("GET", "/eagle/v2/manager-relationships", parameters, correlationId, businessTaskId, correlationId null, 600 /* timeout in seconds */, (result, exception) -> {
if(exception != null) {
// There was an exception while executing the request. Process it.
} else {
switch(result.getResultStatus()) {
case EagleApiResultStatus.SUCCESS:
List<IEagleApiResultDataFile> files = result.getDataFiles();
for (IEagleApiResultDataFile file : files) {
// See the java doc for the IEagleApiResultDataFile. The file will represent one extract.
// Currently EaglemlApi will produce only one file.
// You can get a stream of uncompressed data:
try(InputStream stream = file.getStream()) {
// Parse the extract and execute any transformations - for example to JSON
}
// If needed you can get the compressed data and get access to the file with the file.isInMemory(), file.getData(), file.getFile()
// The temporary files (if any) created while processing the extracts will be removed when you close the IEagleApiResult instance.
// If you want to preserve you'll have to move/copy them here.
}
break;
case EagleApiResultStatus.TIMEOUT:
// TIMEOUT - report an error
break;
case EagleApiResultStatus.ERROR:
// ERROR - use result.getErrorMessage to get the error message
break;
case EagleApiResultStatus.STOPPED:
// The request execution was stopped, when eaglemlApi.stop() is called
break;
case EagleApiResultStatus.NO_DATA:
// The extract resulted in no data retrieved. Report this back.
break;
}
}
});
|
...