+ @PostMapping(path = JOB_ERROR_URL, produces = MediaType.APPLICATION_JSON_VALUE)
+ @ApiOperation(value = "Callback for EI job creation, returns error", notes = "", hidden = true)
+ @ApiResponses(
+ value = { //
+ @ApiResponse(code = 200, message = "OK", response = VoidResponse.class)}//
+ )
+ public ResponseEntity<Object> jobCreatedCallbackReturnError( //
+ @RequestBody ProducerJobInfo request) {
+ logger.info("Job created (returning error) callback {}", request.id);
+ this.testResults.noOfRejectedCreate += 1;
+ return ErrorResponse.create("Producer returns error on create job", HttpStatus.NOT_FOUND);
+ }
+
+ @DeleteMapping(path = JOB_ERROR_URL + "/{eiJobId}", produces = MediaType.APPLICATION_JSON_VALUE)
+ @ApiOperation(value = "Callback for EI job creation, returns error", notes = "", hidden = true)
+ @ApiResponses(
+ value = { //
+ @ApiResponse(code = 200, message = "OK", response = VoidResponse.class)}//
+ )
+ public ResponseEntity<Object> jobDeletedCallbackReturnError( //
+ @RequestBody ProducerJobInfo request) {
+ logger.info("Job created (returning error) callback {}", request.id);
+ this.testResults.noOfRejectedDelete += 1;
+ return ErrorResponse.create("Producer returns error on delete job", HttpStatus.NOT_FOUND);
+ }
+
+ @GetMapping(path = SUPERVISION_URL, produces = MediaType.APPLICATION_JSON_VALUE)
+ @ApiOperation(value = "Producer supervision", notes = "")
+ @ApiResponses(
+ value = { //
+ @ApiResponse(code = 200, message = "OK", response = String.class)}//
+ )
+ public ResponseEntity<Object> producerSupervision() {
+ logger.info("Producer supervision");
+ return new ResponseEntity<>(HttpStatus.OK);
+ }
+
+ @GetMapping(path = SUPERVISION_ERROR_URL, produces = MediaType.APPLICATION_JSON_VALUE)
+ @ApiOperation(value = "Producer supervision error", notes = "", hidden = true)
+ @ApiResponses(
+ value = { //
+ @ApiResponse(code = 200, message = "OK", response = String.class)}//
+ )
+ public ResponseEntity<Object> producerSupervisionError() {
+ logger.info("Producer supervision error");
+ return new ResponseEntity<>(HttpStatus.NOT_FOUND);
+ }
+