KPMH - Remove unused parameter
This commit is contained in:
@@ -534,8 +534,7 @@ public class KafkaProducerMessageHandler<K, V> extends AbstractReplyProducingMes
|
||||
return processReplyFuture(gatewayFuture);
|
||||
}
|
||||
|
||||
private void sendFutureIfRequested(final Message<?> message, ListenableFuture<SendResult<K, V>> sendFuture,
|
||||
Object futureToken) {
|
||||
private void sendFutureIfRequested(ListenableFuture<SendResult<K, V>> sendFuture, Object futureToken) {
|
||||
|
||||
if (futureToken != null) {
|
||||
MessageChannel futures = getFuturesChannel();
|
||||
|
||||
@@ -874,7 +874,8 @@ public class FuturesChannelApplication {
|
||||
|
||||
@Bean
|
||||
IntegrationFlow inbound(ConsumerFactory<String, String> consumerFactory, Handler handler) {
|
||||
return IntegrationFlows.from(Kafka.messageDrivenChannelAdapter(consumerFactory, ListenerMode.batch, "inTopic"))
|
||||
return IntegrationFlows.from(Kafka.messageDrivenChannelAdapter(consumerFactory,
|
||||
ListenerMode.batch, "inTopic"))
|
||||
.handle(handler)
|
||||
.get();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user