Skip to content

Commit 4d4fcf8

Browse files
GH-249 Javadoc corrections.
1 parent 33657f7 commit 4d4fcf8

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/org/springframework/integration/aws/outbound/KplMessageHandler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -121,13 +121,13 @@ public void setConverter(Converter<Object, byte[]> converter) {
121121

122122
/**
123123
* Configure maximum records in flight for handling backpressure. By Default, backpressure handling is not enabled.
124-
* On number of records flights exceeding the threshold, {@link KPLBackpressureException} would be thrown.
124+
* On number of records in flight exceeding the threshold, {@link KPLBackpressureException} would be thrown.
125125
* If Backpressure handling is enabled, {@link KPLBackpressureException} must be handled.
126126
* @param backPressureThreshold Defaulted to 0. Set a value greater than 0 to enable backpressure handling.
127127
* @since 3.0.9
128128
*/
129129
public void setBackPressureThreshold(long backPressureThreshold) {
130-
Assert.isTrue(backPressureThreshold > 0, "'maxInFlightRecords must be greater than 0.");
130+
Assert.isTrue(backPressureThreshold > 0, "'backPressureThreshold must be greater than 0.");
131131
this.backPressureThreshold = backPressureThreshold;
132132
}
133133

0 commit comments

Comments
 (0)