Skip to content

Commit c5f6c44

Browse files
Silvarr97Silvarr97
committed
feat: support for azure service bus
1 parent 7f5c581 commit c5f6c44

File tree

16 files changed

+345
-3
lines changed

16 files changed

+345
-3
lines changed

‎build.gradle‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@ var bindings = [
2828
]
2929
var plugins = [
3030
'springwolf-amqp',
31+
'springwolf-asb',
3132
'springwolf-cloud-stream',
3233
'springwolf-jms',
3334
'springwolf-kafka',

‎gradle/libs.versions.toml‎

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,11 +7,11 @@ io-awspring-cloud = "3.3.0"
77
io-confluent = "7.9.0"
88
io-swagger-core-v3 = "2.2.30"
99
jackson-core = "2.18.3"
10-
kotlin = "2.1.20"
10+
kotlin = "2.1.20"
1111
node-plugin = "7.1.0"
1212
nodeVersion = "22.12.0"
1313
npm = "10.9.0"
14-
openapi-gradle = "1.9.0"
14+
openapi-gradle = "1.9.0"
1515
org-junit-jupiter = "5.12.1"
1616
org-junit-plattform = "1.12.1"
1717
org-mockito = "5.17.0"
@@ -24,10 +24,13 @@ spotless = "7.0.3"
2424
spring-boot-plugin = "3.4.4"
2525
spring-cloud = "2024.0.1" # not managed by spring-boot-dependencies
2626
spring-cloud-stream = "4.2.1" # not managed by spring-boot-dependencies
27-
27+
azure-messaging-servicebus = "7.17.10"
28+
azure-service-bus-starter="5.20.1"
2829
[libraries]
2930
activemq-broker = { module = "org.apache.activemq:activemq-broker", version.ref = "activemq" }
3031
amqp-client = "com.rabbitmq:amqp-client:5.25.0"
32+
azure-messaging-service-bus = { module = "com.azure:azure-messaging-servicebus", version.ref = "azure-messaging-servicebus" }
33+
azure-service-bus-starter = {module = "com.azure.spring:spring-cloud-azure-starter-servicebus", version.ref = "azure-service-bus-starter"}
3134
assertj-core = "org.assertj:assertj-core:3.27.3"
3235
avro = "org.apache.avro:avro:1.12.0"
3336
awaitility = "org.awaitility:awaitility:4.3.0"

‎settings.gradle‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ include(
44
'springwolf-asyncapi',
55
'springwolf-core',
66
'springwolf-plugins:springwolf-amqp-plugin',
7+
'springwolf-plugins:springwolf-asb-plugin',
78
'springwolf-plugins:springwolf-cloud-stream-plugin',
89
'springwolf-plugins:springwolf-jms-plugin',
910
'springwolf-plugins:springwolf-kafka-plugin',
@@ -12,6 +13,7 @@ include(
1213
'springwolf-plugins:springwolf-stomp-plugin',
1314
'springwolf-examples:e2e',
1415
'springwolf-examples:springwolf-amqp-example',
16+
'springwolf-examples:springwolf-asb-example',
1517
'springwolf-examples:springwolf-cloud-stream-example',
1618
'springwolf-examples:springwolf-jms-example',
1719
'springwolf-examples:springwolf-kafka-example',
@@ -33,6 +35,7 @@ include(
3335
)
3436

3537
project(':springwolf-plugins:springwolf-amqp-plugin').name = 'springwolf-amqp'
38+
project(':springwolf-plugins:springwolf-asb-plugin').name = 'springwolf-asb'
3639
project(':springwolf-plugins:springwolf-cloud-stream-plugin').name = 'springwolf-cloud-stream'
3740
project(':springwolf-plugins:springwolf-jms-plugin').name = 'springwolf-jms'
3841
project(':springwolf-plugins:springwolf-kafka-plugin').name = 'springwolf-kafka'

‎springwolf-examples/springwolf-asb-example/.env‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
SPRINGWOLF_VERSION=1.13.0-SNAPSHOT

‎springwolf-examples/springwolf-asb-example/build.gradle‎

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,35 @@
1+
import org.springframework.boot.gradle.plugin.SpringBootPlugin
2+
3+
plugins {
4+
id 'java'
5+
6+
alias libs.plugins.spring.boot
7+
// alias libs.plugins.cutterslade.analyze
8+
9+
alias libs.plugins.docker.spring.boot
10+
}
11+
12+
dependencies {
13+
implementation project(":springwolf-core")
14+
implementation project(":springwolf-plugins:springwolf-asb")
15+
// permitUnusedDeclared project(":springwolf-plugins:springwolf-asb")
16+
17+
// annotationProcessor project(":springwolf-plugins:springwolf-amqp")
18+
runtimeOnly project(":springwolf-ui")
19+
20+
annotationProcessor libs.lombok
21+
compileOnly libs.lombok
22+
23+
runtimeOnly libs.spring.boot.starter.web
24+
25+
implementation libs.azure.service.bus.starter
26+
27+
implementation libs.slf4j.api
28+
implementation libs.swagger.annotations.jakarta
29+
30+
implementation platform(SpringBootPlugin.BOM_COORDINATES)
31+
implementation libs.spring.boot.autoconfigure
32+
implementation libs.spring.boot
33+
implementation libs.spring.context
34+
}
35+

‎springwolf-examples/springwolf-asb-example/src/main/java/io/github/springwolf/examples/asb/SpringwolfAsbExampleApplication.java‎

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
// SPDX-License-Identifier: Apache-2.0
2+
package io.github.springwolf.examples.asb;
3+
4+
import org.springframework.boot.SpringApplication;
5+
import org.springframework.boot.autoconfigure.SpringBootApplication;
6+
7+
@SpringBootApplication
8+
public class SpringwolfAsbExampleApplication {
9+
10+
public static void main(String[] args) {
11+
SpringApplication.run(SpringwolfAsbExampleApplication.class, args);
12+
}
13+
}

‎springwolf-examples/springwolf-asb-example/src/main/resources/application.properties‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,21 @@
1+
#########
2+
# Spring configuration
3+
spring.application.name=Springwolf example project - Azure Service Bus (ASB)
4+
5+
6+
#########
7+
# Spring azure service bus configuration
8+
spring.cloud.azure.servicebus.enabled=true
9+
spring.cloud.azure.servicebus.connection-string=Endpoint=sb://localhost;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;
10+
spring.cloud.azure.servicebus.producer.entity-name=test
11+
spring.cloud.azure.servicebus.producer.entity-type=queue
12+
13+
14+
#########
15+
# Springwolf configuration
16+
springwolf.enabled=true
17+
springwolf.docket.base-package=io.github.springwolf.examples.asb
18+
19+
20+
springwolf.plugin.asb.publishing.enabled=true
21+

‎springwolf-plugins/springwolf-asb-plugin/build.gradle‎

Lines changed: 72 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,72 @@
1+
import org.springframework.boot.gradle.plugin.SpringBootPlugin
2+
3+
plugins {
4+
id 'java-library'
5+
6+
alias libs.plugins.spring.boot
7+
// alias libs.plugins.cutterslade.analyze
8+
}
9+
10+
dependencies {
11+
api project(":springwolf-core")
12+
api project(":springwolf-asyncapi")
13+
api project(":springwolf-bindings:springwolf-amqp-binding")
14+
// permitUnusedDeclared project(":springwolf-bindings:springwolf-amqp-binding")
15+
16+
implementation libs.slf4j.api
17+
18+
annotationProcessor platform(SpringBootPlugin.BOM_COORDINATES)
19+
implementation platform(SpringBootPlugin.BOM_COORDINATES)
20+
implementation libs.spring.context
21+
implementation libs.spring.core
22+
implementation libs.spring.web
23+
implementation libs.spring.boot
24+
implementation libs.spring.boot.autoconfigure
25+
implementation libs.azure.messaging.service.bus
26+
27+
annotationProcessor libs.lombok
28+
compileOnly libs.lombok
29+
30+
implementation libs.jakarta.annotation.api
31+
32+
annotationProcessor libs.spring.boot.configuration.processor
33+
34+
testAnnotationProcessor libs.lombok
35+
36+
testImplementation libs.assertj.core
37+
38+
testImplementation libs.mockito.core
39+
testImplementation libs.jackson.databind
40+
41+
testImplementation libs.spring.boot.test
42+
testImplementation libs.spring.beans
43+
testImplementation libs.spring.test
44+
45+
testAnnotationProcessor libs.lombok
46+
47+
testImplementation libs.junit.jupiter.api
48+
testRuntimeOnly libs.junit.jupiter
49+
testRuntimeOnly libs.junit.plattform.launcher
50+
}
51+
52+
jar {
53+
enabled = true
54+
archiveClassifier = ''
55+
}
56+
bootJar.enabled = false
57+
58+
java {
59+
withJavadocJar()
60+
withSourcesJar()
61+
}
62+
63+
publishing {
64+
publications {
65+
mavenJava(MavenPublication) {
66+
pom {
67+
name = 'springwolf-asb'
68+
description = 'Automated JSON API documentation for AMQP (Azure Service Bus) Listeners built with Spring'
69+
}
70+
}
71+
}
72+
}

‎springwolf-plugins/springwolf-asb-plugin/src/main/java/io/github/springwolf/plugins/asb/asyncapi/SpringwolfAsbAutoConfiguration.java‎

Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
// SPDX-License-Identifier: Apache-2.0
2+
package io.github.springwolf.plugins.asb.asyncapi;
3+
4+
import io.github.springwolf.core.configuration.properties.SpringwolfConfigConstants;
5+
import org.springframework.boot.autoconfigure.AutoConfiguration;
6+
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
7+
import org.springframework.context.annotation.Import;
8+
9+
/**
10+
* SpringwolfAsbAutoConfiguration for the springwolf asb plugin.
11+
*/
12+
13+
@AutoConfiguration
14+
@ConditionalOnProperty(name = SpringwolfConfigConstants.SPRINGWOLF_ENABLED, havingValue = "true", matchIfMissing = true)
15+
@Import({
16+
SpringwolfAsbPropertiesConfiguration.class,
17+
SpringwolfAsbProducerConfiguration.class
18+
})
19+
public class SpringwolfAsbAutoConfiguration {
20+
21+
22+
}

‎springwolf-plugins/springwolf-asb-plugin/src/main/java/io/github/springwolf/plugins/asb/asyncapi/SpringwolfAsbConfigConstants.java‎

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
package io.github.springwolf.plugins.asb.asyncapi;
2+
3+
import static io.github.springwolf.core.configuration.properties.SpringwolfConfigConstants.SPRINGWOLF_PLUGIN_CONFIG_PREFIX;
4+
5+
/**
6+
* SpringwolfAsbConfigConstants.
7+
*/
8+
public class SpringwolfAsbConfigConstants {
9+
public static final String SPRINGWOLF_AMQP_CONFIG_PREFIX = SPRINGWOLF_PLUGIN_CONFIG_PREFIX + ".asb";
10+
public static final String SPRINGWOLF_ASB_PLUGIN_PUBLISHING_ENABLED = "publishing.enabled";
11+
}

0 commit comments

Comments
 (0)