Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Migrate Kafka domain service to new module system #2455

Merged
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
a16c7d8
feat(kafka): modules - add dependency and docker compose
fdelbrayelle Jul 8, 2022
62e34fc
feat(kafka): modules - add properties
fdelbrayelle Jul 8, 2022
169bfdb
feat(kafka): modules - testcontainers
fdelbrayelle Jul 8, 2022
539d8db
feat(kafka): modules - add config
fdelbrayelle Jul 8, 2022
6f9ca99
feat(kafka): modules - documentation
fdelbrayelle Jul 8, 2022
f563607
feat(kafka): use addDependency
fdelbrayelle Jul 11, 2022
734c0e7
feat(kafka): code review feedback
fdelbrayelle Jul 11, 2022
8217802
feat(kafka): link module to primary for init part
fdelbrayelle Jul 11, 2022
e3f9f2d
feat(kafka): format code
fdelbrayelle Jul 11, 2022
c115514
fix(kafka): integration test replacements
fdelbrayelle Jul 11, 2022
5958e81
feat(kafka): rename method
fdelbrayelle Jul 11, 2022
1daa8b1
feat(kafka): remove unused code
fdelbrayelle Jul 11, 2022
3fd371d
feat(kafka): modules - dummy - topic property
fdelbrayelle Jul 11, 2022
9f2a46f
feat(kafka): remove unused attribute
fdelbrayelle Jul 11, 2022
4b5aaf3
feat(kafka): modules - dummy - files
fdelbrayelle Jul 11, 2022
1e23421
feat(kafka): modules - akhq
fdelbrayelle Jul 11, 2022
ce98247
feat(kafka): modules - akhq - remove unused code
fdelbrayelle Jul 11, 2022
f052a69
feat(kafka): sonar
fdelbrayelle Jul 11, 2022
52614bd
fix(kafka): dependencies versions
fdelbrayelle Jul 12, 2022
43662e1
fix(kafka): add missing base package
fdelbrayelle Jul 12, 2022
e105ce1
fix(kafka): properties for tests
fdelbrayelle Jul 12, 2022
b8c7e9f
fix(kafka): feature (and add all generated files)
fdelbrayelle Jul 12, 2022
8b953a4
fix(kafka): code review feedback
fdelbrayelle Jul 12, 2022
abebdac
fix(kafka): code review feedback
fdelbrayelle Jul 13, 2022
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -62,10 +62,6 @@ private GeneratorAction() {}

public static final String REACT_CYPRESS = "react-cypress";

public static final String SPRINGBOOT_KAFKA = "springboot-kafka";
public static final String SPRINGBOOT_KAFKA_DUMMY_PRODUCER_CONSUMER = "springboot-kafka-dummy-producer-consumer";
public static final String SPRINGBOOT_KAFKA_AKHQ = "springboot-kafka-akhq";

public static final String SPRINGBOOT_PULSAR = "springboot-pulsar";

public static final String SPRINGBOOT_WEBFLUX_NETTY = "springboot-webflux-netty";
Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@
import tech.jhipster.lite.module.infrastructure.primary.JHipsterModuleResource;

@Configuration
class BannerResourceConfiguration {
class BannerModuleConfiguration {

private static final String TAG = "Spring Boot";

Expand Down
Original file line number Diff line number Diff line change
@@ -1,27 +1,29 @@
package tech.jhipster.lite.generator.server.springboot.broker.kafka.application;

import org.springframework.stereotype.Service;
import tech.jhipster.lite.generator.project.domain.Project;
import tech.jhipster.lite.generator.server.springboot.broker.kafka.domain.KafkaService;
import tech.jhipster.lite.docker.domain.DockerImages;
import tech.jhipster.lite.generator.server.springboot.broker.kafka.domain.KafkaModuleFactory;
import tech.jhipster.lite.module.domain.JHipsterModule;
import tech.jhipster.lite.module.domain.properties.JHipsterModuleProperties;

@Service
public class KafkaApplicationService {

private final KafkaService kafkaService;
private final KafkaModuleFactory kafkaModuleFactory;

public KafkaApplicationService(final KafkaService kafkaService) {
this.kafkaService = kafkaService;
public KafkaApplicationService(final DockerImages dockerImages) {
this.kafkaModuleFactory = new KafkaModuleFactory(dockerImages);
}

public void init(final Project project) {
kafkaService.init(project);
public JHipsterModule init(final JHipsterModuleProperties properties) {
return kafkaModuleFactory.buildModuleInit(properties);
}

public void addDummyProducerConsumer(final Project project) {
kafkaService.addDummyProducerConsumer(project);
public JHipsterModule addDummyProducerConsumer(final JHipsterModuleProperties properties) {
return kafkaModuleFactory.buildModuleDummyProducerConsumer(properties);
}

public void addAkhq(final Project project) {
kafkaService.addAkhq(project);
public JHipsterModule addAkhq(final JHipsterModuleProperties properties) {
return kafkaModuleFactory.buildModuleAkhq(properties);
}
}

This file was deleted.

Loading