Apply Java pattern matching

Author: ngocnhan-tran1996

spring-amqp/src/main/java/org/springframework/amqp/core/MessageProperties.java

@@ -447,12 +447,10 @@ public void setConsumerQueue(String consumerQueue) {
 	 */
 	public Long getDelayLong() {
 		Object delay = this.headers.get(X_DELAY);
-		if (delay instanceof Long) {
-			return (Long) delay;
-		}
-		else {
-			return null;
+		if (delay instanceof Long delayLong) {
+			return delayLong;
 		}
+		return null;
 	}
 
 	/**

spring-amqp/src/main/java/org/springframework/amqp/support/AmqpMessageHeaderAccessor.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2014-2019 the original author or authors.
+ * Copyright 2014-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -87,12 +87,10 @@ public Long getContentLength() {
 	@Override
 	public MimeType getContentType() {
 		Object value = getHeader(AmqpHeaders.CONTENT_TYPE);
-		if (value instanceof String) {
-			return MimeType.valueOf((String) value);
-		}
-		else {
-			return super.getContentType();
+		if (value instanceof String contentType) {
+			return MimeType.valueOf(contentType);
 		}
+		return super.getContentType();
 	}
 
 	public String getCorrelationId() {

spring-amqp/src/main/java/org/springframework/amqp/support/SimpleAmqpHeaderMapper.java

@@ -66,8 +66,8 @@ public void fromHeaders(MessageHeaders headers, MessageProperties amqpMessagePro
 					amqpMessageProperties::setContentLength)
 			.acceptIfHasText(extractContentTypeAsString(headers), amqpMessageProperties::setContentType);
 		Object correlationId = headers.get(AmqpHeaders.CORRELATION_ID);
-		if (correlationId instanceof String) {
-			amqpMessageProperties.setCorrelationId((String) correlationId);
+		if (correlationId instanceof String string) {
+			amqpMessageProperties.setCorrelationId(string);
 		}
 		javaUtils
 			.acceptIfNotNull(getHeaderIfAvailable(headers, AmqpHeaders.DELAY, Long.class),
@@ -195,8 +195,8 @@ private String extractContentTypeAsString(Map<String, Object> headers) {
 			if (contentType instanceof MimeType) {
 				contentTypeStringValue = contentType.toString();
 			}
-			else if (contentType instanceof String) {
-				contentTypeStringValue = (String) contentType;
+			else if (contentType instanceof String string) {
+				contentTypeStringValue = string;
 			}
 			else {
 				if (logger.isWarnEnabled()) {

spring-amqp/src/main/java/org/springframework/amqp/support/converter/AbstractJackson2MessageConverter.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2022 the original author or authors.
+ * Copyright 2018-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -246,8 +246,8 @@ public void setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence typePreceden
 		if (this.typeMapperSet) {
 			throw new IllegalStateException("When providing your own type mapper, you should set the precedence on it");
 		}
-		if (this.javaTypeMapper instanceof DefaultJackson2JavaTypeMapper) {
-			((DefaultJackson2JavaTypeMapper) this.javaTypeMapper).setTypePrecedence(typePrecedence);
+		if (this.javaTypeMapper instanceof DefaultJackson2JavaTypeMapper defaultJackson2JavaTypeMapper) {
+			defaultJackson2JavaTypeMapper.setTypePrecedence(typePrecedence);
 		}
 		else {
 			throw new IllegalStateException("Type precedence is available with the DefaultJackson2JavaTypeMapper");
@@ -384,10 +384,10 @@ else if (inferredType != null && this.alwaysConvertToInferredType) {
 			content = tryConverType(message, encoding, inferredType);
 		}
 		if (content == null) {
-			if (conversionHint instanceof ParameterizedTypeReference) {
+			if (conversionHint instanceof ParameterizedTypeReference<?> parameterizedTypeReference) {
 				content = convertBytesToObject(message.getBody(), encoding,
 						this.objectMapper.getTypeFactory().constructType(
-								((ParameterizedTypeReference<?>) conversionHint).getType()));
+							parameterizedTypeReference.getType()));
 			}
 			else if (getClassMapper() == null) {
 				JavaType targetJavaType = getJavaTypeMapper()

spring-amqp/src/main/java/org/springframework/amqp/support/converter/RemoteInvocationAwareMessageConverterAdapter.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2022 the original author or authors.
+ * Copyright 2016-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -51,9 +51,9 @@ public Message toMessage(Object object, MessageProperties messageProperties) thr
 	@Override
 	public Object fromMessage(Message message) throws MessageConversionException {
 		Object result = this.delegate.fromMessage(message);
-		if (result instanceof RemoteInvocationResult) {
+		if (result instanceof RemoteInvocationResult remoteInvocationResult) {
 			try {
-				result = ((RemoteInvocationResult) result).recreate();
+				result = remoteInvocationResult.recreate();
 				if (result == null) {
 					throw new MessageConversionException("RemoteInvocationResult returned null");
 				}

spring-amqp/src/main/java/org/springframework/amqp/support/converter/RemoteInvocationResult.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2021 the original author or authors.
+ * Copyright 2021-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -143,8 +143,8 @@ public boolean hasInvocationTargetException() {
 	public Object recreate() throws Throwable {
 		if (this.exception != null) {
 			Throwable exToThrow = this.exception;
-			if (this.exception instanceof InvocationTargetException) {
-				exToThrow = ((InvocationTargetException) this.exception).getTargetException();
+			if (this.exception instanceof InvocationTargetException invocationTargetException) {
+				exToThrow = invocationTargetException.getTargetException();
 			}
 			RemoteInvocationUtils.fillInClientStackTraceIfPossible(exToThrow);
 			throw exToThrow;

spring-amqp/src/main/java/org/springframework/amqp/support/converter/SerializerMessageConverter.java

@@ -187,18 +187,18 @@ protected Message createMessage(Object object, MessageProperties messageProperti
 			throws MessageConversionException {
 
 		byte[] bytes;
-		if (object instanceof String) {
+		if (object instanceof String string) {
 			try {
-				bytes = ((String) object).getBytes(this.defaultCharset);
+				bytes = string.getBytes(this.defaultCharset);
 			}
 			catch (UnsupportedEncodingException e) {
 				throw new MessageConversionException("failed to convert Message content", e);
 			}
 			messageProperties.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN);
 			messageProperties.setContentEncoding(this.defaultCharset);
 		}
-		else if (object instanceof byte[]) {
-			bytes = (byte[]) object;
+		else if (object instanceof byte[] objectBytes) {
+			bytes = objectBytes;
 			messageProperties.setContentType(MessageProperties.CONTENT_TYPE_BYTES);
 		}
 		else {

spring-amqp/src/main/java/org/springframework/amqp/support/converter/SimpleMessageConverter.java

@@ -112,13 +112,13 @@ protected Message createMessage(Object object, MessageProperties messageProperti
 			throws MessageConversionException {
 
 		byte[] bytes = null;
-		if (object instanceof byte[]) {
-			bytes = (byte[]) object;
+		if (object instanceof byte[] objectBytes) {
+			bytes = objectBytes;
 			messageProperties.setContentType(MessageProperties.CONTENT_TYPE_BYTES);
 		}
-		else if (object instanceof String) {
+		else if (object instanceof String string) {
 			try {
-				bytes = ((String) object).getBytes(this.defaultCharset);
+				bytes = string.getBytes(this.defaultCharset);
 			}
 			catch (UnsupportedEncodingException e) {
 				throw new MessageConversionException("failed to convert to Message content", e);

spring-amqp/src/main/java/org/springframework/amqp/support/postprocessor/AbstractDecompressingPostProcessor.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2014-2020 the original author or authors.
+ * Copyright 2014-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -83,7 +83,7 @@ protected void setOrder(int order) {
 	public Message postProcessMessage(Message message) throws AmqpException {
 		Object autoDecompress = message.getMessageProperties().getHeaders()
 				.get(MessageProperties.SPRING_AUTO_DECOMPRESS);
-		if (this.alwaysDecompress || (autoDecompress instanceof Boolean && ((Boolean) autoDecompress))) {
+		if (this.alwaysDecompress || (autoDecompress instanceof Boolean isAutoDecompress && isAutoDecompress)) {
 			ByteArrayInputStream zipped = new ByteArrayInputStream(message.getBody());
 			try {
 				InputStream unzipper = getDecompressorStream(zipped);

spring-amqp/src/test/java/org/springframework/amqp/support/converter/AllowedListDeserializingMessageConverterTests.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2016-2023 the original author or authors.
+ * Copyright 2016-2024 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -74,7 +74,7 @@ protected TestBean(String text) {
 
 		@Override
 		public boolean equals(Object other) {
-			return (other instanceof TestBean && this.text.equals(((TestBean) other).text));
+			return (other instanceof TestBean testBean && this.text.equals(testBean.text));
 		}
 
 		@Override