SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

some new features of jdk to optimize the code

Browse Source
This commit is contained in:
刘鑫
2023-01-03 18:03:55 +08:00
committed by Oleg Zhurakousky
parent 14edf04189
commit af2df8ba0e
4 changed files with 9 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
binders/kafka-binder/spring-cloud-stream-binder-kafka-streams/src/main/java/org/springframework/cloud/stream/binder/kafka/streams/KafkaStreamsMessageConversionDelegate.java
View File

@@ -285,8 +285,7 @@ public class KafkaStreamsMessageConversionDelegate {
if (o2 != null) {
if (KafkaStreamsMessageConversionDelegate.this.kstreamBindingInformationCatalogue
.isDlqEnabled(bindingTarget)) {
if (o2 instanceof Message) {
Message message = (Message) o2;
if (o2 instanceof Message message) {
// We need to convert the key to a byte[] before sending to DLQ.
Serde keySerde = kstreamBindingInformationCatalogue.getKeySerde(bindingTarget);

3
binders/kafka-binder/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java
View File

@@ -1265,8 +1265,7 @@ public class KafkaMessageChannelBinder extends
}
MessageHeaders headers;
if (message instanceof ErrorMessage) {
final ErrorMessage errorMessage = (ErrorMessage) message;
if (message instanceof ErrorMessage errorMessage) {
final Message<?> originalMessage = errorMessage.getOriginalMessage();
if (originalMessage != null) {
headers = originalMessage.getHeaders();

3
binders/rabbit-binder/spring-cloud-stream-binder-rabbit/src/main/java/org/springframework/cloud/stream/binder/rabbit/config/ObservationAutoConfiguration.java
View File

@@ -38,8 +38,7 @@ public class ObservationAutoConfiguration {
ListenerContainerCustomizer<MessageListenerContainer> observedListenerContainerCustomizer(
ApplicationContext applicationContext) {
return (container, destinationName, group) -> {
if (container instanceof AbstractMessageListenerContainer) {
AbstractMessageListenerContainer abstractMessageListenerContainer = ((AbstractMessageListenerContainer) container);
if (container instanceof AbstractMessageListenerContainer abstractMessageListenerContainer) {
abstractMessageListenerContainer.setObservationEnabled(true);
abstractMessageListenerContainer.setApplicationContext(applicationContext);
}

20
core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingsLifecycleController.java
View File

@@ -111,20 +111,12 @@ public class BindingsLifecycleController {
Binding<?> binding = BindingsLifecycleController.this.locateBinding(bindingName);
if (binding != null) {
switch (state) {
case STARTED:
binding.start();
break;
case STOPPED:
binding.stop();
break;
case PAUSED:
binding.pause();
break;
case RESUMED:
binding.resume();
break;
default:
break;
case STARTED -> binding.start();
case STOPPED -> binding.stop();
case PAUSED -> binding.pause();
case RESUMED -> binding.resume();
default -> {
}
}
}
}