Update Spring Boot 3.0.2 (#314)
Also update: * testcontainersVersion = `1.17.6` * springCloudStreamVersion = `4.0.1`
This commit is contained in:
@@ -31,7 +31,7 @@ configurations {
|
||||
}
|
||||
|
||||
ext {
|
||||
springBootVersion = '3.0.0'
|
||||
springBootVersion = '3.0.2'
|
||||
}
|
||||
|
||||
dependencies {
|
||||
|
||||
@@ -9,11 +9,11 @@ javaPlatform {
|
||||
ext {
|
||||
googleJsr305Version = '3.0.2'
|
||||
protobufJavaVersion = '3.21.5'
|
||||
testcontainersVersion = '1.17.3'
|
||||
testcontainersVersion = '1.17.6'
|
||||
pulsarVersion = '2.10.2'
|
||||
pulsarClientReactiveVersion = '0.1.0'
|
||||
springBootVersion = '3.0.0'
|
||||
springCloudStreamVersion = '4.0.0'
|
||||
springBootVersion = '3.0.2'
|
||||
springCloudStreamVersion = '4.0.1'
|
||||
}
|
||||
|
||||
dependencies {
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
plugins {
|
||||
id 'org.springframework.pulsar.spring-module'
|
||||
id 'org.springframework.boot' version '3.0.0'
|
||||
id 'org.springframework.boot' version '3.0.2'
|
||||
}
|
||||
|
||||
description = 'Spring Pulsar Sample Application (Send and Receive)'
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
plugins {
|
||||
id 'org.springframework.pulsar.spring-module'
|
||||
id 'org.springframework.boot' version '3.0.0'
|
||||
id 'org.springframework.boot' version '3.0.2'
|
||||
}
|
||||
|
||||
description = 'Spring Pulsar Sample Applications (Custom Routing)'
|
||||
|
||||
@@ -48,9 +48,9 @@ public class FailoverConsumerApp {
|
||||
for (int i = 0; i < 10; i++) {
|
||||
pulsarTemplate.newMessage("hello john doe 0 ").withTopic(topic)
|
||||
.withProducerCustomizer(builder -> builder.messageRouter(new FooRouter())).sendAsync();
|
||||
pulsarTemplate.newMessage("hello alice doe 1")
|
||||
pulsarTemplate.newMessage("hello alice doe 1").withTopic(topic)
|
||||
.withProducerCustomizer(builder -> builder.messageRouter(new BarRouter())).sendAsync();
|
||||
pulsarTemplate.newMessage("hello buzz doe 2")
|
||||
pulsarTemplate.newMessage("hello buzz doe 2").withTopic(topic)
|
||||
.withProducerCustomizer(builder -> builder.messageRouter(new BuzzRouter())).sendAsync();
|
||||
Thread.sleep(1_000);
|
||||
}
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
plugins {
|
||||
id 'org.springframework.pulsar.spring-module'
|
||||
id 'org.springframework.boot' version '3.0.0'
|
||||
id 'org.springframework.boot' version '3.0.2'
|
||||
}
|
||||
|
||||
description = 'Spring Cloud Stream Binder for Pulsar Sample Application'
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
plugins {
|
||||
id 'org.springframework.pulsar.spring-module'
|
||||
id 'org.springframework.boot' version '3.0.0'
|
||||
id 'org.springframework.boot' version '3.0.2'
|
||||
}
|
||||
|
||||
group = 'org.springframework.pulsar.sample'
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
plugins {
|
||||
id 'org.springframework.pulsar.spring-module'
|
||||
id 'org.springframework.boot' version '3.0.0'
|
||||
id 'org.springframework.boot' version '3.0.2'
|
||||
}
|
||||
|
||||
description = 'Reactive Spring Pulsar Sample Application'
|
||||
|
||||
Reference in New Issue
Block a user