Skip to content

Commit a2b8743

Browse files
committed
fixed checkstyle errors
1 parent 0051d3f commit a2b8743

File tree

6 files changed

+13
-13
lines changed

6 files changed

+13
-13
lines changed

polling-publisher/polling-service/src/main/java/com/iluwatar/polling/App.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -34,14 +34,14 @@
3434
*/
3535
@SpringBootApplication
3636
@EnableScheduling
37-
public class App{
37+
public class App {
3838

3939
/**
4040
* Program entry point.
4141
*
4242
* @param args command line args.
4343
*/
44-
public static void main(String[] args){
44+
public static void main(String[] args) {
4545
SpringApplication.run(PollingApplication.class, args);
4646
}
4747
}

polling-publisher/polling-service/src/main/java/com/iluwatar/polling/DataRepository.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,6 @@
3131
* Data repository to keep or store data.
3232
* */
3333
@Repository
34-
public class DataRepository{
34+
public class DataRepository {
3535
// Simulate a repository for data access
3636
}

polling-publisher/polling-service/src/main/java/com/iluwatar/polling/DataSourceService.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -32,12 +32,12 @@
3232
* This class is responsible for keep the events.
3333
*/
3434
@Service
35-
public class DataSourceService{
35+
public class DataSourceService {
3636

3737
/**
3838
* Function to fetch data from DataRepository.
3939
* */
40-
public String fetchData(){
40+
public String fetchData() {
4141
// Simulate fetching data from a data source
4242
return "Sample Data " + System.currentTimeMillis();
4343
}

polling-publisher/polling-service/src/main/java/com/iluwatar/polling/KafkaProducer.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -34,11 +34,11 @@
3434
* This class is responsible for sending messages to Kafka.
3535
*/
3636
@Service
37-
public class KafkaProducer{
37+
public class KafkaProducer {
3838

3939
private final KafkaTemplate<String, String> kafkaTemplate;
4040

41-
public KafkaProducer(KafkaTemplate<String, String> kafkaTemplate){
41+
public KafkaProducer(KafkaTemplate<String, String> kafkaTemplate) {
4242
this.kafkaTemplate = kafkaTemplate;
4343
}
4444

@@ -47,7 +47,7 @@ public KafkaProducer(KafkaTemplate<String, String> kafkaTemplate){
4747
*
4848
* @param message The message to send.
4949
*/
50-
public void sendMessage(String message){
50+
public void sendMessage(String message) {
5151
kafkaTemplate.send("updates", message);
5252
}
5353
}

polling-publisher/polling-service/src/main/java/com/iluwatar/polling/PollingController.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -32,10 +32,10 @@
3232
* This class is responsible for contolling polling tasks.
3333
*/
3434
@RestController
35-
public class PollingController{
35+
public class PollingController {
3636

3737
@GetMapping("/health")
38-
public String healthCheck(){
38+
public String healthCheck() {
3939
return "Polling Service is up and running!";
4040
}
4141
}

polling-publisher/polling-service/src/main/java/com/iluwatar/polling/PollingSchedular.java renamed to polling-publisher/polling-service/src/main/java/com/iluwatar/polling/PollingScheduler.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@
3333
* This class is responsible for scheduling polling tasks.
3434
*/
3535
@Component
36-
public class PollingScheduler{
36+
public class PollingScheduler {
3737

3838
@Autowired
3939
private DataSourceService dataSourceService;
@@ -45,9 +45,9 @@ public class PollingScheduler{
4545
* schedular for poll data on each 5 second.
4646
* */
4747
@Scheduled(fixedRate = 5000) // Poll every 5 seconds
48-
public void pollDataSource(){
48+
public void pollDataSource() {
4949
String data = dataSourceService.fetchData();
50-
if(data != null){
50+
if (data != null) {
5151
kafkaProducer.sendMessage(data);
5252
}
5353
}

0 commit comments

Comments
 (0)