From 0de4287ad745fa364e2bac599c08ea827ce6dd2c Mon Sep 17 00:00:00 2001 From: Timon Back Date: Mon, 29 Dec 2025 16:28:10 +0100 Subject: [PATCH 1/3] chore(core): reduce debugging log level to TRACE As a library, Springwolf does - log no fatal errors - log no error errors - log warn for configuration errors (detectable at startup) - log info for problems during runtime that impact Springwolf functionality (for example publishing) - log debug for information around Springwolf (start, finish, detected classes and method, ...) - log trace for more detail on information that are mostly relevant for debugging --- .../addons/json_schema/JsonSchemaCustomizer.java | 4 ++-- .../channels/DefaultChannelsService.java | 2 +- .../components/DefaultComponentsService.java | 4 ++-- .../examples/walkers/DefaultSchemaWalker.java | 2 +- .../walkers/json/ExampleJsonValueGenerator.java | 2 +- .../walkers/xml/ExampleXmlValueGenerator.java | 2 +- .../walkers/yaml/ExampleYamlValueGenerator.java | 2 +- .../ExampleGeneratorPostProcessor.java | 2 +- .../operations/DefaultOperationsService.java | 2 +- .../spring/annotations/ClassScannerUtil.java | 2 +- .../common/annotation/AnnotationScannerUtil.java | 16 ++++++++-------- .../common/headers/HeaderClassExtractor.java | 2 +- .../payload/internal/PayloadExtractor.java | 2 +- .../controller/PublishingBaseController.java | 2 +- .../scanners/bindings/RabbitListenerUtil.java | 2 +- .../scanners/common/KafkaListenerUtil.java | 10 +++++----- .../scanners/common/MessageMappingUtil.java | 2 +- .../asyncapi/scanners/common/SendToUserUtil.java | 2 +- .../asyncapi/scanners/common/SendToUtil.java | 2 +- 19 files changed, 32 insertions(+), 32 deletions(-) diff --git a/springwolf-add-ons/springwolf-json-schema/src/main/java/io/github/springwolf/addons/json_schema/JsonSchemaCustomizer.java b/springwolf-add-ons/springwolf-json-schema/src/main/java/io/github/springwolf/addons/json_schema/JsonSchemaCustomizer.java index 71fa9d5b7..e44dab4d6 100644 --- a/springwolf-add-ons/springwolf-json-schema/src/main/java/io/github/springwolf/addons/json_schema/JsonSchemaCustomizer.java +++ b/springwolf-add-ons/springwolf-json-schema/src/main/java/io/github/springwolf/addons/json_schema/JsonSchemaCustomizer.java @@ -36,14 +36,14 @@ public void customize(AsyncAPI asyncAPI) { } try { - log.debug("Generate json-schema for {}", entry.getKey()); + log.trace("Generate json-schema for {}", entry.getKey()); Object jsonSchema = jsonSchemaGenerator.fromSchema(componentSchema, componentSchemas); if (jsonSchema != null) { schema.getExtensionFields().putIfAbsent(EXTENSION_JSON_SCHEMA, jsonSchema); } } catch (Exception ex) { - log.warn("Unable to create json-schema for {}", entry.getKey(), ex); + log.info("Unable to create json-schema for {}", entry.getKey(), ex); } } } diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/channels/DefaultChannelsService.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/channels/DefaultChannelsService.java index c5c813c99..ac062287c 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/channels/DefaultChannelsService.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/channels/DefaultChannelsService.java @@ -34,7 +34,7 @@ public Map findChannels() { Map channels = scanner.scan(); foundChannelItems.addAll(channels.values()); } catch (Exception e) { - log.error("An error was encountered during channel scanning with {}: {}", scanner, e.getMessage(), e); + log.warn("An error was encountered during channel scanning with {}: {}", scanner, e.getMessage(), e); } } return ChannelMerger.mergeChannels(foundChannelItems); diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/DefaultComponentsService.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/DefaultComponentsService.java index da4a65f51..cd9cf189d 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/DefaultComponentsService.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/DefaultComponentsService.java @@ -72,7 +72,7 @@ public ComponentSchema resolvePayloadSchema(Type type, String contentType) { */ @Override public String registerSchema(SchemaObject schemaWithoutRef) { - log.debug("Registering schema for {}", schemaWithoutRef.getTitle()); + log.trace("Registering schema for {}", schemaWithoutRef.getTitle()); ComponentSchema processedSchema = schemaService.postProcessSchemaWithoutRef(schemaWithoutRef); this.schemas.putIfAbsent(schemaWithoutRef.getTitle(), processedSchema); @@ -98,7 +98,7 @@ public Map getMessages() { */ @Override public MessageReference registerMessage(MessageObject message) { - log.debug("Registering message for {}", message.getMessageId()); + log.trace("Registering message for {}", message.getMessageId()); messages.putIfAbsent(message.getMessageId(), message); diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/DefaultSchemaWalker.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/DefaultSchemaWalker.java index f7c0a26c6..35187d00c 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/DefaultSchemaWalker.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/DefaultSchemaWalker.java @@ -76,7 +76,7 @@ public R fromSchema(Schema schema, Map definitions) { private Optional buildExample( Optional name, Schema schema, Map definitions, Set visited) { - log.debug("Building example for schema {}", schema); + log.trace("Building example for schema {}", schema); Optional exampleValue = getExampleFromSchemaAnnotation(name, schema); if (exampleValue.isPresent()) { diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/json/ExampleJsonValueGenerator.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/json/ExampleJsonValueGenerator.java index a3dcdecee..5ca25009a 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/json/ExampleJsonValueGenerator.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/json/ExampleJsonValueGenerator.java @@ -90,7 +90,7 @@ public JsonNode createRaw(Object exampleValue) { try { return yamlMapper.readTree(exampleValue.toString()); } catch (JacksonException e) { - log.info("Unable to parse example to JsonNode: {}", exampleValue, e); + log.debug("Unable to parse example to JsonNode: {}", exampleValue, e); return null; } } diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/xml/ExampleXmlValueGenerator.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/xml/ExampleXmlValueGenerator.java index da1730240..f91a5d205 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/xml/ExampleXmlValueGenerator.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/xml/ExampleXmlValueGenerator.java @@ -184,7 +184,7 @@ public String prepareForSerialization(Schema schema, Node exampleObject) { return xml; } catch (TransformerException | DOMException e) { - log.error("Unable to serialize example for schema {}", schema.getName(), e); + log.warn("Unable to serialize example for schema {}", schema.getName(), e); return null; } } diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/yaml/ExampleYamlValueGenerator.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/yaml/ExampleYamlValueGenerator.java index 6a0ebb0b6..3526022a2 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/yaml/ExampleYamlValueGenerator.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/examples/walkers/yaml/ExampleYamlValueGenerator.java @@ -50,7 +50,7 @@ public String prepareForSerialization(Schema schema, JsonNode exampleObject) { return exampleYamlValueSerializer.writeDocumentAsYamlString(exampleObject); } catch (JacksonException e) { - log.error("Serialize {}", name, e); + log.warn("Serialize {}", name, e); return null; } } diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/postprocessors/ExampleGeneratorPostProcessor.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/postprocessors/ExampleGeneratorPostProcessor.java index 93f0a83b8..dd10acbd1 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/postprocessors/ExampleGeneratorPostProcessor.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/components/postprocessors/ExampleGeneratorPostProcessor.java @@ -19,7 +19,7 @@ public class ExampleGeneratorPostProcessor implements SchemasPostProcessor { @Override public void process(Schema schema, Map definitions, String contentType) { if (schema.getExample() == null) { - log.debug("Generate example for {}", schema.getName()); + log.trace("Generate example for {}", schema.getName()); Optional schemaWalkerOptional = schemaWalkerProvider.generatorFor(contentType); if (schemaWalkerOptional.isPresent()) { diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/operations/DefaultOperationsService.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/operations/DefaultOperationsService.java index 0dca9d503..8b3c728cb 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/operations/DefaultOperationsService.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/operations/DefaultOperationsService.java @@ -34,7 +34,7 @@ public Map findOperations() { Map channels = scanner.scan(); foundOperations.addAll(channels.values()); } catch (Exception e) { - log.error("An error was encountered during operation scanning with {}: {}", scanner, e.getMessage(), e); + log.warn("An error was encountered during operation scanning with {}: {}", scanner, e.getMessage(), e); } } return OperationMerger.mergeOperations(foundOperations); diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/classes/spring/annotations/ClassScannerUtil.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/classes/spring/annotations/ClassScannerUtil.java index 61e21e304..1e01ef9a8 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/classes/spring/annotations/ClassScannerUtil.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/classes/spring/annotations/ClassScannerUtil.java @@ -35,7 +35,7 @@ public static List> getClasses(String basePackages, TypeFilter filter, private static Optional> getClass(String className) { try { - log.debug("Found candidate class: {}", className); + log.trace("Found candidate class: {}", className); return Optional.of(Class.forName(className)); } catch (ClassNotFoundException e) { log.warn("Failed to get class for name: {}", className); diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java index a97bb3e21..0e2530437 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java @@ -30,11 +30,14 @@ public static Stream findAnno Class classAnnotationClass, Class methodAnnotationClass, BiFunction, Set>, Stream> transformer) { - log.debug("Scanning class \"{}\" for @\"{}\" annotation", clazz.getName(), classAnnotationClass.getName()); + log.trace("Scanning class {} for @{} annotation", clazz.getName(), classAnnotationClass.getName()); Set> methods = Stream.of(clazz) .filter(it -> AnnotationScannerUtil.isClassRelevant(it, classAnnotationClass)) - .peek(it -> log.debug("Mapping class \"{}\"", it.getName())) .flatMap(it -> AnnotationScannerUtil.findAnnotatedMethods(it, methodAnnotationClass)) + .peek(it -> log.debug( + "Mapping class method {}#{}", + clazz.getName(), + it.method().getName())) .collect(Collectors.toSet()); if (methods.isEmpty()) { @@ -51,22 +54,19 @@ static boolean isClassRelevant(Class clazz, Class a public static Stream> findAnnotatedMethods( Class clazz, Class methodAnnotationClass) { - log.debug( - "Scanning class \"{}\" for @\"{}\" annotated methods", - clazz.getName(), - methodAnnotationClass.getName()); + log.trace("Scanning class {} for @{} annotated methods", clazz.getName(), methodAnnotationClass.getName()); Stream methods = Arrays.stream(ReflectionUtils.getAllDeclaredMethods(clazz)) .filter(ReflectionUtils.USER_DECLARED_METHODS::matches) .filter(AnnotationScannerUtil::isNotHidden); if (methodAnnotationClass == AllMethods.class) { - return methods.peek(method -> log.debug("Mapping method \"{}\"", method.getName())) + return methods.peek(method -> log.debug("Mapping (all) method {}#{}", clazz.getName(), method.getName())) .map(method -> new MethodAndAnnotation<>(method, null)); } return methods.filter(method -> AnnotationUtil.findFirstAnnotation(methodAnnotationClass, method) != null) - .peek(method -> log.debug("Mapping method \"{}\"", method.getName())) + .peek(method -> log.debug("Mapping method {}#{}", clazz.getName(), method.getName())) .flatMap(method -> AnnotationUtil.findAnnotations(methodAnnotationClass, method).stream() .map(annotation -> new MethodAndAnnotation<>(method, annotation))); } diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/headers/HeaderClassExtractor.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/headers/HeaderClassExtractor.java index c3e2444dc..c66bd3a09 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/headers/HeaderClassExtractor.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/headers/HeaderClassExtractor.java @@ -21,7 +21,7 @@ public class HeaderClassExtractor { public SchemaObject extractHeader(Method method, PayloadSchemaObject payload) { String methodName = "%s::%s".formatted(method.getDeclaringClass().getSimpleName(), method.getName()); - log.debug("Extract header for {}", methodName); + log.trace("Extract header for {}", methodName); SchemaObject headers = SchemaObject.builder() .type(SchemaType.OBJECT) diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/payload/internal/PayloadExtractor.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/payload/internal/PayloadExtractor.java index db40ae257..969843d68 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/payload/internal/PayloadExtractor.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/payload/internal/PayloadExtractor.java @@ -19,7 +19,7 @@ public class PayloadExtractor { public Optional extractFrom(Method method) { String methodName = "%s::%s".formatted(method.getDeclaringClass().getSimpleName(), method.getName()); - log.debug("Finding payload type for {}", methodName); + log.trace("Finding payload type for {}", methodName); return getPayloadParameterIndex(method.getParameterTypes(), method.getParameterAnnotations(), methodName) .map((parameterPayloadIndex) -> method.getGenericParameterTypes()[parameterPayloadIndex]) diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/controller/PublishingBaseController.java b/springwolf-core/src/main/java/io/github/springwolf/core/controller/PublishingBaseController.java index ca87bf695..a9907f130 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/controller/PublishingBaseController.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/controller/PublishingBaseController.java @@ -39,7 +39,7 @@ public ResponseEntity publish(@RequestParam String topic, @RequestBody M if (!isEnabled()) { String errorMessage = "Publishing using %s is not enabled - message will not be published" .formatted(this.getClass().getSimpleName()); - log.warn(errorMessage); + log.info(errorMessage); return ResponseEntity.status(HttpStatus.NOT_FOUND).body(errorMessage); } diff --git a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/springwolf/plugins/amqp/asyncapi/scanners/bindings/RabbitListenerUtil.java b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/springwolf/plugins/amqp/asyncapi/scanners/bindings/RabbitListenerUtil.java index cf300705a..1f025fd0a 100644 --- a/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/springwolf/plugins/amqp/asyncapi/scanners/bindings/RabbitListenerUtil.java +++ b/springwolf-plugins/springwolf-amqp-plugin/src/main/java/io/github/springwolf/plugins/amqp/asyncapi/scanners/bindings/RabbitListenerUtil.java @@ -276,7 +276,7 @@ public static Map buildMessageBinding() { private static String resolveFirstValue(Stream values, StringValueResolver resolver, String valueType) { return values.map(resolver::resolveStringValue) .filter(Objects::nonNull) - .peek(value -> log.debug("Resolved {}: {}", valueType, value)) + .peek(value -> log.trace("Resolved {}: {}", valueType, value)) .findFirst() .orElseThrow(() -> new IllegalArgumentException("No " + valueType + " was found in @RabbitListener annotation (neither in queues nor bindings property)")); diff --git a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/springwolf/plugins/kafka/asyncapi/scanners/common/KafkaListenerUtil.java b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/springwolf/plugins/kafka/asyncapi/scanners/common/KafkaListenerUtil.java index 2cf4cc975..b176ff56b 100644 --- a/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/springwolf/plugins/kafka/asyncapi/scanners/common/KafkaListenerUtil.java +++ b/springwolf-plugins/springwolf-kafka-plugin/src/main/java/io/github/springwolf/plugins/kafka/asyncapi/scanners/common/KafkaListenerUtil.java @@ -33,7 +33,7 @@ public static String getChannelName(KafkaListener annotation, StringValueResolve List resolvedTopics = topicName.map(stringValueResolver::resolveStringValue).collect(toList()); - log.debug("Found topics: {}", String.join(", ", resolvedTopics)); + log.trace("Found topics: {}", String.join(", ", resolvedTopics)); return resolvedTopics.get(0); } @@ -56,9 +56,9 @@ public static SchemaObject buildKafkaClientIdSchema(String clientId) { SchemaObject schema = createStringSchema(clientId); if (schema != null) { - log.debug("Found client id: {}", clientId); + log.trace("Found client id: {}", clientId); } else { - log.debug("No client id found for this listener"); + log.trace("No client id found for this listener"); } return schema; @@ -69,9 +69,9 @@ public static SchemaObject buildKafkaGroupIdSchema(String groupId) { SchemaObject schema = createStringSchema(groupId); if (schema != null) { - log.debug("Found group id: {}", groupId); + log.trace("Found group id: {}", groupId); } else { - log.debug("No group id found for this listener"); + log.trace("No group id found for this listener"); } return schema; diff --git a/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/MessageMappingUtil.java b/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/MessageMappingUtil.java index 5e13d262a..b6f24c344 100644 --- a/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/MessageMappingUtil.java +++ b/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/MessageMappingUtil.java @@ -26,7 +26,7 @@ public static String getChannelName(MessageMapping annotation, StringValueResolv List resolvedDestinations = destinations.map(stringValueResolver::resolveStringValue).collect(toList()); - log.debug("Found destinations: {}", String.join(", ", resolvedDestinations)); + log.trace("Found destinations: {}", String.join(", ", resolvedDestinations)); return resolvedDestinations.get(0); } diff --git a/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUserUtil.java b/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUserUtil.java index 815b35152..5a7dd7efd 100644 --- a/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUserUtil.java +++ b/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUserUtil.java @@ -26,7 +26,7 @@ public static String getChannelName(SendToUser annotation, StringValueResolver s List resolvedDestinations = destinations.map(stringValueResolver::resolveStringValue).collect(toList()); - log.debug("Found destinations: {}", String.join(", ", resolvedDestinations)); + log.trace("Found destinations: {}", String.join(", ", resolvedDestinations)); return resolvedDestinations.get(0); } diff --git a/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUtil.java b/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUtil.java index 2ccf3b340..d41a355ae 100644 --- a/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUtil.java +++ b/springwolf-plugins/springwolf-stomp-plugin/src/main/java/io/github/springwolf/plugins/stomp/asyncapi/scanners/common/SendToUtil.java @@ -26,7 +26,7 @@ public static String getChannelName(SendTo annotation, StringValueResolver strin List resolvedDestinations = destinations.map(stringValueResolver::resolveStringValue).collect(toList()); - log.debug("Found destinations: {}", String.join(", ", resolvedDestinations)); + log.trace("Found destinations: {}", String.join(", ", resolvedDestinations)); return resolvedDestinations.get(0); } From a716e0f44dcde79a01c224e7194824a904035d82 Mon Sep 17 00:00:00 2001 From: Timon Back Date: Mon, 29 Dec 2025 16:41:50 +0100 Subject: [PATCH 2/3] test: update examples as well --- springwolf-examples/e2e/build.gradle | 11 +++++++++++ .../e2e/util/external_process.ts | 4 +++- .../amqp/consumers/ExampleConsumer.java | 18 +++++++++--------- .../CloudstreamConfiguration.java | 14 +++++++------- .../configuration/ConsumerClass.java | 2 +- .../jms/consumers/ExampleConsumer.java | 4 ++-- .../examples/jms/JmsProducerSystemTest.java | 2 +- .../examples/kafka/consumers/AvroConsumer.java | 2 +- .../kafka/consumers/DiscriminatorConsumer.java | 2 +- .../ExampleClassLevelKafkaListener.java | 6 +++--- .../kafka/consumers/ExampleConsumer.java | 4 ++-- .../kafka/consumers/IntegerConsumer.java | 2 +- .../kafka/consumers/NoPayloadUsedConsumer.java | 2 +- .../kafka/consumers/ProtobufConsumer.java | 2 +- .../consumers/RequiredAndNullableConsumer.java | 2 +- .../kafka/consumers/StringConsumer.java | 2 +- .../examples/kafka/consumers/XmlConsumer.java | 2 +- .../examples/kafka/consumers/YamlConsumer.java | 2 +- .../sns/consumers/ExampleConsumer.java | 4 ++-- .../sqs/consumers/ExampleConsumer.java | 4 ++-- .../stomp/consumers/ExampleConsumer.java | 6 +++--- 21 files changed, 55 insertions(+), 42 deletions(-) diff --git a/springwolf-examples/e2e/build.gradle b/springwolf-examples/e2e/build.gradle index 6ddc6deca..f6d7cd3c9 100644 --- a/springwolf-examples/e2e/build.gradle +++ b/springwolf-examples/e2e/build.gradle @@ -20,6 +20,17 @@ tasks.register('pnpm_run_install_deps', PnpmTask) { inputs.file 'pnpm-lock.yaml' outputs.upToDateWhen { true } } +tasks.register('pnpmStart', PnpmTask) { + group = "pnpm" + dependsOn pnpmInstall + + args = ['start'] + + inputs.file 'playwright.config.ts' + inputs.file 'package.json' + inputs.file 'pnpm-lock.yaml' + outputs.upToDateWhen { true } +} tasks.register('pnpm_run_lint', PnpmTask) { group = "pnpm" diff --git a/springwolf-examples/e2e/util/external_process.ts b/springwolf-examples/e2e/util/external_process.ts index a0474dba6..f224fd5e4 100644 --- a/springwolf-examples/e2e/util/external_process.ts +++ b/springwolf-examples/e2e/util/external_process.ts @@ -56,12 +56,14 @@ export function verifyNoErrorLogs(dockerLogs: MonitorDockerLogsResponse) { .filter((message) => message.includes("i.g.s")) // io.github.springwolf .filter( (message) => + message.includes("FATAL") || message.includes("ERROR") || message.includes("WARN") || + message.includes("INFO") || message.includes("Failed") ); expect(errorMessages, { - message: "expect: No Springwolf ERROR or WARN log messages found", + message: "expect: No Springwolf FATAL, ERROR, WARN or INFO log messages found", }).toHaveLength(0); } diff --git a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java index 2f836b972..6d70c1db2 100644 --- a/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-amqp-example/src/main/java/io/github/springwolf/examples/amqp/consumers/ExampleConsumer.java @@ -26,7 +26,7 @@ public class ExampleConsumer { @RabbitListener(queues = AmqpConstants.QUEUE_EXAMPLE_QUEUE) public void receiveExamplePayload(ExamplePayloadDto payload) { - log.info("Received new message in {}: {}", AmqpConstants.QUEUE_EXAMPLE_QUEUE, payload.toString()); + log.debug("Received new message in {}: {}", AmqpConstants.QUEUE_EXAMPLE_QUEUE, payload.toString()); AnotherPayloadDto example = new AnotherPayloadDto(); example.setExample(payload); @@ -37,7 +37,7 @@ public void receiveExamplePayload(ExamplePayloadDto payload) { @RabbitListener(queues = AmqpConstants.QUEUE_ANOTHER_QUEUE) public void receiveAnotherPayload(AnotherPayloadDto payload) { - log.info("Received new message in {}: {}", AmqpConstants.QUEUE_ANOTHER_QUEUE, payload.toString()); + log.debug("Received new message in {}: {}", AmqpConstants.QUEUE_ANOTHER_QUEUE, payload.toString()); } @RabbitListener( @@ -56,7 +56,7 @@ public void receiveAnotherPayload(AnotherPayloadDto payload) { key = AmqpConstants.ROUTING_KEY_EXAMPLE_TOPIC_ROUTING_KEY) }) public void bindingsExample(ExamplePayloadDto payload) { - log.info( + log.debug( "Received new message in {}" + " through exchange {}" + " using routing key {}: {}", AmqpConstants.QUEUE_EXAMPLE_BINDINGS_QUEUE, AmqpConstants.EXCHANGE_EXAMPLE_TOPIC_EXCHANGE, @@ -66,7 +66,7 @@ public void bindingsExample(ExamplePayloadDto payload) { @RabbitListener(queues = AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE) public void bindingsBeanExample(AnotherPayloadDto payload) { - log.info( + log.debug( "Received new message in {} (AnotherPayloadDto): {}", AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE, payload.toString()); @@ -74,7 +74,7 @@ public void bindingsBeanExample(AnotherPayloadDto payload) { @RabbitListener(queues = AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE) public void bindingsBeanExample(ExamplePayloadDto payload) { - log.info( + log.debug( "Received new message in {} (ExamplePayloadDto): {}", AmqpConstants.QUEUE_MULTI_PAYLOAD_QUEUE, payload.toString()); @@ -82,7 +82,7 @@ public void bindingsBeanExample(ExamplePayloadDto payload) { @RabbitListener(queuesToDeclare = @Queue(name = AmqpConstants.QUEUE_CREATE, autoDelete = "false", durable = "true")) public void queuesToDeclareCreate(Message message, @Payload GenericPayloadDto payload) { - log.info( + log.debug( "Received new message {} in {} (GenericPayloadDto): {}", message, AmqpConstants.QUEUE_CREATE, @@ -91,7 +91,7 @@ public void queuesToDeclareCreate(Message message, @Payload GenericPayloadDto payload) { - log.info( + log.debug( "Received new message {} in {} (GenericPayloadDto): {}", message, AmqpConstants.QUEUE_DELETE, @@ -109,7 +109,7 @@ public void queuesToDeclareDelete(Message message, @Payload GenericPayloadDto payload) { - log.info( + log.debug( "Received new message {} in {} (GenericPayloadDto): {}", message, AmqpConstants.EXCHANGE_CRUD_TOPIC_EXCHANGE_1, @@ -127,7 +127,7 @@ public void bindingsUpdate(Message message, @Payload GenericPayloadDto process() { return input -> { - log.info("Received new message in example-topic: {}", input); + log.debug("Received new message in example-topic: {}", input); AnotherPayloadDto output = new AnotherPayloadDto("foo", input); - log.info("Publishing output: {}", output); + log.debug("Publishing output: {}", output); return output; }; } @@ -34,22 +34,22 @@ public Function process() { @Bean public BiFunction, AnotherPayloadDto> biProcess() { return (input, headers) -> { - log.info("Received new message in bifunction-topic: {}. Headers: {}", input, headers); + log.debug("Received new message in bifunction-topic: {}. Headers: {}", input, headers); AnotherPayloadDto output = new AnotherPayloadDto("foo", input); - log.info("Publishing output: {}", output); + log.debug("Publishing output: {}", output); return output; }; } @Bean public Consumer consumerMethod() { - return input -> log.info("Received new message in another-topic: {}", input.toString()); + return input -> log.debug("Received new message in another-topic: {}", input.toString()); } @Bean public BiConsumer> biConsumerMethod() { return (input, headers) -> - log.info("Received new message in biconsumer-topic: {}. Headers {}.", input.toString(), headers); + log.debug("Received new message in biconsumer-topic: {}. Headers {}.", input.toString(), headers); } @GooglePubSubAsyncChannelBinding( @@ -57,6 +57,6 @@ public BiConsumer> biConsumerMethod() { @GooglePubSubAsyncMessageBinding(schema = @GooglePubSubAsyncMessageSchema(name = "project/test")) @Bean public Consumer googlePubSubConsumerMethod() { - return input -> log.info("Received new message in google-pubsub-topic: {}", input.toString()); + return input -> log.debug("Received new message in google-pubsub-topic: {}", input.toString()); } } diff --git a/springwolf-examples/springwolf-cloud-stream-example/src/main/java/io/github/springwolf/examples/cloudstream/configuration/ConsumerClass.java b/springwolf-examples/springwolf-cloud-stream-example/src/main/java/io/github/springwolf/examples/cloudstream/configuration/ConsumerClass.java index f55cf1a48..3dc94ea82 100644 --- a/springwolf-examples/springwolf-cloud-stream-example/src/main/java/io/github/springwolf/examples/cloudstream/configuration/ConsumerClass.java +++ b/springwolf-examples/springwolf-cloud-stream-example/src/main/java/io/github/springwolf/examples/cloudstream/configuration/ConsumerClass.java @@ -13,6 +13,6 @@ public class ConsumerClass implements Consumer { @Override public void accept(ExamplePayloadDto payload) { - log.info("Called with payload: {}", payload); + log.debug("Called with payload: {}", payload); } } diff --git a/springwolf-examples/springwolf-jms-example/src/main/java/io/github/springwolf/examples/jms/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-jms-example/src/main/java/io/github/springwolf/examples/jms/consumers/ExampleConsumer.java index 7e728e59d..10ddf0ab8 100644 --- a/springwolf-examples/springwolf-jms-example/src/main/java/io/github/springwolf/examples/jms/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-jms-example/src/main/java/io/github/springwolf/examples/jms/consumers/ExampleConsumer.java @@ -17,7 +17,7 @@ public class ExampleConsumer { @JmsListener(destination = "example-queue") public void receiveExamplePayload(ExamplePayloadDto payload) { - log.info("Received new message in example-queue: {}", payload.toString()); + log.debug("Received new message in example-queue: {}", payload.toString()); AnotherPayloadDto example = new AnotherPayloadDto(); example.setExample(payload); @@ -28,6 +28,6 @@ public void receiveExamplePayload(ExamplePayloadDto payload) { @JmsListener(destination = "another-queue") public void receiveAnotherPayload(AnotherPayloadDto payload) { - log.info("Received new message in another-queue: {}", payload.toString()); + log.debug("Received new message in another-queue: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-jms-example/src/test/java/io/github/springwolf/examples/jms/JmsProducerSystemTest.java b/springwolf-examples/springwolf-jms-example/src/test/java/io/github/springwolf/examples/jms/JmsProducerSystemTest.java index f42623ab2..b5f31afe6 100644 --- a/springwolf-examples/springwolf-jms-example/src/test/java/io/github/springwolf/examples/jms/JmsProducerSystemTest.java +++ b/springwolf-examples/springwolf-jms-example/src/test/java/io/github/springwolf/examples/jms/JmsProducerSystemTest.java @@ -76,7 +76,7 @@ void producerCanUseSpringwolfConfigurationToSendMessage() { // Awaitility is used, because message sent before amqp is ready are lost Awaitility.await().atMost(10, TimeUnit.SECONDS).untilAsserted(() -> { // when - log.info("Waiting for message in {} on {}", exampleConsumer, brokerUrl); + log.debug("Waiting for message in {} on {}", exampleConsumer, brokerUrl); springwolfJmsProducer.send("example-queue", Map.of(), payload); // then diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/AvroConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/AvroConsumer.java index 5b82956cd..64fd28b2c 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/AvroConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/AvroConsumer.java @@ -32,6 +32,6 @@ public class AvroConsumer { "Requires a running kafka-schema-registry. See docker-compose.yml to start it")) @KafkaAsyncOperationBinding public void receiveExampleAvroPayload(AnotherPayloadAvroDto payloads) { - log.info("Received new message in avro-topic: {}", payloads.toString()); + log.debug("Received new message in avro-topic: {}", payloads.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/DiscriminatorConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/DiscriminatorConsumer.java index 97381cb9d..01bca31e8 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/DiscriminatorConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/DiscriminatorConsumer.java @@ -14,6 +14,6 @@ public class DiscriminatorConsumer { @KafkaListener(topics = "vehicle-topic") public void receiveExamplePayload(VehicleBase payload) { - log.info("Received new message in vehicle-topic: {}", payload.toString()); + log.debug("Received new message in vehicle-topic: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleClassLevelKafkaListener.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleClassLevelKafkaListener.java index 815f74dc2..9006de48d 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleClassLevelKafkaListener.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleClassLevelKafkaListener.java @@ -35,12 +35,12 @@ public void receiveExamplePayload( @Header(KafkaHeaders.OFFSET) Integer offset, @Header(KafkaHeaders.RECORD_METADATA) ConsumerRecordMetadata meta, @Payload ExamplePayloadDto payload) { - log.info("Received new message in {}: {}", TOPIC, payload.toString()); + log.debug("Received new message in {}: {}", TOPIC, payload.toString()); } @KafkaHandler public void receiveAnotherPayload(ConsumerRecord payload) { - log.info("Received new message in {}: {}", TOPIC, payload.value().toString()); + log.debug("Received new message in {}: {}", TOPIC, payload.value().toString()); } @KafkaHandler @@ -80,6 +80,6 @@ public void receiveAnotherPayload(ConsumerRecord payloa description = "Kafka Consumer Message Key", example = "example-key"))) public void receiveMonetaryAmount(MonetaryAmount payload) { - log.info("Received new message in {}: {}", TOPIC, payload.toString()); + log.debug("Received new message in {}: {}", TOPIC, payload.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleConsumer.java index b8637e0a0..9d8f6ca11 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ExampleConsumer.java @@ -28,7 +28,7 @@ public void receiveExamplePayload( @Header(KafkaHeaders.OFFSET) Integer offset, @Header(KafkaHeaders.RECORD_METADATA) ConsumerRecordMetadata meta, @Payload ExamplePayloadDto payload) { - log.info("Received new message in example-topic: {}", payload.toString()); + log.debug("Received new message in example-topic: {}", payload.toString()); AnotherPayloadDto example = new AnotherPayloadDto(); example.setExample(payload); @@ -39,6 +39,6 @@ public void receiveExamplePayload( @KafkaListener(topicPattern = "another-topic", groupId = "example-group-id", batch = "true") public void receiveAnotherPayloadBatched(List payloads) { - log.info("Received new message in another-topic: {}", payloads.toString()); + log.debug("Received new message in another-topic: {}", payloads.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/IntegerConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/IntegerConsumer.java index 1eb83f1a3..2fb9d06e2 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/IntegerConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/IntegerConsumer.java @@ -14,6 +14,6 @@ public class IntegerConsumer { @KafkaListener(topics = TOPIC) public void receiveIntegerPayload(Integer integerPayload) { - log.info("Received new message in {}: {}", TOPIC, integerPayload); + log.debug("Received new message in {}: {}", TOPIC, integerPayload); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/NoPayloadUsedConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/NoPayloadUsedConsumer.java index 9cdcd9a6e..7c5a11d6b 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/NoPayloadUsedConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/NoPayloadUsedConsumer.java @@ -13,6 +13,6 @@ public class NoPayloadUsedConsumer { @KafkaListener(topics = "no-payload-used-topic") public void receiveExamplePayload() { - log.info("Received new message in no-payload-used-topic"); + log.debug("Received new message in no-payload-used-topic"); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ProtobufConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ProtobufConsumer.java index 1c20150e3..a06db6aee 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ProtobufConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/ProtobufConsumer.java @@ -23,6 +23,6 @@ public class ProtobufConsumer { "spring.deserializer.value.delegate.class=io.confluent.kafka.serializers.protobuf.KafkaProtobufDeserializer" }) public void receiveExampleProtobufPayload(ExamplePayloadProtobufDto.Message payload) { - log.info("Received new message in protobuf-topic: {}", payload.toString()); + log.debug("Received new message in protobuf-topic: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/RequiredAndNullableConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/RequiredAndNullableConsumer.java index d1ae8cffc..1f3eaddbc 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/RequiredAndNullableConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/RequiredAndNullableConsumer.java @@ -15,6 +15,6 @@ public class RequiredAndNullableConsumer { @KafkaListener(topics = "nullable-topic") @KafkaAsyncOperationBinding public void receiveNullablePayload(RequiredAndNullablePayloadDto payloads) { - log.info("Received new message in nullable-topic: {}", payloads.toString()); + log.debug("Received new message in nullable-topic: {}", payloads.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/StringConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/StringConsumer.java index 38208e70c..65279f387 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/StringConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/StringConsumer.java @@ -33,7 +33,7 @@ public class StringConsumer { headers = @AsyncOperation.Headers(notUsed = true))) @KafkaAsyncOperationBinding public void receiveStringPayload(String stringPayload) { - log.info("Received new message in {}: {}", TOPIC, stringPayload); + log.debug("Received new message in {}: {}", TOPIC, stringPayload); } @Data diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/XmlConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/XmlConsumer.java index 3ca0e88a8..26638c61f 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/XmlConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/XmlConsumer.java @@ -27,6 +27,6 @@ public class XmlConsumer { @KafkaAsyncOperationBinding @KafkaListener(topics = "xml-topic") public void receiveExamplePayload(XmlPayloadDto payload) { - log.info("Received new message in example-queue: {}", payload.toString()); + log.debug("Received new message in example-queue: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/YamlConsumer.java b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/YamlConsumer.java index 98fe448c2..237020d8b 100644 --- a/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/YamlConsumer.java +++ b/springwolf-examples/springwolf-kafka-example/src/main/java/io/github/springwolf/examples/kafka/consumers/YamlConsumer.java @@ -27,6 +27,6 @@ public class YamlConsumer { @KafkaAsyncOperationBinding @KafkaListener(topics = "yaml-topic") public void receiveExamplePayload(YamlPayloadDto payload) { - log.info("Received new message in example-queue: {}", payload.toString()); + log.debug("Received new message in example-queue: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-sns-example/src/main/java/io/github/springwolf/examples/sns/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-sns-example/src/main/java/io/github/springwolf/examples/sns/consumers/ExampleConsumer.java index 23a3a4c86..4f3f06480 100644 --- a/springwolf-examples/springwolf-sns-example/src/main/java/io/github/springwolf/examples/sns/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-sns-example/src/main/java/io/github/springwolf/examples/sns/consumers/ExampleConsumer.java @@ -21,7 +21,7 @@ public class ExampleConsumer { @AsyncListener(operation = @AsyncOperation(channelName = "example-topic")) @SnsAsyncOperationBinding(protocol = "sqs", endpoint = @SnsAsyncOperationBindingIdentifier()) public void receiveExamplePayload(ExamplePayloadDto payload) { - log.info("Received new message in example-topic: {}", payload.toString()); + log.debug("Received new message in example-topic: {}", payload.toString()); AnotherPayloadDto example = new AnotherPayloadDto(); example.setExample(payload); @@ -33,6 +33,6 @@ public void receiveExamplePayload(ExamplePayloadDto payload) { @AsyncListener(operation = @AsyncOperation(channelName = "another-topic")) @SnsAsyncOperationBinding(protocol = "sqs", endpoint = @SnsAsyncOperationBindingIdentifier()) public void receiveAnotherPayload(AnotherPayloadDto payload) { - log.info("Received new message in another-topic: {}", payload.toString()); + log.debug("Received new message in another-topic: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/springwolf/examples/sqs/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/springwolf/examples/sqs/consumers/ExampleConsumer.java index f940e293e..06df9020a 100644 --- a/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/springwolf/examples/sqs/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-sqs-example/src/main/java/io/github/springwolf/examples/sqs/consumers/ExampleConsumer.java @@ -21,7 +21,7 @@ public class ExampleConsumer { @SqsListener("example-queue") public void receiveExamplePayload(@Payload ExamplePayloadDto payload, @Headers Map headers) { - log.info("Received new message in example-queue: {}, with headers: {}", payload.toString(), headers); + log.debug("Received new message in example-queue: {}, with headers: {}", payload.toString(), headers); AnotherPayloadDto example = new AnotherPayloadDto(); example.setExample(payload); @@ -32,6 +32,6 @@ public void receiveExamplePayload(@Payload ExamplePayloadDto payload, @Headers M @SqsListener("another-queue") public void receiveAnotherPayload(AnotherPayloadDto payload) { - log.info("Received new message in another-queue: {}", payload.toString()); + log.debug("Received new message in another-queue: {}", payload.toString()); } } diff --git a/springwolf-examples/springwolf-stomp-example/src/main/java/io/github/springwolf/examples/stomp/consumers/ExampleConsumer.java b/springwolf-examples/springwolf-stomp-example/src/main/java/io/github/springwolf/examples/stomp/consumers/ExampleConsumer.java index e7acfe8b8..0dcdbadae 100644 --- a/springwolf-examples/springwolf-stomp-example/src/main/java/io/github/springwolf/examples/stomp/consumers/ExampleConsumer.java +++ b/springwolf-examples/springwolf-stomp-example/src/main/java/io/github/springwolf/examples/stomp/consumers/ExampleConsumer.java @@ -26,7 +26,7 @@ public class ExampleConsumer { @MessageMapping(EXAMPLE_QUEUE) public void receiveExamplePayload(ExamplePayloadDto payload) { - log.info("Received new message in {}: {}", EXAMPLE_QUEUE, payload.toString()); + log.debug("Received new message in {}: {}", EXAMPLE_QUEUE, payload.toString()); AnotherPayloadDto example = new AnotherPayloadDto(); example.setExample(payload); @@ -38,7 +38,7 @@ public void receiveExamplePayload(ExamplePayloadDto payload) { @MessageMapping(SENDTO_QUEUE) @SendTo(SENDTO_RESPONSE_QUEUE) public ExamplePayloadDto receiveExamplePayloadSendTo(ExamplePayloadDto payload) { - log.info("Received new message in {}: {}", SENDTO_QUEUE, payload.toString()); + log.debug("Received new message in {}: {}", SENDTO_QUEUE, payload.toString()); return payload; } @@ -46,7 +46,7 @@ public ExamplePayloadDto receiveExamplePayloadSendTo(ExamplePayloadDto payload) @MessageMapping(SENDTOUSER_QUEUE) @SendToUser(SENDTOUSER_RESPONSE_QUEUE) public ExamplePayloadDto receiveExamplePayloadSendToUser(ExamplePayloadDto payload) { - log.info("Received new message in {}: {}", SENDTOUSER_QUEUE, payload.toString()); + log.debug("Received new message in {}: {}", SENDTOUSER_QUEUE, payload.toString()); return payload; } From 57f64d31a7ac02af25022363cc6e0c8a73d0eb36 Mon Sep 17 00:00:00 2001 From: Timon Back Date: Mon, 29 Dec 2025 16:59:36 +0100 Subject: [PATCH 3/3] chore: better log message --- .../scanners/common/annotation/AnnotationScannerUtil.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java index 0e2530437..90d61d3b5 100644 --- a/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java +++ b/springwolf-core/src/main/java/io/github/springwolf/core/asyncapi/scanners/common/annotation/AnnotationScannerUtil.java @@ -35,7 +35,7 @@ public static Stream findAnno .filter(it -> AnnotationScannerUtil.isClassRelevant(it, classAnnotationClass)) .flatMap(it -> AnnotationScannerUtil.findAnnotatedMethods(it, methodAnnotationClass)) .peek(it -> log.debug( - "Mapping class method {}#{}", + "Detected class method {}#{}", clazz.getName(), it.method().getName())) .collect(Collectors.toSet()); @@ -61,12 +61,12 @@ public static Stream> findAnnotate .filter(AnnotationScannerUtil::isNotHidden); if (methodAnnotationClass == AllMethods.class) { - return methods.peek(method -> log.debug("Mapping (all) method {}#{}", clazz.getName(), method.getName())) + return methods.peek(method -> log.debug("Detected (all) method {}#{}", clazz.getName(), method.getName())) .map(method -> new MethodAndAnnotation<>(method, null)); } return methods.filter(method -> AnnotationUtil.findFirstAnnotation(methodAnnotationClass, method) != null) - .peek(method -> log.debug("Mapping method {}#{}", clazz.getName(), method.getName())) + .peek(method -> log.debug("Detected method {}#{}", clazz.getName(), method.getName())) .flatMap(method -> AnnotationUtil.findAnnotations(methodAnnotationClass, method).stream() .map(annotation -> new MethodAndAnnotation<>(method, annotation))); }