public class OnDemandAuditJobUtil extends Object
Constructor and Description |
---|
OnDemandAuditJobUtil() |
Modifier and Type | Method and Description |
---|---|
static org.apache.http.impl.client.CloseableHttpClient |
buildHttpClient()
Returns http client to interact with rest server
|
static org.apache.http.client.methods.HttpPost |
buildKafkaHttpRequest(GetAuditJobStatusRequest getAuditJobStatusRequest)
Returns post request needed to get audit job status from Internal REST server
|
static org.apache.http.client.methods.HttpPost |
buildKafkaHttpRequest(StartAuditJobRequest startAuditJobRequest)
Returns post request needed to trigger start audit job api
|
static org.apache.http.client.methods.HttpGet |
buildKafkaHttpRequest(StopAuditJobRequest stopAuditJobRequest)
Return get request needed to stop audit job from Internal REST server
|
public static org.apache.http.client.methods.HttpPost buildKafkaHttpRequest(StartAuditJobRequest startAuditJobRequest) throws URISyntaxException
startAuditJobRequest
- is startAuditJobRequestURISyntaxException
- is thrown by URIBuilderpublic static org.apache.http.client.methods.HttpPost buildKafkaHttpRequest(GetAuditJobStatusRequest getAuditJobStatusRequest) throws URISyntaxException
getAuditJobStatusRequest
- GetAuditJobStatusRequestURISyntaxException
- is thrown by URIBuilderpublic static org.apache.http.client.methods.HttpGet buildKafkaHttpRequest(StopAuditJobRequest stopAuditJobRequest) throws URISyntaxException
stopAuditJobRequest
- is instance of StopAuditJobRequestURISyntaxException
- is thrown by URIBuilderpublic static org.apache.http.impl.client.CloseableHttpClient buildHttpClient()