Uses of Interface
org.springframework.cloud.stream.provisioning.ConsumerDestination

Packages that use ConsumerDestination

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

Uses of ConsumerDestination in org.springframework.cloud.stream.binder

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

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.
protected AbstractMessageChannelBinder.PolledConsumerResources	AbstractMessageChannelBinder.createPolledConsumerResources(String name, String group, ConsumerDestination destination, C consumerProperties)
protected String	AbstractMessageChannelBinder.errorsBaseName(ConsumerDestination destination, String group, C consumerProperties)
protected String	AbstractMessageChannelBinder.getErrorBridgeName(ConsumerDestination destination, String group, C consumerProperties)
protected org.springframework.messaging.MessageHandler	AbstractMessageChannelBinder.getErrorMessageHandler(ConsumerDestination destination, String group, C consumerProperties) Binders can return a message handler to be subscribed to the error channel.
protected String	AbstractMessageChannelBinder.getErrorMessageHandlerName(ConsumerDestination destination, String group, C consumerProperties)
protected String	AbstractMessageChannelBinder.getErrorRecovererName(ConsumerDestination destination, String group, C consumerProperties)
protected org.springframework.messaging.MessageHandler	AbstractMessageChannelBinder.getPolledConsumerErrorMessageHandler(ConsumerDestination destination, String group, C consumerProperties) Binders can return a message handler to be subscribed to the error channel.
protected AbstractMessageChannelBinder.ErrorInfrastructure	AbstractMessageChannelBinder.registerErrorInfrastructure(ConsumerDestination destination, String group, C consumerProperties) Build an errorChannelRecoverer that writes to a pub/sub channel for the destination when an exception is thrown to a consumer.
protected AbstractMessageChannelBinder.ErrorInfrastructure	AbstractMessageChannelBinder.registerErrorInfrastructure(ConsumerDestination destination, String group, C consumerProperties, boolean polled) Build an errorChannelRecoverer that writes to a pub/sub channel for the destination when an exception is thrown to a consumer.

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

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

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 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 ConsumerDestination in org.springframework.cloud.stream.binder.rabbit

Methods in org.springframework.cloud.stream.binder.rabbit with parameters of type ConsumerDestination

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)

Uses of ConsumerDestination in org.springframework.cloud.stream.provisioning

Methods in org.springframework.cloud.stream.provisioning that return ConsumerDestination

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.