Skip to content

Commit 52d4380

Browse files
committed
Remove Reactive support
This removes all support for Spring Pulsar Reactive. Signed-off-by: onobc <[email protected]>
1 parent c26b1e1 commit 52d4380

File tree

109 files changed

+23
-9972
lines changed

Some content is hidden

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

109 files changed

+23
-9972
lines changed

README.adoc

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -92,9 +92,6 @@ Provides a Gradle https://docs.gradle.org/current/userguide/java_platform_plugin
9292
=== spring-pulsar-docs
9393
Provides reference docs and handles aggregating javadocs.
9494

95-
=== spring-pulsar-reactive
96-
Provides the API to access Apache Pulsar using a Reactive client.
97-
9895
=== spring-pulsar-sample-apps
9996
Provides sample applications to illustrate Spring for Apache Pulsar functionality as well as provide ability for quick manual verification during development.
10097

gradle/aggregate-jacoco-report.gradle

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ project.afterEvaluate {
1414

1515
dependsOn(
1616
':spring-pulsar:compileJava',
17-
':spring-pulsar-reactive:compileJava',
1817
':spring-pulsar-cache-provider:compileJava',
1918
':spring-pulsar-cache-provider:test',
2019
':spring-pulsar-cache-provider-caffeine:compileJava')

gradle/antora-docs.gradle

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,11 +27,9 @@ def generateAttributes() {
2727
def springCloudStreamVersion = versionCatalog.findVersion("spring-cloud-stream").orElseThrow().displayName
2828
def pulsarClientVersion = versionCatalog.findVersion("pulsar").orElseThrow().displayName
2929
def pulsarClientVersionFamily = pulsarClientVersion.tokenize(".")[0] + "." + pulsarClientVersion.tokenize(".")[1] + ".x"
30-
def pulsarClientReactiveVersion = versionCatalog.findVersion("pulsar-reactive").orElseThrow().displayName
3130
return ['is-snapshot-version': project.version.endsWith("-SNAPSHOT"),
3231
'pulsar-client-version': pulsarClientVersion ?: 'current',
3332
'pulsar-client-version-family': pulsarClientVersionFamily ?: 'current',
34-
'pulsar-client-reactive-version': pulsarClientReactiveVersion ?: 'current',
3533
'spring-boot-version': springBootVersionForDocs ?: 'current',
3634
'spring-cloud-stream-version': springCloudStreamVersion ?: 'current',
3735
'spring-framework-version': springFrameworkVersion ?: 'current',

gradle/jacoco-conventions.gradle

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
def javaProjects = [ 'spring-pulsar',
22
'spring-pulsar-cache-provider',
33
'spring-pulsar-cache-provider-caffeine',
4-
'spring-pulsar-reactive',
54
'spring-pulsar-test' ]
65

76

gradle/libs.versions.toml

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,6 @@ micrometer-docs-gen = "1.0.4"
1111
micrometer-tracing = "1.6.0-RC1"
1212
protobuf = "3.25.8"
1313
pulsar = "4.1.1"
14-
pulsar-reactive = "0.7.0"
15-
reactor = "2025.0.0-M7"
1614
spring = "7.0.0-M9"
1715
# tests
1816
assertj = "3.27.6"
@@ -23,8 +21,8 @@ junit = "6.0.0"
2321
hamcrest = "3.0"
2422
mockito = "5.17.0"
2523
spring-dep-mgmt = "1.1.7"
26-
spring-boot = "4.0.0-SNAPSHOT"
27-
spring-boot-for-docs = "4.0.0-SNAPSHOT"
24+
spring-boot = "4.0.0-M3"
25+
spring-boot-for-docs = "4.0.0-M3"
2826
spring-cloud-stream = "5.0.0-SNAPSHOT"
2927
system-lambda = "1.2.1"
3028
testcontainers = "1.21.3"
@@ -52,10 +50,6 @@ micrometer-tracing-bom = { module = "io.micrometer:micrometer-tracing-bom", vers
5250
protobuf-java = { module = "com.google.protobuf:protobuf-java", version.ref = "protobuf" }
5351
protobuf-protoc = { module = "com.google.protobuf:protoc", version.ref = "protobuf" }
5452
pulsar-client-all = { module = "org.apache.pulsar:pulsar-client-all", version.ref = "pulsar" }
55-
pulsar-client-reactive-api = { module = "org.apache.pulsar:pulsar-client-reactive-api", version.ref = "pulsar-reactive" }
56-
pulsar-client-reactive-adapter = { module = "org.apache.pulsar:pulsar-client-reactive-adapter", version.ref = "pulsar-reactive" }
57-
pulsar-client-reactive-producer-cache-caffeine-shaded = { module = "org.apache.pulsar:pulsar-client-reactive-producer-cache-caffeine-shaded", version.ref = "pulsar-reactive" }
58-
reactor-bom = { module = "io.projectreactor:reactor-bom", version.ref = "reactor" }
5953
spring-bom = { module = "org.springframework:spring-framework-bom", version.ref = "spring" }
6054
# Testing libs
6155
assertj-bom = { module = "org.assertj:assertj-bom", version.ref = "assertj" }
@@ -66,7 +60,6 @@ junit-bom = { module = "org.junit:junit-bom", version.ref = "junit" }
6660
mockito-bom = { module = "org.mockito:mockito-bom", version.ref = "mockito" }
6761
spring-boot-starter-amqp = { module = "org.springframework.boot:spring-boot-starter-amqp", version.ref = "spring-boot" }
6862
spring-boot-starter-pulsar = { module = "org.springframework.boot:spring-boot-starter-pulsar", version.ref = "spring-boot" }
69-
spring-boot-starter-pulsar-reactive = { module = "org.springframework.boot:spring-boot-starter-pulsar-reactive", version.ref = "spring-boot" }
7063
spring-boot-starter-test = { module = "org.springframework.boot:spring-boot-starter-test", version.ref = "spring-boot" }
7164
spring-boot-testcontainers = { module = "org.springframework.boot:spring-boot-testcontainers", version.ref = "spring-boot" }
7265
system-lambda = { module = "com.github.stefanbirkner:system-lambda", version.ref = "system-lambda" }

gradle/nullability-conventions.gradle

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
def javaProjects = [ 'spring-pulsar',
22
'spring-pulsar-cache-provider',
33
'spring-pulsar-cache-provider-caffeine',
4-
'spring-pulsar-reactive',
54
'spring-pulsar-test' ]
65

76
allprojects {

gradle/version-catalog-update.gradle

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,7 @@ def isNonStable = { String version ->
1212
def trustedLibPrefixes = [
1313
"org.springframework.",
1414
"io.micrometer.",
15-
"io.spring.dependency-management:",
16-
"org.apache.pulsar:pulsar-client-reactive",
17-
"io.projectreactor:reactor"
15+
"io.spring.dependency-management:"
1816
]
1917

2018
tasks.named("dependencyUpdates").configure {

integration-tests/integration-tests.gradle

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@ repositories {
1414

1515
dependencies {
1616
intTestImplementation project(':spring-pulsar')
17-
intTestImplementation project(':spring-pulsar-reactive')
1817
intTestImplementation project(':spring-pulsar-test')
1918
intTestImplementation 'org.awaitility:awaitility'
2019
intTestImplementation 'org.testcontainers:junit-jupiter'
@@ -26,9 +25,6 @@ dependencies {
2625
intTestImplementation(libs.spring.boot.starter.pulsar) {
2726
exclude group: "org.springframework.pulsar", module: "spring-pulsar"
2827
}
29-
intTestImplementation(libs.spring.boot.starter.pulsar.reactive) {
30-
exclude group: "org.springframework.pulsar", module: "spring-pulsar-reactive"
31-
}
3228
intTestImplementation libs.spring.boot.testcontainers
3329
intTestRuntimeOnly 'org.junit.platform:junit-platform-launcher'
3430
intTestRuntimeOnly libs.logback.classic

integration-tests/src/intTest/java/org/springframework/pulsar/inttest/app/ReactiveAppConfig.java

Lines changed: 0 additions & 67 deletions
This file was deleted.

integration-tests/src/intTest/java/org/springframework/pulsar/inttest/app/SamplePulsarApplicationSslTests.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -34,11 +34,6 @@ class ImperativeAppTests implements SpringBootTestImperativeApp {
3434

3535
}
3636

37-
@Nested
38-
class ReactiveAppTests implements SpringBootTestReactiveApp {
39-
40-
}
41-
4237
}
4338

4439
@Nested
@@ -50,11 +45,6 @@ class ImperativeAppTests implements SpringBootTestImperativeApp {
5045

5146
}
5247

53-
@Nested
54-
class ReactiveAppTests implements SpringBootTestReactiveApp {
55-
56-
}
57-
5848
}
5949

6050
}

0 commit comments

Comments
 (0)