Package | Description |
---|---|
org.springframework.cloud.stream.binder.kafka | |
org.springframework.cloud.stream.binder.rabbit |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.messaging.MessageHandler |
KafkaMessageChannelBinder.createProducerMessageHandler(ProducerDestination destination,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel errorChannel) |
protected org.springframework.kafka.core.DefaultKafkaProducerFactory<byte[],byte[]> |
KafkaMessageChannelBinder.getProducerFactory(String transactionIdPrefix,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaProducerProperties> producerProperties) |
Modifier and Type | Method and Description |
---|---|
protected org.springframework.messaging.MessageHandler |
RabbitMessageChannelBinder.createProducerMessageHandler(ProducerDestination producerDestination,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitProducerProperties> producerProperties,
org.springframework.messaging.MessageChannel errorChannel) |
protected void |
RabbitMessageChannelBinder.postProcessOutputChannel(org.springframework.messaging.MessageChannel outputChannel,
ExtendedProducerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitProducerProperties> producerProperties) |
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.