| Modifier and Type | Method and Description |
|---|---|
protected void |
AbstractMessageChannelBinder.afterUnbindConsumer(ConsumerDestination destination,
String group,
C consumerProperties)
Invoked after the unbinding of a consumer.
|
protected abstract org.springframework.integration.core.MessageProducer |
AbstractMessageChannelBinder.createConsumerEndpoint(ConsumerDestination destination,
String group,
C properties)
Creates
MessageProducer that receives data from the consumer destination. |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.integration.core.MessageProducer |
KafkaMessageChannelBinder.createConsumerEndpoint(ConsumerDestination destination,
String group,
ExtendedConsumerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaConsumerProperties> extendedConsumerProperties) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
RabbitMessageChannelBinder.afterUnbindConsumer(ConsumerDestination consumerDestination,
String group,
ExtendedConsumerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitConsumerProperties> consumerProperties) |
protected org.springframework.integration.core.MessageProducer |
RabbitMessageChannelBinder.createConsumerEndpoint(ConsumerDestination consumerDestination,
String group,
ExtendedConsumerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitConsumerProperties> properties) |
| Modifier and Type | Method and Description |
|---|---|
ConsumerDestination |
ProvisioningProvider.provisionConsumerDestination(String name,
String group,
C properties)
Creates the middleware destination on the physical broker for the consumer to
consume data.
|
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.