@@ -139,9 +139,7 @@ public void setBackPressureThreshold(long backPressureThreshold) {
139
139
140
140
/**
141
141
* Configure a {@link MessageConverter} for converting payload to {@code byte[]} for Kinesis record.
142
- *
143
142
* @param messageConverter the {@link MessageConverter} to use.
144
- *
145
143
* @since 2.3
146
144
*/
147
145
public void setMessageConverter (MessageConverter messageConverter ) {
@@ -196,12 +194,9 @@ public void setSequenceNumberExpression(Expression sequenceNumberExpression) {
196
194
/**
197
195
* Specify a {@link OutboundMessageMapper} for embedding message headers into the
198
196
* record data together with payload.
199
- *
200
197
* @param embeddedHeadersMapper the {@link OutboundMessageMapper} to embed headers
201
198
* into the record data.
202
- *
203
199
* @since 2.0
204
- *
205
200
* @see org.springframework.integration.support.json.EmbeddedJsonHeadersMessageMapper
206
201
*/
207
202
public void setEmbeddedHeadersMapper (OutboundMessageMapper <byte []> embeddedHeadersMapper ) {
@@ -210,9 +205,7 @@ public void setEmbeddedHeadersMapper(OutboundMessageMapper<byte[]> embeddedHeade
210
205
211
206
/**
212
207
* Configure a {@link Duration} how often to call a {@link KinesisProducer#flush()}.
213
- *
214
208
* @param flushDuration the {@link Duration} to periodic call of a {@link KinesisProducer#flush()}.
215
- *
216
209
* @since 2.3.6
217
210
*/
218
211
public void setFlushDuration (Duration flushDuration ) {
@@ -222,9 +215,7 @@ public void setFlushDuration(Duration flushDuration) {
222
215
223
216
/**
224
217
* Unsupported operation. Use {@link #setEmbeddedHeadersMapper} instead.
225
- *
226
218
* @param headerMapper is not used.
227
- *
228
219
* @see #setEmbeddedHeadersMapper
229
220
*/
230
221
@ Override
@@ -235,11 +226,8 @@ public void setHeaderMapper(HeaderMapper<Void> headerMapper) {
235
226
236
227
/**
237
228
* Set a {@link Schema} to add into a {@link UserRecord} built from the request message.
238
- *
239
229
* @param glueSchema the {@link Schema} to add into a {@link UserRecord}.
240
- *
241
230
* @since 2.5.2
242
- *
243
231
* @see UserRecord#setSchema(Schema)
244
232
*/
245
233
public void setGlueSchema (Schema glueSchema ) {
@@ -249,11 +237,8 @@ public void setGlueSchema(Schema glueSchema) {
249
237
/**
250
238
* Set a SpEL expression for {@link Schema} to add into a {@link UserRecord}
251
239
* built from the request message.
252
- *
253
240
* @param glueSchemaExpression the SpEL expression to evaluate a {@link Schema}.
254
- *
255
241
* @since 2.5.2
256
- *
257
242
* @see UserRecord#setSchema(Schema)
258
243
*/
259
244
public void setGlueSchemaExpressionString (String glueSchemaExpression ) {
@@ -263,11 +248,8 @@ public void setGlueSchemaExpressionString(String glueSchemaExpression) {
263
248
/**
264
249
* Set a SpEL expression for {@link Schema} to add into a {@link UserRecord}
265
250
* built from the request message.
266
- *
267
251
* @param glueSchemaExpression the SpEL expression to evaluate a {@link Schema}.
268
- *
269
252
* @since 2.5.2
270
- *
271
253
* @see UserRecord#setSchema(Schema)
272
254
*/
273
255
public void setGlueSchemaExpression (Expression glueSchemaExpression ) {
0 commit comments