Package | Description |
---|---|
org.springframework.cloud.stream.binder.kafka | |
org.springframework.cloud.stream.binder.rabbit |
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) |
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.