File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
src/main/java/org/springframework/integration/aws/outbound Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change 65
65
66
66
/**
67
67
* The {@link AbstractMessageHandler} implementation for the Amazon Kinesis Producer
68
- * Library {@code putRecord(s)}.
69
- *
70
- * @exception KplBackpressureException When backpressure handling is enabled and buffer is at max capacity .
68
+ * Library {@code putRecord(s)}. {@link KplBackpressureException} is thrown When backpressure handling is enabled and
69
+ * buffer is at max capacity. The exceptions can be used with
70
+ * {@link org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice} .
71
71
*
72
72
* @author Arnaud Lecollaire
73
73
* @author Artem Bilan
78
78
* @see KinesisAsyncClient#putRecord(PutRecordRequest)
79
79
* @see KinesisAsyncClient#putRecords(PutRecordsRequest)
80
80
* @see com.amazonaws.handlers.AsyncHandler
81
+ * @see org.springframework.integration.handler.advice.AbstractRequestHandlerAdvice
81
82
*/
82
83
public class KplMessageHandler extends AbstractAwsMessageHandler <Void > implements Lifecycle {
83
84
You can’t perform that action at this time.
0 commit comments