Skip to content

Commit

Permalink
Move kafka to wire
Browse files Browse the repository at this point in the history
  • Loading branch information
DamnClin committed Aug 14, 2023
1 parent eb5c2b7 commit 733b83e
Show file tree
Hide file tree
Showing 7 changed files with 10 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
public class KafkaModuleFactory {

private static final JHipsterSource SOURCE = from("server/springboot/broker/kafka");
private static final String TECHNICAL_INFRASTRUCTURE_CONFIG_KAFKA = "/technical/infrastructure/config/kafka";
private static final String TECHNICAL_INFRASTRUCTURE_CONFIG_KAFKA = "/wire/kafka/infrastructure/config";
private static final String DUMMY_INFRASTRUCTURE_SECONDARY_KAFKA_PRODUCER = "dummy/infrastructure/secondary/kafka/producer";
private static final String DUMMY_INFRASTRUCTURE_PRIMARY_KAFKA_CONSUMER = "dummy/infrastructure/primary/kafka/consumer";
private static final String STRING_DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer";
Expand Down
2 changes: 1 addition & 1 deletion src/main/resources/config/application.properties
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ [email protected]@

jhlite-hidden-resources.tags=banner
# gradle is hidden until it is fully supported
jhlite-hidden-resources.slugs=gradle-java,spring-boot-kafka-dummy-producer-consumer,svelte-core
jhlite-hidden-resources.slugs=gradle-java,svelte-core

# Spring Boot Actuator
management.endpoints.web.base-path=/management
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package {{packageName}}.technical.infrastructure.config.kafka;
package {{packageName}}.wire.kafka.infrastructure.config;

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package {{packageName}}.technical.infrastructure.config.kafka;
package {{packageName}}.wire.kafka.infrastructure.config;

import java.util.HashMap;
import java.util.Map;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
package {{packageName}}.technical.infrastructure.config.kafka;
package {{packageName}}.wire.kafka.infrastructure.config;

import static org.assertj.core.api.Assertions.assertThat;

Expand Down
4 changes: 2 additions & 2 deletions src/test/features/server/broker/apache-kafka.feature
Original file line number Diff line number Diff line change
Expand Up @@ -9,9 +9,9 @@ Feature: Apache Kafka
| kafka.yml |
Then I should have files in "src/test/java/tech/jhipster/chips"
| KafkaTestContainerExtension.java |
Then I should have files in "src/test/java/tech/jhipster/chips/technical/infrastructure/config/kafka"
Then I should have files in "src/test/java/tech/jhipster/chips/wire/kafka/infrastructure/config"
| KafkaPropertiesTest.java |
Then I should have files in "src/main/java/tech/jhipster/chips/technical/infrastructure/config/kafka"
Then I should have files in "src/main/java/tech/jhipster/chips/wire/kafka/infrastructure/config"
| KafkaProperties.java |
| KafkaConfiguration.java |

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -79,11 +79,11 @@ void shouldBuildKafkaModuleInit() {
.hasFile("src/test/java/com/jhipster/test/IntegrationTest.java")
.containing("@ExtendWith(KafkaTestContainerExtension.class)")
.and()
.hasFile("src/main/java/com/jhipster/test/technical/infrastructure/config/kafka/KafkaProperties.java")
.hasFile("src/main/java/com/jhipster/test/wire/kafka/infrastructure/config/KafkaProperties.java")
.and()
.hasFile("src/test/java/com/jhipster/test/technical/infrastructure/config/kafka/KafkaPropertiesTest.java")
.hasFile("src/test/java/com/jhipster/test/wire/kafka/infrastructure/config/KafkaPropertiesTest.java")
.and()
.hasFile("src/main/java/com/jhipster/test/technical/infrastructure/config/kafka/KafkaConfiguration.java")
.hasFile("src/main/java/com/jhipster/test/wire/kafka/infrastructure/config/KafkaConfiguration.java")
.and()
.hasPrefixedFiles("documentation", "apache-kafka.md")
.hasFile("README.md")
Expand Down

0 comments on commit 733b83e

Please sign in to comment.