Skip to content

Commit 86e3406

Browse files
authored
chore(plugins): move packages in plugins (#633)
1 parent befe087 commit 86e3406

File tree

91 files changed

+167
-162
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

91 files changed

+167
-162
lines changed

springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/ExampleValueGenerator.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ public interface ExampleValueGenerator<T, R> {
3939
String lookupSchemaName(Schema schema);
4040

4141
/**
42-
* @return The serializable representation of the example (object for json & yaml, string for others)
42+
* @return The serializable representation of the example (object for json and yaml, string for others)
4343
*/
4444
R prepareForSerialization(Schema name, T exampleObject);
4545

springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/producers/AnotherProducer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
55
import io.github.springwolf.core.asyncapi.annotations.AsyncPublisher;
66
import io.github.springwolf.examples.amqp.dtos.AnotherPayloadDto;
7-
import io.github.springwolf.plugins.amqp.scanners.channels.operationdata.annotation.AmqpAsyncOperationBinding;
7+
import io.github.springwolf.plugins.amqp.asyncapi.annotations.AmqpAsyncOperationBinding;
88
import lombok.RequiredArgsConstructor;
99
import org.springframework.amqp.rabbit.core.RabbitTemplate;
1010
import org.springframework.stereotype.Component;

springwolf-examples/springwolf-jms-example/src/main/java/io/github/springwolf/examples/jms/producers/AnotherProducer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
66
import io.github.springwolf.core.asyncapi.annotations.AsyncPublisher;
77
import io.github.springwolf.examples.jms.dtos.AnotherPayloadDto;
8-
import io.github.springwolf.plugins.jms.scanners.channels.operationdata.annotation.JmsAsyncOperationBinding;
8+
import io.github.springwolf.plugins.jms.asyncapi.annotations.JmsAsyncOperationBinding;
99
import lombok.RequiredArgsConstructor;
1010
import org.springframework.jms.core.JmsTemplate;
1111
import org.springframework.stereotype.Component;

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/AvroConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import io.github.springwolf.core.asyncapi.annotations.AsyncListener;
55
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
66
import io.github.springwolf.examples.kafka.dto.avro.AnotherPayloadAvroDto;
7-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
7+
import io.github.springwolf.plugins.kafka.asyncapi.annotations.KafkaAsyncOperationBinding;
88
import lombok.RequiredArgsConstructor;
99
import lombok.extern.slf4j.Slf4j;
1010
import org.springframework.kafka.annotation.KafkaListener;

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleClassLevelKafkaListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
66
import io.github.springwolf.examples.kafka.dtos.AnotherPayloadDto;
77
import io.github.springwolf.examples.kafka.dtos.ExamplePayloadDto;
8-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
8+
import io.github.springwolf.plugins.kafka.asyncapi.annotations.KafkaAsyncOperationBinding;
99
import lombok.extern.slf4j.Slf4j;
1010
import org.springframework.kafka.annotation.KafkaHandler;
1111
import org.springframework.kafka.annotation.KafkaListener;

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/StringConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import io.github.springwolf.core.asyncapi.annotations.AsyncApiPayload;
55
import io.github.springwolf.core.asyncapi.annotations.AsyncListener;
66
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
7-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
7+
import io.github.springwolf.plugins.kafka.asyncapi.annotations.KafkaAsyncOperationBinding;
88
import io.swagger.v3.oas.annotations.media.Schema;
99
import lombok.Data;
1010
import lombok.RequiredArgsConstructor;

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/XmlConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import io.github.springwolf.core.asyncapi.annotations.AsyncMessage;
66
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
77
import io.github.springwolf.examples.kafka.dtos.XmlPayloadDto;
8-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
8+
import io.github.springwolf.plugins.kafka.asyncapi.annotations.KafkaAsyncOperationBinding;
99
import lombok.RequiredArgsConstructor;
1010
import lombok.extern.slf4j.Slf4j;
1111
import org.springframework.kafka.annotation.KafkaListener;

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/YamlConsumer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import io.github.springwolf.core.asyncapi.annotations.AsyncMessage;
66
import io.github.springwolf.core.asyncapi.annotations.AsyncOperation;
77
import io.github.springwolf.examples.kafka.dtos.YamlPayloadDto;
8-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
8+
import io.github.springwolf.plugins.kafka.asyncapi.annotations.KafkaAsyncOperationBinding;
99
import lombok.RequiredArgsConstructor;
1010
import lombok.extern.slf4j.Slf4j;
1111
import org.springframework.kafka.annotation.KafkaListener;

springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/producers/NestedProducer.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,7 @@
66
import io.github.springwolf.core.asyncapi.components.headers.AsyncHeadersCloudEventConstants;
77
import io.github.springwolf.examples.kafka.configuration.KafkaConfiguration;
88
import io.github.springwolf.examples.kafka.dtos.NestedPayloadDto;
9-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding;
10-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding.KafkaAsyncKey;
11-
import io.github.springwolf.plugins.kafka.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding.KafkaAsyncMessageBinding;
9+
import io.github.springwolf.plugins.kafka.asyncapi.annotations.KafkaAsyncOperationBinding;
1210
import org.springframework.beans.factory.annotation.Autowired;
1311
import org.springframework.http.MediaType;
1412
import org.springframework.kafka.core.KafkaTemplate;
@@ -66,8 +64,11 @@ public class NestedProducer {
6664
@KafkaAsyncOperationBinding(
6765
clientId = "foo-clientId",
6866
messageBinding =
69-
@KafkaAsyncMessageBinding(
70-
key = @KafkaAsyncKey(description = "Kafka Producer Message Key", example = "example-key")))
67+
@KafkaAsyncOperationBinding.KafkaAsyncMessageBinding(
68+
key =
69+
@KafkaAsyncOperationBinding.KafkaAsyncKey(
70+
description = "Kafka Producer Message Key",
71+
example = "example-key")))
7172
public void sendMessage(NestedPayloadDto msg) {
7273
kafkaTemplate.send(KafkaConfiguration.PRODUCER_TOPIC, msg);
7374
}

springwolf-examples/springwolf-kafka-example/src/test/java/io/github/springwolf/examples/kafka/ProducerSystemTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@
99
import io.github.springwolf.examples.kafka.dto.avro.ExamplePayloadAvroDto;
1010
import io.github.springwolf.examples.kafka.dto.proto.ExamplePayloadProtobufDto;
1111
import io.github.springwolf.examples.kafka.dtos.ExamplePayloadDto;
12+
import io.github.springwolf.plugins.kafka.configuration.properties.SpringwolfKafkaConfigProperties;
1213
import io.github.springwolf.plugins.kafka.producer.SpringwolfKafkaProducer;
13-
import io.github.springwolf.plugins.kafka.properties.SpringwolfKafkaConfigProperties;
1414
import org.apache.kafka.clients.admin.AdminClient;
1515
import org.apache.kafka.clients.admin.KafkaAdminClient;
1616
import org.junit.jupiter.api.MethodOrderer.OrderAnnotation;

0 commit comments

Comments
 (0)