GH-1700: Reduce Method Complexity

spring-projects · Feb 11, 2021 · 074f991 · 074f991
1 parent bdd9ee8
commit 074f991
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java b/...kafka/src/main/java/org/springframework/kafka/listener/DeadLetterPublishingRecoverer.java
@@ -221,6 +221,16 @@ public void accept(ConsumerRecord<?, ?> record, @Nullable Consumer<?, ?> consume
 		ProducerRecord<Object, Object> outRecord = createProducerRecord(record, tp, headers,
 				kDeserEx == null ? null : kDeserEx.getData(), vDeserEx == null ? null : vDeserEx.getData());
 		KafkaOperations<Object, Object> kafkaTemplate = findTemplateForValue(outRecord.value());
+		send(outRecord, kafkaTemplate);
+	}
+
+	/**
+	 * Send the record.
+	 * @param outRecord the record.
+	 * @param kafkaTemplate the template.
+	 * @since 2.7
+	 */
+	protected void send(ProducerRecord<Object, Object> outRecord, KafkaOperations<Object, Object> kafkaTemplate) {
 		if (this.transactional && !kafkaTemplate.inTransaction() && !kafkaTemplate.isAllowNonTransactional()) {
 			kafkaTemplate.executeInTransaction(t -> {
 				publish(outRecord, t);