Modifier and Type | Method and Description |
---|---|
protected void |
AbstractMessageChannelBinder.afterUnbindProducer(ProducerDestination destination,
P producerProperties)
Invoked after the unbinding of a producer.
|
protected abstract org.springframework.messaging.MessageHandler |
AbstractMessageChannelBinder.createProducerMessageHandler(ProducerDestination destination,
P producerProperties,
org.springframework.messaging.MessageChannel errorChannel)
Creates a
MessageHandler with the ability to send data to the target
middleware. |
protected String |
AbstractMessageChannelBinder.errorsBaseName(ProducerDestination destination) |
protected String |
AbstractMessageChannelBinder.getErrorBridgeName(ProducerDestination destination) |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
ProducerDestination |
ProvisioningProvider.provisionProducerDestination(String name,
P properties)
Creates middleware destination on the physical broker for the producer to send
data.
|
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.