From 7662b78e1c63a535226e85c2b6bee75d926fdb5d Mon Sep 17 00:00:00 2001 From: Timon Back Date: Fri, 6 Oct 2023 14:50:57 +0200 Subject: [PATCH 1/2] chore(kafka): move SpringwolfKafkaTemplateFactoryTest to producer package --- .../SpringwolfKafkaTemplateFactoryTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) rename springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/{configuration => producer}/SpringwolfKafkaTemplateFactoryTest.java (94%) diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/configuration/SpringwolfKafkaTemplateFactoryTest.java b/springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactoryTest.java similarity index 94% rename from springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/configuration/SpringwolfKafkaTemplateFactoryTest.java rename to springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactoryTest.java index 1ae80ee80..fadd4e448 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/configuration/SpringwolfKafkaTemplateFactoryTest.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/test/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactoryTest.java @@ -1,8 +1,7 @@ // SPDX-License-Identifier: Apache-2.0 -package io.github.stavshamir.springwolf.configuration; +package io.github.stavshamir.springwolf.producer; import io.github.stavshamir.springwolf.configuration.properties.SpringwolfKafkaConfigProperties; -import io.github.stavshamir.springwolf.producer.SpringwolfKafkaTemplateFactory; import org.junit.jupiter.api.Test; import org.springframework.boot.autoconfigure.kafka.KafkaProperties; import org.springframework.kafka.core.KafkaTemplate; From 92f8b9d498ccd3af8ec86b3c314db44bc4f5879d Mon Sep 17 00:00:00 2001 From: Timon Back Date: Fri, 6 Oct 2023 15:57:31 +0200 Subject: [PATCH 2/2] refactor(core): remove unused `@Component` and `@Service` annotation As suggested in the PR Co-authored-by: sam0r040 <93372330+sam0r040@users.noreply.github.com> --- .../DefaultAsyncApiSerializerService.java | 2 -- .../asyncapi/DefaultAsyncApiService.java | 2 -- .../asyncapi/DefaultChannelsService.java | 2 -- .../SpringwolfInitApplicationListener.java | 2 -- .../ActuatorAsyncApiController.java | 2 -- .../beans/DefaultBeanMethodsScanner.java | 2 -- .../ConsumerOperationDataScanner.java | 2 -- .../ProducerOperationDataScanner.java | 2 -- .../AsyncListenerAnnotationScanner.java | 2 -- .../AsyncPublisherAnnotationScanner.java | 2 -- .../classes/ComponentClassScanner.java | 2 -- .../classes/ConfigurationClassScanner.java | 2 -- .../DefaultAsyncApiDocketService.java | 2 -- .../schemas/DefaultSchemasService.java | 2 -- .../schemas/example/ExampleJsonGenerator.java | 2 -- .../ComponentClassScannerIntegrationTest.java | 21 ++++++++++--------- .../scanners/classes/TestComponent.java | 7 +++++++ .../TestOtherConditionalComponent.java | 2 -- .../amqp/consumers/ExampleConsumer.java | 4 ++-- .../ExampleClassLevelKafkaListener.java | 4 ++-- .../kafka/consumers/ExampleConsumer.java | 4 ++-- .../sqs/consumers/ExampleConsumer.java | 4 ++-- .../ClassLevelRabbitListenerScanner.java | 2 -- .../MethodLevelRabbitListenerScanner.java | 2 -- .../AmqpMessageBindingProcessor.java | 2 -- .../AmqpOperationBindingProcessor.java | 2 -- .../producer/SpringwolfAmqpProducer.java | 2 -- .../CloudStreamFunctionChannelsScanner.java | 2 -- .../ClassLevelKafkaListenerScanner.java | 2 -- .../MethodLevelKafkaListenerScanner.java | 2 -- .../KafkaMessageBindingProcessor.java | 2 -- .../KafkaOperationBindingProcessor.java | 2 -- .../SpringwolfKafkaTemplateFactory.java | 2 -- .../MethodLevelSqsListenerScanner.java | 2 -- .../SqsMessageBindingProcessor.java | 2 -- .../SqsOperationBindingProcessor.java | 2 -- .../producer/SpringwolfSqsProducer.java | 2 -- 37 files changed, 26 insertions(+), 80 deletions(-) create mode 100644 springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestComponent.java diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiSerializerService.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiSerializerService.java index 6139c5f56..e67e76d11 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiSerializerService.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiSerializerService.java @@ -13,9 +13,7 @@ import io.swagger.v3.core.util.Json; import io.swagger.v3.core.util.Yaml; import jakarta.annotation.PostConstruct; -import org.springframework.stereotype.Service; -@Service public class DefaultAsyncApiSerializerService implements AsyncApiSerializerService { private ObjectMapper jsonMapper = Json.mapper(); diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiService.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiService.java index 578843c01..eb948fee0 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiService.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultAsyncApiService.java @@ -9,13 +9,11 @@ import io.github.stavshamir.springwolf.schemas.SchemasService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Service; import java.util.List; import java.util.Map; @Slf4j -@Service @RequiredArgsConstructor public class DefaultAsyncApiService implements AsyncApiService { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultChannelsService.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultChannelsService.java index 55ea76475..7bce43aff 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultChannelsService.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultChannelsService.java @@ -6,7 +6,6 @@ import io.github.stavshamir.springwolf.asyncapi.scanners.channels.ChannelsScanner; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.List; @@ -16,7 +15,6 @@ * Service to detect AsyncAPI channels in the current spring context. */ @Slf4j -@Service @RequiredArgsConstructor public class DefaultChannelsService implements ChannelsService { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/SpringwolfInitApplicationListener.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/SpringwolfInitApplicationListener.java index b438ab8aa..fc55c772b 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/SpringwolfInitApplicationListener.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/SpringwolfInitApplicationListener.java @@ -8,7 +8,6 @@ import org.springframework.beans.factory.InitializingBean; import org.springframework.boot.context.event.ApplicationReadyEvent; import org.springframework.context.ApplicationListener; -import org.springframework.stereotype.Service; /** * Spring ApplicationListener listening on {@link ApplicationReadyEvent}. Triggers the AsyncAPI creation. @@ -17,7 +16,6 @@ */ @Slf4j @RequiredArgsConstructor -@Service public class SpringwolfInitApplicationListener implements ApplicationListener, InitializingBean { private final AsyncApiService asyncApiService; diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/controller/ActuatorAsyncApiController.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/controller/ActuatorAsyncApiController.java index f88d92e40..af6cb7686 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/controller/ActuatorAsyncApiController.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/controller/ActuatorAsyncApiController.java @@ -9,10 +9,8 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.boot.actuate.endpoint.web.annotation.RestControllerEndpoint; import org.springframework.http.MediaType; -import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.GetMapping; -@Component @Slf4j @RestControllerEndpoint(id = "springwolf") @RequiredArgsConstructor diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/beans/DefaultBeanMethodsScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/beans/DefaultBeanMethodsScanner.java index e653e458d..23a6a1d8b 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/beans/DefaultBeanMethodsScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/beans/DefaultBeanMethodsScanner.java @@ -4,7 +4,6 @@ import io.github.stavshamir.springwolf.asyncapi.scanners.classes.ConfigurationClassScanner; import lombok.RequiredArgsConstructor; import org.springframework.context.annotation.Bean; -import org.springframework.stereotype.Service; import java.lang.reflect.Method; import java.util.Arrays; @@ -14,7 +13,6 @@ import static java.util.stream.Collectors.toSet; -@Service @RequiredArgsConstructor public class DefaultBeanMethodsScanner implements BeanMethodsScanner { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ConsumerOperationDataScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ConsumerOperationDataScanner.java index 86b0fe2c3..fefaffea7 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ConsumerOperationDataScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ConsumerOperationDataScanner.java @@ -6,14 +6,12 @@ import io.github.stavshamir.springwolf.schemas.SchemasService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.List; @Slf4j @RequiredArgsConstructor -@Component public class ConsumerOperationDataScanner extends AbstractOperationDataScanner { private final AsyncApiDocketService asyncApiDocketService; diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ProducerOperationDataScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ProducerOperationDataScanner.java index 0833327b7..0de186c44 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ProducerOperationDataScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/ProducerOperationDataScanner.java @@ -6,14 +6,12 @@ import io.github.stavshamir.springwolf.schemas.SchemasService; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.List; @Slf4j @RequiredArgsConstructor -@Component public class ProducerOperationDataScanner extends AbstractOperationDataScanner { private final AsyncApiDocketService asyncApiDocketService; diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncListenerAnnotationScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncListenerAnnotationScanner.java index ccdc1dfaa..598fc7fa8 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncListenerAnnotationScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncListenerAnnotationScanner.java @@ -15,7 +15,6 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.context.EmbeddedValueResolverAware; import org.springframework.core.annotation.Order; -import org.springframework.stereotype.Component; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; @@ -27,7 +26,6 @@ @Slf4j @RequiredArgsConstructor -@Component @Order(value = ChannelPriority.ASYNC_ANNOTATION) public class AsyncListenerAnnotationScanner extends AbstractOperationDataScanner implements EmbeddedValueResolverAware { private StringValueResolver resolver; diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncPublisherAnnotationScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncPublisherAnnotationScanner.java index 8f000e680..7c2612f6d 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncPublisherAnnotationScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/annotation/AsyncPublisherAnnotationScanner.java @@ -15,7 +15,6 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.context.EmbeddedValueResolverAware; import org.springframework.core.annotation.Order; -import org.springframework.stereotype.Component; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; @@ -26,7 +25,6 @@ @Slf4j @RequiredArgsConstructor -@Component @Order(value = ChannelPriority.ASYNC_ANNOTATION) public class AsyncPublisherAnnotationScanner extends AbstractOperationDataScanner implements EmbeddedValueResolverAware { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScanner.java index a94127876..a6be1c3f2 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScanner.java @@ -4,9 +4,7 @@ import io.github.stavshamir.springwolf.configuration.AsyncApiDocketService; import org.springframework.core.env.Environment; import org.springframework.stereotype.Component; -import org.springframework.stereotype.Service; -@Service public class ComponentClassScanner extends AbstractAnnotatedClassScanner implements ClassScanner { public ComponentClassScanner(AsyncApiDocketService asyncApiDocketService, Environment environment) { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ConfigurationClassScanner.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ConfigurationClassScanner.java index dd1f26aba..a59f8d17e 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ConfigurationClassScanner.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ConfigurationClassScanner.java @@ -4,9 +4,7 @@ import io.github.stavshamir.springwolf.configuration.AsyncApiDocketService; import org.springframework.context.annotation.Configuration; import org.springframework.core.env.Environment; -import org.springframework.stereotype.Service; -@Service public class ConfigurationClassScanner extends AbstractAnnotatedClassScanner implements ClassScanner { public ConfigurationClassScanner(AsyncApiDocketService asyncApiDocketService, Environment environment) { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/configuration/DefaultAsyncApiDocketService.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/configuration/DefaultAsyncApiDocketService.java index 1f3eb0a41..5d096ddbe 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/configuration/DefaultAsyncApiDocketService.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/configuration/DefaultAsyncApiDocketService.java @@ -7,13 +7,11 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.lang.Nullable; -import org.springframework.stereotype.Service; import org.springframework.util.StringUtils; import java.util.Optional; @Slf4j -@Service @RequiredArgsConstructor public class DefaultAsyncApiDocketService implements AsyncApiDocketService { diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/DefaultSchemasService.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/DefaultSchemasService.java index 5a656be41..300145e4e 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/DefaultSchemasService.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/DefaultSchemasService.java @@ -9,7 +9,6 @@ import io.swagger.v3.oas.models.media.Schema; import io.swagger.v3.oas.models.media.StringSchema; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.HashMap; @@ -18,7 +17,6 @@ import java.util.Set; @Slf4j -@Service public class DefaultSchemasService implements SchemasService { private final ModelConverters converter = ModelConverters.getInstance(); diff --git a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/example/ExampleJsonGenerator.java b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/example/ExampleJsonGenerator.java index 31e514064..6563aa7b9 100644 --- a/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/example/ExampleJsonGenerator.java +++ b/springwolf-core/src/main/java/io/github/stavshamir/springwolf/schemas/example/ExampleJsonGenerator.java @@ -9,7 +9,6 @@ import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; -import org.springframework.stereotype.Component; import java.util.HashSet; import java.util.List; @@ -20,7 +19,6 @@ import static io.github.stavshamir.springwolf.configuration.properties.SpringwolfConfigConstants.SPRINGWOLF_SCHEMA_EXAMPLE_GENERATOR; -@Component @Slf4j @ConditionalOnProperty(name = SPRINGWOLF_SCHEMA_EXAMPLE_GENERATOR, havingValue = "buildin-json", matchIfMissing = true) public class ExampleJsonGenerator implements ExampleGenerator { diff --git a/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScannerIntegrationTest.java b/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScannerIntegrationTest.java index 0a07e963e..b85b5563a 100644 --- a/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScannerIntegrationTest.java +++ b/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/ComponentClassScannerIntegrationTest.java @@ -6,23 +6,28 @@ import io.github.stavshamir.springwolf.configuration.AsyncApiDocketService; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; -import org.junit.jupiter.api.extension.ExtendWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.ConfigurableBeanFactory; +import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.mock.mockito.MockBean; import org.springframework.core.env.Environment; import org.springframework.core.env.StandardEnvironment; import org.springframework.test.annotation.DirtiesContext; import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit.jupiter.SpringExtension; import java.util.Set; import static org.assertj.core.api.Assertions.assertThat; import static org.mockito.Mockito.when; -@ExtendWith(SpringExtension.class) -@ContextConfiguration(classes = {ComponentClassScanner.class}) +@SpringBootTest +@ContextConfiguration( + classes = { + ComponentClassScanner.class, + TestComponent.class, + TestConditionalComponent.class, + TestOtherConditionalComponent.class + }) @DirtiesContext class ComponentClassScannerIntegrationTest { @MockBean @@ -51,9 +56,7 @@ void getComponents() { Set> components = componentsScanner.scan(); assertThat(components) - .contains(ComponentClassScanner.class) - .contains(ConfigurationClassScanner.class) - .doesNotContain(ClassScanner.class) + .contains(TestComponent.class) .doesNotContain(TestConditionalComponent.class) .doesNotContain(TestOtherConditionalComponent.class); } @@ -66,10 +69,8 @@ void getComponentsIncludesConditional() { Set> components = componentsScanner.scan(); assertThat(components) - .contains(ComponentClassScanner.class) - .contains(ConfigurationClassScanner.class) + .contains(TestComponent.class) .contains(TestConditionalComponent.class) - .doesNotContain(ClassScanner.class) .doesNotContain(TestOtherConditionalComponent.class); } } diff --git a/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestComponent.java b/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestComponent.java new file mode 100644 index 000000000..dfaacc64c --- /dev/null +++ b/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestComponent.java @@ -0,0 +1,7 @@ +// SPDX-License-Identifier: Apache-2.0 +package io.github.stavshamir.springwolf.asyncapi.scanners.classes; + +import org.springframework.stereotype.Component; + +@Component +public class TestComponent {} diff --git a/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestOtherConditionalComponent.java b/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestOtherConditionalComponent.java index e40278a37..e44a4f01f 100644 --- a/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestOtherConditionalComponent.java +++ b/springwolf-core/src/test/java/io/github/stavshamir/springwolf/asyncapi/scanners/classes/TestOtherConditionalComponent.java @@ -2,8 +2,6 @@ package io.github.stavshamir.springwolf.asyncapi.scanners.classes; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; -import org.springframework.stereotype.Component; -@Component @ConditionalOnProperty("missing-property") public class TestOtherConditionalComponent {} diff --git a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/consumers/ExampleConsumer.java index 1a43ad1fa..6ebb65de4 100644 --- a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/stavshamir/springwolf/example/amqp/consumers/ExampleConsumer.java @@ -11,9 +11,9 @@ import org.springframework.amqp.rabbit.annotation.Queue; import org.springframework.amqp.rabbit.annotation.QueueBinding; import org.springframework.amqp.rabbit.annotation.RabbitListener; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; -@Service +@Component @Slf4j @RequiredArgsConstructor public class ExampleConsumer { diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleClassLevelKafkaListener.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleClassLevelKafkaListener.java index 59881167d..d6b09c6de 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleClassLevelKafkaListener.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleClassLevelKafkaListener.java @@ -10,13 +10,13 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.kafka.annotation.KafkaHandler; import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; import javax.money.MonetaryAmount; import static org.springframework.kafka.support.mapping.AbstractJavaTypeMapper.DEFAULT_CLASSID_FIELD_NAME; -@Service +@Component @Slf4j @KafkaListener(topics = "multi-payload-topic") public class ExampleClassLevelKafkaListener { diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleConsumer.java index c0d4cc539..784f6b5eb 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/stavshamir/springwolf/example/kafka/consumers/ExampleConsumer.java @@ -7,11 +7,11 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; import java.util.List; -@Service +@Component @RequiredArgsConstructor @Slf4j public class ExampleConsumer { diff --git a/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/stavshamir/springwolf/example/sqs/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/stavshamir/springwolf/example/sqs/consumers/ExampleConsumer.java index b73f63311..118cbcab5 100644 --- a/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/stavshamir/springwolf/example/sqs/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/stavshamir/springwolf/example/sqs/consumers/ExampleConsumer.java @@ -7,9 +7,9 @@ import io.github.stavshamir.springwolf.example.sqs.producers.AnotherProducer; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Service; +import org.springframework.stereotype.Component; -@Service +@Component @RequiredArgsConstructor @Slf4j public class ExampleConsumer { diff --git a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelRabbitListenerScanner.java b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelRabbitListenerScanner.java index b22d10e92..b4f0fb8c1 100644 --- a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelRabbitListenerScanner.java +++ b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelRabbitListenerScanner.java @@ -17,7 +17,6 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.context.EmbeddedValueResolverAware; import org.springframework.core.annotation.Order; -import org.springframework.stereotype.Service; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; @@ -25,7 +24,6 @@ import java.util.Map; @Slf4j -@Service @Order(value = ChannelPriority.AUTO_DISCOVERED) public class ClassLevelRabbitListenerScanner extends AbstractClassLevelListenerScanner implements ChannelsScanner, EmbeddedValueResolverAware { diff --git a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelRabbitListenerScanner.java b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelRabbitListenerScanner.java index f6ed8e20d..b07ffc5f8 100644 --- a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelRabbitListenerScanner.java +++ b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelRabbitListenerScanner.java @@ -15,7 +15,6 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.context.EmbeddedValueResolverAware; import org.springframework.core.annotation.Order; -import org.springframework.stereotype.Service; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; @@ -23,7 +22,6 @@ import java.util.Map; @Slf4j -@Service @Order(value = ChannelPriority.AUTO_DISCOVERED) public class MethodLevelRabbitListenerScanner extends AbstractMethodLevelListenerScanner implements ChannelsScanner, EmbeddedValueResolverAware { diff --git a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpMessageBindingProcessor.java b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpMessageBindingProcessor.java index ba2ee9523..978312ea2 100644 --- a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpMessageBindingProcessor.java +++ b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpMessageBindingProcessor.java @@ -5,14 +5,12 @@ import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AmqpAsyncOperationBinding; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.MessageBindingProcessor; import org.springframework.context.EmbeddedValueResolverAware; -import org.springframework.stereotype.Component; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; import java.util.Arrays; import java.util.Optional; -@Component public class AmqpMessageBindingProcessor implements MessageBindingProcessor, EmbeddedValueResolverAware { private StringValueResolver resolver; diff --git a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpOperationBindingProcessor.java b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpOperationBindingProcessor.java index 67077b002..8fd2b2676 100644 --- a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpOperationBindingProcessor.java +++ b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/AmqpOperationBindingProcessor.java @@ -4,11 +4,9 @@ import com.asyncapi.v2.binding.operation.amqp.AMQPOperationBinding; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.AbstractOperationBindingProcessor; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.AmqpAsyncOperationBinding; -import org.springframework.stereotype.Component; import java.util.Arrays; -@Component public class AmqpOperationBindingProcessor extends AbstractOperationBindingProcessor { @Override protected ProcessedOperationBinding mapToOperationBinding(AmqpAsyncOperationBinding bindingAnnotation) { diff --git a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfAmqpProducer.java b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfAmqpProducer.java index 5db24d4c5..7285c6569 100644 --- a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfAmqpProducer.java +++ b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfAmqpProducer.java @@ -9,14 +9,12 @@ import io.github.stavshamir.springwolf.asyncapi.types.AsyncAPI; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.core.RabbitTemplate; -import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import java.util.List; import java.util.Optional; @Slf4j -@Service public class SpringwolfAmqpProducer { private final AsyncApiService asyncApiService; diff --git a/springwolf-plugins/springwolf-cloud-stream-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/cloudstream/CloudStreamFunctionChannelsScanner.java b/springwolf-plugins/springwolf-cloud-stream-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/cloudstream/CloudStreamFunctionChannelsScanner.java index 215a07b28..bc2905375 100644 --- a/springwolf-plugins/springwolf-cloud-stream-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/cloudstream/CloudStreamFunctionChannelsScanner.java +++ b/springwolf-plugins/springwolf-cloud-stream-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/cloudstream/CloudStreamFunctionChannelsScanner.java @@ -20,7 +20,6 @@ import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.cloud.stream.config.BindingServiceProperties; -import org.springframework.stereotype.Service; import java.lang.reflect.Method; import java.util.Map; @@ -29,7 +28,6 @@ import static java.util.stream.Collectors.toMap; @Slf4j -@Service @RequiredArgsConstructor public class CloudStreamFunctionChannelsScanner implements ChannelsScanner { diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelKafkaListenerScanner.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelKafkaListenerScanner.java index 4bdeeab44..82386b774 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelKafkaListenerScanner.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/ClassLevelKafkaListenerScanner.java @@ -13,7 +13,6 @@ import org.springframework.context.EmbeddedValueResolverAware; import org.springframework.kafka.annotation.KafkaHandler; import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.stereotype.Service; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; @@ -22,7 +21,6 @@ import static io.github.stavshamir.springwolf.asyncapi.scanners.channels.annotation.SpringPayloadAnnotationTypeExtractor.getPayloadType; @Slf4j -@Service public class ClassLevelKafkaListenerScanner extends AbstractClassLevelListenerScanner implements ChannelsScanner, EmbeddedValueResolverAware { diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelKafkaListenerScanner.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelKafkaListenerScanner.java index 44c63125f..7d9e0888b 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelKafkaListenerScanner.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelKafkaListenerScanner.java @@ -10,14 +10,12 @@ import lombok.extern.slf4j.Slf4j; import org.springframework.context.EmbeddedValueResolverAware; import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.stereotype.Service; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; import java.util.Map; @Slf4j -@Service public class MethodLevelKafkaListenerScanner extends AbstractMethodLevelListenerScanner implements ChannelsScanner, EmbeddedValueResolverAware { diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaMessageBindingProcessor.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaMessageBindingProcessor.java index 0cf27bb91..e30a25fcd 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaMessageBindingProcessor.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaMessageBindingProcessor.java @@ -8,7 +8,6 @@ import io.swagger.v3.oas.models.media.Schema; import io.swagger.v3.oas.models.media.StringSchema; import org.springframework.context.EmbeddedValueResolverAware; -import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; import org.springframework.util.StringValueResolver; @@ -16,7 +15,6 @@ import java.util.Arrays; import java.util.Optional; -@Component public class KafkaMessageBindingProcessor implements MessageBindingProcessor, EmbeddedValueResolverAware { private StringValueResolver resolver; diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaOperationBindingProcessor.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaOperationBindingProcessor.java index bf6fc85b8..6be7185a9 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaOperationBindingProcessor.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/KafkaOperationBindingProcessor.java @@ -6,10 +6,8 @@ import io.github.stavshamir.springwolf.asyncapi.scanners.channels.AbstractOperationBindingProcessor; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.annotation.KafkaListenerUtil; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.KafkaAsyncOperationBinding; -import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; -@Component public class KafkaOperationBindingProcessor extends AbstractOperationBindingProcessor { @Override protected ProcessedOperationBinding mapToOperationBinding(KafkaAsyncOperationBinding bindingAnnotation) { diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactory.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactory.java index 1533e5edf..be700e1bc 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactory.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfKafkaTemplateFactory.java @@ -7,12 +7,10 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnBean; import org.springframework.kafka.core.DefaultKafkaProducerFactory; import org.springframework.kafka.core.KafkaTemplate; -import org.springframework.stereotype.Component; import java.util.Map; import java.util.Optional; -@Component @RequiredArgsConstructor @ConditionalOnBean(value = SpringwolfKafkaProducerConfiguration.class) public class SpringwolfKafkaTemplateFactory { diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelSqsListenerScanner.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelSqsListenerScanner.java index 5815fc50d..74766bd90 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelSqsListenerScanner.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/MethodLevelSqsListenerScanner.java @@ -10,14 +10,12 @@ import io.github.stavshamir.springwolf.schemas.SchemasService; import lombok.extern.slf4j.Slf4j; import org.springframework.context.EmbeddedValueResolverAware; -import org.springframework.stereotype.Service; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; import java.util.Map; @Slf4j -@Service public class MethodLevelSqsListenerScanner extends AbstractMethodLevelListenerScanner implements ChannelsScanner, EmbeddedValueResolverAware { diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsMessageBindingProcessor.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsMessageBindingProcessor.java index cb992682e..3dd0c257e 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsMessageBindingProcessor.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsMessageBindingProcessor.java @@ -5,14 +5,12 @@ import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.MessageBindingProcessor; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.SqsAsyncOperationBinding; import org.springframework.context.EmbeddedValueResolverAware; -import org.springframework.stereotype.Component; import org.springframework.util.StringValueResolver; import java.lang.reflect.Method; import java.util.Arrays; import java.util.Optional; -@Component public class SqsMessageBindingProcessor implements MessageBindingProcessor, EmbeddedValueResolverAware { private StringValueResolver resolver; diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsOperationBindingProcessor.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsOperationBindingProcessor.java index 3764c7d7b..8997ece7a 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsOperationBindingProcessor.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SqsOperationBindingProcessor.java @@ -4,9 +4,7 @@ import com.asyncapi.v2.binding.operation.sqs.SQSOperationBinding; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.AbstractOperationBindingProcessor; import io.github.stavshamir.springwolf.asyncapi.scanners.channels.operationdata.annotation.SqsAsyncOperationBinding; -import org.springframework.stereotype.Component; -@Component public class SqsOperationBindingProcessor extends AbstractOperationBindingProcessor { @Override diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfSqsProducer.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfSqsProducer.java index c08262676..5d70ce31e 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfSqsProducer.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/producer/SpringwolfSqsProducer.java @@ -3,13 +3,11 @@ import io.awspring.cloud.sqs.operations.SqsTemplate; import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Service; import java.util.List; import java.util.Optional; @Slf4j -@Service public class SpringwolfSqsProducer { private final Optional template;