diff --git a/springwolf-plugins/springwolf-sns-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SnsOperationBindingProcessor.java b/springwolf-plugins/springwolf-sns-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SnsOperationBindingProcessor.java index 29e1bb65d..508261f47 100644 --- a/springwolf-plugins/springwolf-sns-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SnsOperationBindingProcessor.java +++ b/springwolf-plugins/springwolf-sns-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/operationdata/SnsOperationBindingProcessor.java @@ -20,9 +20,8 @@ protected ProcessedOperationBinding mapToOperationBinding(SnsAsyncOperationBindi .endpoint(SNSOperationBindingIdentifier.builder().build()) .rawMessageDelivery(true) .build(); - var snsOperationBinding = SNSOperationBinding.builder() - .consumers(List.of(consumer)) - .build(); + var snsOperationBinding = + SNSOperationBinding.builder().consumers(List.of(consumer)).build(); return new ProcessedOperationBinding(bindingAnnotation.type(), snsOperationBinding); } } diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsOperationBindingProcessor.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsOperationBindingProcessor.java index 47e6c78fc..606d48c68 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsOperationBindingProcessor.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/bindings/processor/SqsOperationBindingProcessor.java @@ -17,9 +17,8 @@ protected ProcessedOperationBinding mapToOperationBinding(SqsAsyncOperationBindi .name("queue-name") .fifoQueue(true) .build(); - var operationBinding = SQSOperationBinding.builder() - .queues(List.of(queue)) - .build(); + var operationBinding = + SQSOperationBinding.builder().queues(List.of(queue)).build(); return new ProcessedOperationBinding(bindingAnnotation.type(), operationBinding); } } diff --git a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/SqsListenerUtil.java b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/SqsListenerUtil.java index ee252f16b..bcd1c8b8a 100644 --- a/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/SqsListenerUtil.java +++ b/springwolf-plugins/springwolf-sqs-plugin/src/main/java/io/github/stavshamir/springwolf/asyncapi/scanners/channels/annotation/SqsListenerUtil.java @@ -34,9 +34,7 @@ public static Map buildChannelBinding( .name("queue-name") .fifoQueue(true) .build(); - var channelBinding = SQSChannelBinding.builder() - .queue(queue) - .build(); + var channelBinding = SQSChannelBinding.builder().queue(queue).build(); return Map.of("sqs", channelBinding); } @@ -47,9 +45,8 @@ public static Map buildOperationBinding( .name("queue-name") .fifoQueue(true) .build(); - var operationBinding = SQSOperationBinding.builder() - .queues(List.of(queue)) - .build(); + var operationBinding = + SQSOperationBinding.builder().queues(List.of(queue)).build(); return Map.of("sqs", operationBinding); }