Uses of Class
org.springframework.cloud.stream.binder.ExtendedConsumerProperties

Packages that use ExtendedConsumerProperties

Package	Description
org.springframework.cloud.stream.binder.kafka
org.springframework.cloud.stream.binder.rabbit

Uses of ExtendedConsumerProperties in org.springframework.cloud.stream.binder.kafka

Methods in org.springframework.cloud.stream.binder.kafka with parameters of type ExtendedConsumerProperties

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)
protected org.springframework.kafka.core.ConsumerFactory<?,?>	KafkaMessageChannelBinder.createKafkaConsumerFactory(boolean anonymous, String consumerGroup, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaConsumerProperties> consumerProperties)
protected AbstractMessageChannelBinder.PolledConsumerResources	KafkaMessageChannelBinder.createPolledConsumerResources(String name, String group, ConsumerDestination destination, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaConsumerProperties> consumerProperties)
protected org.springframework.messaging.MessageHandler	KafkaMessageChannelBinder.getErrorMessageHandler(ConsumerDestination destination, String group, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaConsumerProperties> properties)
protected org.springframework.messaging.MessageHandler	KafkaMessageChannelBinder.getPolledConsumerErrorMessageHandler(ConsumerDestination destination, String group, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.kafka.properties.KafkaConsumerProperties> properties)

Uses of ExtendedConsumerProperties in org.springframework.cloud.stream.binder.rabbit

Methods in org.springframework.cloud.stream.binder.rabbit with parameters of type 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)
protected AbstractMessageChannelBinder.PolledConsumerResources	RabbitMessageChannelBinder.createPolledConsumerResources(String name, String group, ConsumerDestination destination, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitConsumerProperties> consumerProperties)
protected String	RabbitMessageChannelBinder.errorsBaseName(ConsumerDestination destination, String group, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitConsumerProperties> consumerProperties)
protected org.springframework.messaging.MessageHandler	RabbitMessageChannelBinder.getErrorMessageHandler(ConsumerDestination destination, String group, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitConsumerProperties> properties)
protected org.springframework.messaging.MessageHandler	RabbitMessageChannelBinder.getPolledConsumerErrorMessageHandler(ConsumerDestination destination, String group, ExtendedConsumerProperties<org.springframework.cloud.stream.binder.rabbit.properties.RabbitConsumerProperties> properties)