diff --git a/spring-messaging/src/main/java/org/springframework/messaging/MessageChannel.java b/spring-messaging/src/main/java/org/springframework/messaging/MessageChannel.java
index ff92e0c364f..0423ac265dd 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/MessageChannel.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/MessageChannel.java
@@ -39,7 +39,7 @@ public interface MessageChannel {
*
This method may block indefinitely, depending on the implementation.
* To provide a maximum wait time, use {@link #send(Message, long)}.
* @param message the message to send
- * @return whether or not the message was sent
+ * @return whether the message was sent
*/
default boolean send(Message> message) {
return send(message, INDEFINITE_TIMEOUT);
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/converter/AbstractMessageConverter.java b/spring-messaging/src/main/java/org/springframework/messaging/converter/AbstractMessageConverter.java
index b8400e046c8..56269e9ba32 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/converter/AbstractMessageConverter.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/converter/AbstractMessageConverter.java
@@ -127,7 +127,7 @@ public abstract class AbstractMessageConverter implements SmartMessageConverter
* Whether this converter should convert messages for which no content type
* could be resolved through the configured
* {@link org.springframework.messaging.converter.ContentTypeResolver}.
- *
A converter can configured to be strict only when a
+ *
A converter can be configured to be strict only when a
* {@link #setContentTypeResolver contentTypeResolver} is configured and the
* list of {@link #getSupportedMimeTypes() supportedMimeTypes} is not be empty.
*
When this flag is set to {@code true}, {@link #supportsMimeType(MessageHeaders)}
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/AbstractNamedValueMethodArgumentResolver.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/AbstractNamedValueMethodArgumentResolver.java
index 2075aa9e889..f35a97eae87 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/AbstractNamedValueMethodArgumentResolver.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/AbstractNamedValueMethodArgumentResolver.java
@@ -186,7 +186,7 @@ public abstract class AbstractNamedValueMethodArgumentResolver implements SyncHa
/**
* Invoked when a value is required, but {@link #resolveArgumentInternal}
- * returned {@code null} and there is no default value. Sub-classes can
+ * returned {@code null} and there is no default value. Subclasses can
* throw an appropriate exception for this case.
* @param name the name for the value
* @param parameter the target method parameter
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/MessageMappingMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/MessageMappingMessageHandler.java
index 86bd2720850..771680dbc43 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/MessageMappingMessageHandler.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/reactive/MessageMappingMessageHandler.java
@@ -65,7 +65,7 @@ import org.springframework.validation.Validator;
/**
* Extension of {@link AbstractMethodMessageHandler} for reactive, non-blocking
* handling of messages via {@link MessageMapping @MessageMapping} methods.
- * By default such methods are detected in {@code @Controller} Spring beans but
+ * By default, such methods are detected in {@code @Controller} Spring beans but
* that can be changed via {@link #setHandlerPredicate(Predicate)}.
*
*
Payloads for incoming messages are decoded through the configured
@@ -74,7 +74,7 @@ import org.springframework.validation.Validator;
*
*
There is no default handling for return values but
* {@link #setReturnValueHandlerConfigurer} can be used to configure custom
- * return value handlers. Sub-classes may also override
+ * return value handlers. Subclasses may also override
* {@link #initReturnValueHandlers()} to set up default return value handlers.
*
* @author Rossen Stoyanchev
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AbstractNamedValueMethodArgumentResolver.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AbstractNamedValueMethodArgumentResolver.java
index f64407b18dc..4d6be65ccd2 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AbstractNamedValueMethodArgumentResolver.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AbstractNamedValueMethodArgumentResolver.java
@@ -198,7 +198,7 @@ public abstract class AbstractNamedValueMethodArgumentResolver implements Handle
/**
* Invoked when a value is required, but {@link #resolveArgumentInternal}
- * returned {@code null} and there is no default value. Sub-classes can
+ * returned {@code null} and there is no default value. Subclasses can
* throw an appropriate exception for this case.
* @param name the name for the value
* @param parameter the target method parameter
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AnnotationExceptionHandlerMethodResolver.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AnnotationExceptionHandlerMethodResolver.java
index 21493b46924..9be3e2d504e 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AnnotationExceptionHandlerMethodResolver.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/annotation/support/AnnotationExceptionHandlerMethodResolver.java
@@ -29,7 +29,7 @@ import org.springframework.messaging.handler.annotation.MessageExceptionHandler;
import org.springframework.messaging.handler.invocation.AbstractExceptionHandlerMethodResolver;
/**
- * A sub-class of {@link AbstractExceptionHandlerMethodResolver} that looks for
+ * A subclass of {@link AbstractExceptionHandlerMethodResolver} that looks for
* {@link MessageExceptionHandler}-annotated methods in a given class. The actual
* exception types handled are extracted either from the annotation, if present,
* or from the method signature as a fallback option.
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractExceptionHandlerMethodResolver.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractExceptionHandlerMethodResolver.java
index 6bf11cf119b..86d7471d269 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractExceptionHandlerMethodResolver.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractExceptionHandlerMethodResolver.java
@@ -67,8 +67,8 @@ public abstract class AbstractExceptionHandlerMethodResolver {
/**
* Extract the exceptions this method handles. This implementation looks for
- * sub-classes of Throwable in the method signature.
- *
The method is static to ensure safe use from sub-class constructors.
+ * subclasses of Throwable in the method signature.
+ *
The method is static to ensure safe use from subclass constructors.
*/
@SuppressWarnings("unchecked")
protected static List> getExceptionsFromMethodSignature(Method method) {
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractMethodMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractMethodMessageHandler.java
index f160d506eed..2c2517bc701 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractMethodMessageHandler.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/AbstractMethodMessageHandler.java
@@ -340,7 +340,7 @@ public abstract class AbstractMethodMessageHandler
/**
* Provide the mapping for a handler method.
* @param method the method to provide a mapping for
- * @param handlerType the handler type, possibly a sub-type of the method's declaring class
+ * @param handlerType the handler type, possibly a subtype of the method's declaring class
* @return the mapping, or {@code null} if the method is not mapped
*/
@Nullable
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/InvocableHandlerMethod.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/InvocableHandlerMethod.java
index 3dc5e2ec263..0b84083d8f0 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/InvocableHandlerMethod.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/InvocableHandlerMethod.java
@@ -78,7 +78,7 @@ public class InvocableHandlerMethod extends HandlerMethod {
/**
- * Set {@link HandlerMethodArgumentResolver HandlerMethodArgumentResolvers} to use to use for resolving method argument values.
+ * Set {@link HandlerMethodArgumentResolver HandlerMethodArgumentResolvers} to use for resolving method argument values.
*/
public void setMessageMethodArgumentResolvers(HandlerMethodArgumentResolverComposite argumentResolvers) {
this.resolvers = argumentResolvers;
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/AbstractMethodMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/AbstractMethodMessageHandler.java
index a240f4d8efa..b8a72642ce3 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/AbstractMethodMessageHandler.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/AbstractMethodMessageHandler.java
@@ -113,7 +113,7 @@ public abstract class AbstractMethodMessageHandler
/**
* Configure a predicate for selecting which Spring beans to check for the
* presence of message handler methods.
- * This is not set by default. However sub-classes may initialize it to
+ *
This is not set by default. However, subclasses may initialize it to
* some default strategy (e.g. {@code @Controller} classes).
* @see #setHandlers(List)
*/
@@ -235,7 +235,7 @@ public abstract class AbstractMethodMessageHandler
/**
* Return the argument resolvers initialized during {@link #afterPropertiesSet()}.
- * Primarily for internal use in sub-classes.
+ * Primarily for internal use in subclasses.
* @since 5.2.2
*/
protected HandlerMethodArgumentResolverComposite getArgumentResolvers() {
@@ -362,7 +362,7 @@ public abstract class AbstractMethodMessageHandler
/**
* Obtain the mapping for the given method, if any.
* @param method the method to check
- * @param handlerType the handler type, possibly a sub-type of the method's declaring class
+ * @param handlerType the handler type, possibly a subtype of the method's declaring class
* @return the mapping, or {@code null} if the method is not mapped
*/
@Nullable
@@ -418,7 +418,7 @@ public abstract class AbstractMethodMessageHandler
/**
* This method is invoked just before mappings are added. It allows
- * sub-classes to update the mapping with the {@link HandlerMethod} in mind.
+ * subclasses to update the mapping with the {@link HandlerMethod} in mind.
* This can be useful when the method signature is used to refine the
* mapping, e.g. based on the cardinality of input and output.
* By default this method returns the mapping that is passed in.
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/InvocableHandlerMethod.java b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/InvocableHandlerMethod.java
index 18f17b5a27f..b3be50c33dc 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/InvocableHandlerMethod.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/handler/invocation/reactive/InvocableHandlerMethod.java
@@ -77,7 +77,7 @@ public class InvocableHandlerMethod extends HandlerMethod {
/**
- * Configure the argument resolvers to use to use for resolving method
+ * Configure the argument resolvers to use for resolving method
* argument values against a {@code ServerWebExchange}.
*/
public void setArgumentResolvers(List resolvers) {
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java
index 365d894cb95..80b18ec1704 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketRequester.java
@@ -91,7 +91,7 @@ public interface RSocketRequester extends Disposable {
* If a formatted variable contains a "." it is replaced with the escape
* sequence "%2E" to avoid treating it as separator by the responder .
* If the connection is set to use composite metadata, the route is
- * encoded as {@code "message/x.rsocket.routing.v0"}. Otherwise the route
+ * encoded as {@code "message/x.rsocket.routing.v0"}. Otherwise, the route
* is encoded according to the mime type for the connection.
* @param route the route expressing a remote handler mapping
* @param routeVars variables to be expanded into the route template
@@ -105,7 +105,7 @@ public interface RSocketRequester extends Disposable {
* to a {@link Publisher} via {@link ReactiveAdapterRegistry}.
* @param metadata the metadata value to encode
* @param mimeType the mime type that describes the metadata;
- * This is required for connection using composite metadata. Otherwise the
+ * This is required for connection using composite metadata. Otherwise, the
* value is encoded according to the mime type for the connection and this
* argument may be left as {@code null}.
*/
@@ -434,7 +434,7 @@ public interface RSocketRequester extends Disposable {
*
If the return type is {@code Mono}, the {@code Mono} will
* complete after all data is consumed.
* Note: This method will raise an error if
- * the request payload is a multi-valued {@link Publisher} as there is
+ * the request payload is a multivalued {@link Publisher} as there is
* no many-to-one RSocket interaction.
* @param dataType the expected data type for the response
* @param parameter for the expected data type
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java
index 332603561ac..8e8a43a10f1 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/RSocketStrategies.java
@@ -183,7 +183,7 @@ public interface RSocketStrategies {
Builder routeMatcher(@Nullable RouteMatcher routeMatcher);
/**
- * Configure the registry for reactive type support. This can be used to
+ * Configure the registry for reactive type support. This can be used
* to adapt to, and/or determine the semantics of a given
* {@link org.reactivestreams.Publisher Publisher}.
* By default this {@link ReactiveAdapterRegistry#getSharedInstance()}.
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java
index f7b06d8be3c..a483b32dde3 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/MessagingRSocket.java
@@ -104,7 +104,7 @@ class MessagingRSocket implements RSocket {
*/
public Mono handleConnectionSetupPayload(ConnectionSetupPayload payload) {
// frameDecoder does not apply to connectionSetupPayload
- // so retain here since handle expects it..
+ // so retain here since handle expects it.
payload.retain();
return handle(payload, FrameType.SETUP);
}
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketFrameTypeMessageCondition.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketFrameTypeMessageCondition.java
index b8e1f303e8d..925c61edc8f 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketFrameTypeMessageCondition.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketFrameTypeMessageCondition.java
@@ -169,7 +169,7 @@ public class RSocketFrameTypeMessageCondition extends AbstractMessageConditionThe table below shows the selections made:
*
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketMessageHandler.java
index a779b327262..27fb1a5d76f 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketMessageHandler.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/rsocket/annotation/support/RSocketMessageHandler.java
@@ -193,7 +193,7 @@ public class RSocketMessageHandler extends MessageMappingMessageHandler {
* likewise when this property is set the {@code RSocketStrategies} are
* mutated to change the extractor in it.
* By default this is set to the
- * {@link org.springframework.messaging.rsocket.RSocketStrategies.Builder#metadataExtractor(MetadataExtractor)} defaults}
+ * {@link org.springframework.messaging.rsocket.RSocketStrategies.Builder#metadataExtractor(MetadataExtractor) defaults}
* from {@code RSocketStrategies}.
* @param extractor the extractor to use
*/
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/SimpMessageHeaderAccessor.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/SimpMessageHeaderAccessor.java
index 307b1071e57..b32c3836ed1 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/SimpMessageHeaderAccessor.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/SimpMessageHeaderAccessor.java
@@ -91,7 +91,7 @@ public class SimpMessageHeaderAccessor extends NativeMessageHeaderAccessor {
/**
* A constructor for creating new message headers.
- * This constructor is protected. See factory methods in this and sub-classes.
+ * This constructor is protected. See factory methods in this and subclasses.
*/
protected SimpMessageHeaderAccessor(SimpMessageType messageType,
@Nullable Map> externalSourceHeaders) {
@@ -104,7 +104,7 @@ public class SimpMessageHeaderAccessor extends NativeMessageHeaderAccessor {
/**
* A constructor for accessing and modifying existing message headers. This
- * constructor is protected. See factory methods in this and sub-classes.
+ * constructor is protected. See factory methods in this and subclasses.
*/
protected SimpMessageHeaderAccessor(Message> message) {
super(message);
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/AbstractBrokerMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/AbstractBrokerMessageHandler.java
index 1babc663ebf..b504047a770 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/AbstractBrokerMessageHandler.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/AbstractBrokerMessageHandler.java
@@ -247,7 +247,7 @@ public abstract class AbstractBrokerMessageHandler
* Check whether this message handler is currently running.
* Note that even when this message handler is running the
* {@link #isBrokerAvailable()} flag may still independently alternate between
- * being on and off depending on the concrete sub-class implementation.
+ * being on and off depending on the concrete subclass implementation.
*/
@Override
public final boolean isRunning() {
@@ -260,7 +260,7 @@ public abstract class AbstractBrokerMessageHandler
* indicates whether this message handler is running. In other words the message
* handler must first be running and then the {@code #isBrokerAvailable()} flag
* may still independently alternate between being on and off depending on the
- * concrete sub-class implementation.
+ * concrete subclass implementation.
*
Application components may implement
* {@code org.springframework.context.ApplicationListener<BrokerAvailabilityEvent>}
* to receive notifications when broker becomes available and unavailable.
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/OrderedMessageChannelDecorator.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/OrderedMessageChannelDecorator.java
index 7a55adde7c3..f4312910dc2 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/OrderedMessageChannelDecorator.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/broker/OrderedMessageChannelDecorator.java
@@ -35,7 +35,7 @@ import org.springframework.util.Assert;
/**
* Decorator for an {@link ExecutorSubscribableChannel} that ensures messages
* are processed in the order they were published to the channel. Messages are
- * sent one at a time with the next one released when the prevoius has been
+ * sent one at a time with the next one released when the previous has been
* processed. This decorator is intended to be applied per session.
*
* @author Rossen Stoyanchev
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java
index a0285a2d2f5..d1f0c451710 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompBrokerRelayMessageHandler.java
@@ -923,7 +923,7 @@ public class StompBrokerRelayMessageHandler extends AbstractBrokerMessageHandler
/**
* After a DISCONNECT there should be no more client frames so we can
- * close the connection pro-actively. However, if the DISCONNECT has a
+ * close the connection proactively. However, if the DISCONNECT has a
* receipt header we leave the connection open and expect the server will
* respond with a RECEIPT and then close the connection.
* @see
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompDecoder.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompDecoder.java
index d71f78752cc..b8c5e6cbf72 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompDecoder.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompDecoder.java
@@ -92,9 +92,9 @@ public class StompDecoder {
* Decodes one or more STOMP frames from the given {@code buffer} and returns
* a list of {@link Message Messages}.
* If the given ByteBuffer contains only partial STOMP frame content and no
- * complete STOMP frames, an empty list is returned, and the buffer is reset to
+ * complete STOMP frames, an empty list is returned, and the buffer is reset
* to where it was.
- *
If the buffer contains one ore more STOMP frames, those are returned and
+ *
If the buffer contains one or more STOMP frames, those are returned and
* the buffer reset to point to the beginning of the unused partial content.
*
The output partialMessageHeaders map is used to store successfully parsed
* headers in case of partial content. The caller can then check if a
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompSession.java b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompSession.java
index 61e0b68489d..01ad81b8d44 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompSession.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/simp/stomp/StompSession.java
@@ -82,7 +82,7 @@ public interface StompSession {
/**
* An overloaded version of {@link #subscribe(String, StompFrameHandler)}
* with full {@link StompHeaders} instead of just a destination.
- * @param headers the headers for the subscribe message frame
+ * @param headers the headers for the subscribed message frame
* @param handler the handler for received messages
* @return a handle to use to unsubscribe and/or track receipts
*/
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/support/ExecutorChannelInterceptor.java b/spring-messaging/src/main/java/org/springframework/messaging/support/ExecutorChannelInterceptor.java
index c53869f48b9..ef34ae90ec6 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/support/ExecutorChannelInterceptor.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/support/ExecutorChannelInterceptor.java
@@ -60,7 +60,7 @@ public interface ExecutorChannelInterceptor extends ChannelInterceptor {
* @param message the message handled
* @param channel the channel on which the message was sent to
* @param handler the target handler that handled the message
- * @param ex any exception that may been raised by the handler
+ * @param ex any exception that may have been raised by the handler
*/
default void afterMessageHandled(Message> message, MessageChannel channel, MessageHandler handler,
@Nullable Exception ex) {
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/support/MessageBuilder.java b/spring-messaging/src/main/java/org/springframework/messaging/support/MessageBuilder.java
index 64d75f2d0f9..4e58b578db9 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/support/MessageBuilder.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/support/MessageBuilder.java
@@ -110,7 +110,7 @@ public final class MessageBuilder {
/**
* Copy the name-value pairs from the provided Map. This operation will overwrite any
- * existing values. Use { {@link #copyHeadersIfAbsent(Map)} to avoid overwriting
+ * existing values. Use {@link #copyHeadersIfAbsent(Map)} to avoid overwriting
* values. Note that the 'id' and 'timestamp' header values will never be overwritten.
*/
public MessageBuilder copyHeaders(@Nullable Map headersToCopy) {
@@ -169,7 +169,7 @@ public final class MessageBuilder {
/**
- * Create a builder for a new {@link Message} instance pre-populated with all of the
+ * Create a builder for a new {@link Message} instance pre-populated with all the
* headers copied from the provided message. The payload of the provided Message will
* also be used as the payload for the new message.
* If the provided message is an {@link ErrorMessage}, the
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/support/MessageHeaderAccessor.java b/spring-messaging/src/main/java/org/springframework/messaging/support/MessageHeaderAccessor.java
index 95e04b63f48..8ea3f285396 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/support/MessageHeaderAccessor.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/support/MessageHeaderAccessor.java
@@ -43,12 +43,12 @@ import org.springframework.util.StringUtils;
* strongly typed accessors for specific headers, the ability to leave headers
* in a {@link Message} mutable, and the option to suppress automatic generation
* of {@link MessageHeaders#ID id} and {@link MessageHeaders#TIMESTAMP
- * timesteamp} headers. Sub-classes such as {@link NativeMessageHeaderAccessor}
+ * timesteamp} headers. Subclasses such as {@link NativeMessageHeaderAccessor}
* and others provide support for managing processing vs external source headers
* as well as protocol specific headers.
*
*
Below is a workflow to initialize headers via {@code MessageHeaderAccessor},
- * or one of its sub-classes, then create a {@link Message}, and then re-obtain
+ * or one of its subclasses, then create a {@link Message}, and then re-obtain
* the accessor possibly from a different component:
*
* // Create a message with headers
@@ -153,7 +153,7 @@ public class MessageHeaderAccessor {
// Configuration properties
/**
- * By default when {@link #getMessageHeaders()} is called, {@code "this"}
+ * By default, when {@link #getMessageHeaders()} is called, {@code "this"}
* {@code MessageHeaderAccessor} instance can no longer be used to modify the
* underlying message headers and the returned {@code MessageHeaders} is immutable.
* However when this is set to {@code true}, the returned (underlying)
@@ -173,7 +173,7 @@ public class MessageHeaderAccessor {
}
/**
- * By default when {@link #getMessageHeaders()} is called, {@code "this"}
+ * By default, when {@link #getMessageHeaders()} is called, {@code "this"}
* {@code MessageHeaderAccessor} instance can no longer be used to modify the
* underlying message headers. However if {@link #setLeaveMutable(boolean)}
* is used, this method is necessary to indicate explicitly when the
diff --git a/spring-messaging/src/main/java/org/springframework/messaging/support/NativeMessageHeaderAccessor.java b/spring-messaging/src/main/java/org/springframework/messaging/support/NativeMessageHeaderAccessor.java
index 2a3607fde2b..1089119c605 100644
--- a/spring-messaging/src/main/java/org/springframework/messaging/support/NativeMessageHeaderAccessor.java
+++ b/spring-messaging/src/main/java/org/springframework/messaging/support/NativeMessageHeaderAccessor.java
@@ -36,9 +36,9 @@ import org.springframework.util.ObjectUtils;
* key {@link #NATIVE_HEADERS}. This allows separating processing headers from
* headers that need to be sent to or received from the external source.
*
- *
This class is likely to be used through indirectly through a protocol
- * specific sub-class that also provide factory methods to translate
- * message headers to an from an external messaging source.
+ *
This class is likely to be used indirectly through a protocol-specific
+ * subclass that also provide factory methods to translate
+ * message headers to and from an external messaging source.
*
* @author Rossen Stoyanchev
* @since 4.0
diff --git a/spring-messaging/src/test/java/org/springframework/messaging/handler/invocation/TestExceptionResolver.java b/spring-messaging/src/test/java/org/springframework/messaging/handler/invocation/TestExceptionResolver.java
index bf30e67416e..bc13d1f27b7 100644
--- a/spring-messaging/src/test/java/org/springframework/messaging/handler/invocation/TestExceptionResolver.java
+++ b/spring-messaging/src/test/java/org/springframework/messaging/handler/invocation/TestExceptionResolver.java
@@ -24,7 +24,7 @@ import org.springframework.core.MethodIntrospector;
import org.springframework.util.ReflectionUtils;
/**
- * Sub-class for {@link AbstractExceptionHandlerMethodResolver} for testing.
+ * Subclass for {@link AbstractExceptionHandlerMethodResolver} for testing.
* @author Rossen Stoyanchev
*/
public class TestExceptionResolver extends AbstractExceptionHandlerMethodResolver {