Skip to content

Commit 56c8acd

Browse files
committed
Update to Spring Framework 7.0.0-RC1
This commit updates to Spring Framework and replaces deprecated API usages. Signed-off-by: onobc <[email protected]>
1 parent 9c4f687 commit 56c8acd

File tree

3 files changed

+6
-12
lines changed

3 files changed

+6
-12
lines changed

gradle/libs.versions.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ micrometer-docs-gen = "1.0.4"
1111
micrometer-tracing = "1.6.0-RC1"
1212
protobuf = "3.25.8"
1313
pulsar = "4.1.1"
14-
spring = "7.0.0-M9"
14+
spring = "7.0.0-RC1"
1515
# tests
1616
assertj = "3.27.6"
1717
awaitility = "4.3.0"

spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java

Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,6 @@
7777
import org.springframework.pulsar.transaction.PulsarTransactionUtils;
7878
import org.springframework.scheduling.SchedulingAwareRunnable;
7979
import org.springframework.transaction.TransactionDefinition;
80-
import org.springframework.transaction.TransactionStatus;
81-
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
8280
import org.springframework.transaction.support.TransactionTemplate;
8381
import org.springframework.util.Assert;
8482
import org.springframework.util.CollectionUtils;
@@ -604,14 +602,10 @@ private Observation newObservation(Message<T> message) {
604602
private void dispatchMessageToListenerInTxn(Message<T> message, AtomicBoolean inRetryMode) {
605603
try {
606604
requireNonNull(this.transactionTemplate, "transactionTemplate must not be null")
607-
.execute(new TransactionCallbackWithoutResult() {
608-
@Override
609-
protected void doInTransactionWithoutResult(TransactionStatus status) {
610-
RuntimeException aborted = dispatchMessageToListener(message, inRetryMode,
611-
getTransaction());
612-
if (aborted != null) {
613-
throw aborted;
614-
}
605+
.executeWithoutResult((status) -> {
606+
RuntimeException aborted = dispatchMessageToListener(message, inRetryMode, getTransaction());
607+
if (aborted != null) {
608+
throw aborted;
615609
}
616610
});
617611
}

spring-pulsar/src/main/java/org/springframework/pulsar/listener/adapter/AbstractPulsarMessageToSpringMessageAdapter.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,11 +28,11 @@
2828
import org.apache.pulsar.client.api.Reader;
2929
import org.jspecify.annotations.Nullable;
3030

31-
import org.springframework.context.expression.MapAccessor;
3231
import org.springframework.core.MethodParameter;
3332
import org.springframework.core.log.LogAccessor;
3433
import org.springframework.expression.BeanResolver;
3534
import org.springframework.expression.spel.standard.SpelExpressionParser;
35+
import org.springframework.expression.spel.support.MapAccessor;
3636
import org.springframework.expression.spel.support.StandardEvaluationContext;
3737
import org.springframework.expression.spel.support.StandardTypeConverter;
3838
import org.springframework.messaging.converter.MessageConversionException;

0 commit comments

Comments
 (0)