From b7ae2967e24873e2fcffb20a74731872d48ffb97 Mon Sep 17 00:00:00 2001
From: Siddharth Jain <siddharth.jain210@gmail.com>
Date: Sun, 29 Dec 2024 23:10:33 +0530
Subject: [PATCH] GH-249 Corrected all java docs in KplMessageHandler

---
 .../aws/outbound/KplMessageHandler.java        | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git a/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java b/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java
index 643bd13..e937837 100644
--- a/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java
+++ b/src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java
@@ -139,7 +139,9 @@ public void setBackPressureThreshold(long backPressureThreshold) {
 
 	/**
 	 * Configure a {@link MessageConverter} for converting payload to {@code byte[]} for Kinesis record.
+	 *
 	 * @param messageConverter the {@link MessageConverter} to use.
+	 *
 	 * @since 2.3
 	 */
 	public void setMessageConverter(MessageConverter messageConverter) {
@@ -194,9 +196,12 @@ public void setSequenceNumberExpression(Expression sequenceNumberExpression) {
 	/**
 	 * Specify a {@link OutboundMessageMapper} for embedding message headers into the
 	 * record data together with payload.
+	 *
 	 * @param embeddedHeadersMapper the {@link OutboundMessageMapper} to embed headers
 	 * into the record data.
+	 *
 	 * @since 2.0
+	 *
 	 * @see org.springframework.integration.support.json.EmbeddedJsonHeadersMessageMapper
 	 */
 	public void setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]> embeddedHeadersMapper) {
@@ -205,7 +210,9 @@ public void setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]> embeddedHeade
 
 	/**
 	 * Configure a {@link Duration} how often to call a {@link KinesisProducer#flush()}.
+	 *
 	 * @param flushDuration the {@link Duration} to periodic call of a {@link KinesisProducer#flush()}.
+	 *
 	 * @since 2.3.6
 	 */
 	public void setFlushDuration(Duration flushDuration) {
@@ -215,7 +222,9 @@ public void setFlushDuration(Duration flushDuration) {
 
 	/**
 	 * Unsupported operation. Use {@link #setEmbeddedHeadersMapper} instead.
+	 *
 	 * @param headerMapper is not used.
+	 *
 	 * @see #setEmbeddedHeadersMapper
 	 */
 	@Override
@@ -226,8 +235,11 @@ public void setHeaderMapper(HeaderMapper<Void> headerMapper) {
 
 	/**
 	 * Set a {@link Schema} to add into a {@link UserRecord} built from the request message.
+	 *
 	 * @param glueSchema the {@link Schema} to add into a {@link UserRecord}.
+	 *
 	 * @since 2.5.2
+	 *
 	 * @see UserRecord#setSchema(Schema)
 	 */
 	public void setGlueSchema(Schema glueSchema) {
@@ -237,8 +249,11 @@ public void setGlueSchema(Schema glueSchema) {
 	/**
 	 * Set a SpEL expression for {@link Schema} to add into a {@link UserRecord}
 	 * built from the request message.
+	 *
 	 * @param glueSchemaExpression the SpEL expression to evaluate a {@link Schema}.
+	 *
 	 * @since 2.5.2
+	 *
 	 * @see UserRecord#setSchema(Schema)
 	 */
 	public void setGlueSchemaExpressionString(String glueSchemaExpression) {
@@ -248,8 +263,11 @@ public void setGlueSchemaExpressionString(String glueSchemaExpression) {
 	/**
 	 * Set a SpEL expression for {@link Schema} to add into a {@link UserRecord}
 	 * built from the request message.
+	 *
 	 * @param glueSchemaExpression the SpEL expression to evaluate a {@link Schema}.
+	 *
 	 * @since 2.5.2
+	 *
 	 * @see UserRecord#setSchema(Schema)
 	 */
 	public void setGlueSchemaExpression(Expression glueSchemaExpression) {