Skip to content

Commit

Permalink
Version bump 2.4.0
Browse files Browse the repository at this point in the history
  • Loading branch information
chinmoy12c committed Nov 27, 2023
1 parent a5fef12 commit aeaccc9
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 29 deletions.
6 changes: 3 additions & 3 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -10,14 +10,14 @@
</parent>
<groupId>com.uci</groupId>
<artifactId>broadcast-transformer</artifactId>
<version>2.3.0</version>
<version>2.4.0</version>
<name>broadcast-transformer</name>
<description>Demo project for Spring Boot</description>

<properties>
<java.version>11</java.version>
<utils.version>2.3.0-SNAPSHOT</utils.version>
<messagerosa.version>2.3.0-SNAPSHOT</messagerosa.version>
<utils.version>2.4.0</utils.version>
<messagerosa.version>2.4.0</messagerosa.version>
</properties>

<!-- For Downloading repositories from github packages -->
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,6 @@
import com.uci.utils.model.ApiResponseParams;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.actuate.health.Status;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
Expand All @@ -32,9 +31,6 @@ public class HealthController {
@Autowired
public SimpleProducer kafkaProducer;

@Value("${test.transformer.xmessage}")
private String testTransformerXmessage;

@RequestMapping(value = "/health", method = RequestMethod.GET, produces = {"application/json", "text/json"})
public Mono<ResponseEntity<ApiResponse>> statusCheck() {
return healthService.getAllHealthNode().map(health -> ApiResponse.builder()
Expand Down Expand Up @@ -76,26 +72,4 @@ public ResponseEntity<String> testNotification(@RequestParam(value = "size", req
return new ResponseEntity<>(ex.getMessage(), HttpStatus.BAD_REQUEST);
}
}

@RequestMapping(value = "/testTransformer", method = RequestMethod.GET, produces = {"application/json", "text/json"})
public ResponseEntity<String> testTransformer(@RequestParam(value = "size", required = false) String size) {
try {
Date start = new Date();
long longSize = 0;
if (size != null && !size.isEmpty()) {
longSize = Long.parseLong(size);
} else {
longSize = 0;
}
for (long i = 0; i < longSize; i++) {
log.info("push notification count : " + i);
kafkaProducer.send("com.odk.transformer", testTransformerXmessage);
}
Date endDate = new Date();
return new ResponseEntity<>("process complete start date : " + start + " end : " + endDate, HttpStatus.OK);
} catch (Exception ex) {
ex.printStackTrace();
return new ResponseEntity<>(ex.getMessage(), HttpStatus.BAD_REQUEST);
}
}
}

0 comments on commit aeaccc9

Please sign in to comment.