Skip to content

Commit 074f991

Browse files
committed
GH-1700: Reduce Method Complexity
1 parent bdd9ee8 commit 074f991

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -221,6 +221,16 @@ public void accept(ConsumerRecord<?, ?> record, @Nullable Consumer<?, ?> consume
221221
ProducerRecord<Object, Object> outRecord = createProducerRecord(record, tp, headers,
222222
kDeserEx == null ? null : kDeserEx.getData(), vDeserEx == null ? null : vDeserEx.getData());
223223
KafkaOperations<Object, Object> kafkaTemplate = findTemplateForValue(outRecord.value());
224+
send(outRecord, kafkaTemplate);
225+
}
226+
227+
/**
228+
* Send the record.
229+
* @param outRecord the record.
230+
* @param kafkaTemplate the template.
231+
* @since 2.7
232+
*/
233+
protected void send(ProducerRecord<Object, Object> outRecord, KafkaOperations<Object, Object> kafkaTemplate) {
224234
if (this.transactional && !kafkaTemplate.inTransaction() && !kafkaTemplate.isAllowNonTransactional()) {
225235
kafkaTemplate.executeInTransaction(t -> {
226236
publish(outRecord, t);

0 commit comments

Comments
 (0)