Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

GH-3661: Fix Javadocs for RetryingMLA

Browse Source 
Use of the `RetryingMessageListenerAdapter` was removed in
0550380704
but the javadocs were not corrected.
This commit is contained in:
Gary Russell
2022-09-21 15:59:55 -04:00
committed by Artem Bilan
parent d825adeeda
commit cbfa150dfa
4 changed files with 15 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaInboundGatewaySpec.java
View File

@@ -72,9 +72,7 @@ public class KafkaInboundGatewaySpec<K, V, R, S extends KafkaInboundGatewaySpec<
}
/**
* Specify a {@link RetryTemplate} instance to wrap
* {@code KafkaInboundGateway.IntegrationRecordMessageListener} into
* {@link org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter}.
* Specify a {@link RetryTemplate} instance to use for retrying deliveries.
* @param retryTemplate the {@link RetryTemplate} to use.
* @return the spec
*/

22
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/dsl/KafkaMessageDrivenChannelAdapterSpec.java
View File

@@ -118,9 +118,7 @@ public class KafkaMessageDrivenChannelAdapterSpec<K, V, S extends KafkaMessageDr
}
/**
* Specify a {@link RetryTemplate} instance to wrap
* {@code KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener} into
* {@link org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter}.
* Specify a {@link RetryTemplate} instance to use for retrying deliveries.
* @param retryTemplate the {@link RetryTemplate} to use.
* @return the spec
*/
@@ -153,17 +151,13 @@ public class KafkaMessageDrivenChannelAdapterSpec<K, V, S extends KafkaMessageDr
}
/**
* The {@code boolean} flag to specify the order how
* {@link org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter}
* and
* {@link org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter}
* are wrapped to each other, if both of them are present. Does not make sense if only
* one of {@link RetryTemplate} or {@link RecordFilterStrategy} is present, or any.
* @param filterInRetry the order for
* {@link org.springframework.kafka.listener.adapter.RetryingMessageListenerAdapter}
* and
* {@link org.springframework.kafka.listener.adapter.FilteringMessageListenerAdapter}
* wrapping. Defaults to {@code false}.
* The {@code boolean} flag to specify the order in which the filter and retry
* operations are performed.
* Does not make sense if only one of {@link RetryTemplate} or
* {@link RecordFilterStrategy} is present, or none.
* When true, the filter is called for each retry; when false, the filter is only
* called once for each delivery from the container.
* @param filterInRetry true to filter for each retry. Defaults to {@code false}.
* @return the spec
*/
public S filterInRetry(boolean filterInRetry) {

4
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaInboundGateway.java
View File

@@ -140,9 +140,7 @@ public class KafkaInboundGateway<K, V, R> extends MessagingGatewaySupport
}
/**
* Specify a {@link RetryTemplate} instance to wrap
* {@link KafkaInboundGateway.IntegrationRecordMessageListener} into
* {@code RetryingMessageListenerAdapter}.
* Specify a {@link RetryTemplate} instance to use for retrying deliveries.
* <p>
* IMPORTANT: This form of retry is blocking and could cause a rebalance if the
* aggregate retry delays across all polled records might exceed the

15
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/inbound/KafkaMessageDrivenChannelAdapter.java
View File

@@ -199,9 +199,7 @@ public class KafkaMessageDrivenChannelAdapter<K, V> extends MessageProducerSuppo
}
/**
* Specify a {@link RetryTemplate} instance to wrap
* {@link KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener} into
* {@code RetryingMessageListenerAdapter}.
* Specify a {@link RetryTemplate} instance to use for retrying deliveries.
* <p>
* IMPORTANT: This form of retry is blocking and could cause a rebalance if the
* aggregate retry delays across all polled records might exceed the
@@ -231,16 +229,13 @@ public class KafkaMessageDrivenChannelAdapter<K, V> extends MessageProducerSuppo
}
/**
* The {@code boolean} flag to specify the order how
* {@code RetryingMessageListenerAdapter} and
* {@link FilteringMessageListenerAdapter} are wrapped to each other,
* if both of them are present.
* The {@code boolean} flag to specify the order in which the filter and retry
* operations are performed.
* Does not make sense if only one of {@link RetryTemplate} or
* {@link RecordFilterStrategy} is present, or any.
* {@link RecordFilterStrategy} is present, or none.
* When true, the filter is called for each retry; when false, the filter is only
* called once for each delivery from the container.
* @param filterInRetry the order for {@code RetryingMessageListenerAdapter} and
* {@link FilteringMessageListenerAdapter} wrapping. Defaults to {@code false}.
* @param filterInRetry true to filter for each retry. Defaults to {@code false}.
*/
public void setFilterInRetry(boolean filterInRetry) {
this.filterInRetry = filterInRetry;