From b67fa489cbc0a18b86cf58a064f2b08602748123 Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Thu, 22 Oct 2015 17:50:01 -0400 Subject: [PATCH] Adding a deprecated setter for KafkaProducerMessageHandler.setPartitionExpression() for backwards compatibility --- .../kafka/outbound/KafkaProducerMessageHandler.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java index e861fe389e..e9f9b0e6c9 100644 --- a/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java +++ b/spring-integration-kafka/src/main/java/org/springframework/integration/kafka/outbound/KafkaProducerMessageHandler.java @@ -57,6 +57,14 @@ public class KafkaProducerMessageHandler extends AbstractMessageHandler { this.messageKeyExpression = messageKeyExpression; } + /** + * @deprecated as of 1.3, {@link #setPartitionIdExpression(Expression)} should be used instead + */ + @Deprecated + public void setPartitionExpression(Expression partitionExpression) { + setPartitionIdExpression(partitionExpression); + } + public void setPartitionIdExpression(Expression partitionIdExpression) { this.partitionIdExpression = partitionIdExpression; }