Modifier and Type | Class and Description |
---|---|
class |
AbstractBinder<T,C extends ConsumerProperties,P extends ProducerProperties>
Base class for
Binder implementations. |
class |
AbstractMessageChannelBinder<C extends ConsumerProperties,P extends ProducerProperties,PP extends ProvisioningProvider<C,P>>
AbstractBinder that serves as base class for MessageChannel binders. |
interface |
Binder<T,C extends ConsumerProperties,P extends ProducerProperties>
A strategy interface used to bind an app interface to a logical name.
|
interface |
PollableConsumerBinder<H,C extends ConsumerProperties>
A binder that supports pollable message sources.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtendedConsumerProperties<T>
Extension of
ConsumerProperties to be used with an
ExtendedPropertiesBinder . |
Modifier and Type | Method and Description |
---|---|
<T> Binder<T,? extends ConsumerProperties,? extends ProducerProperties> |
BinderFactory.getBinder(String configurationName,
Class<? extends T> bindableType)
Returns the binder instance associated with the given configuration name.
|
Modifier and Type | Method and Description |
---|---|
protected org.springframework.retry.support.RetryTemplate |
AbstractBinder.buildRetryTemplate(ConsumerProperties properties)
Create and configure a default retry template unless one
has already been provided via @Bean by an application.
|
Modifier and Type | Method and Description |
---|---|
<T> Binding<T> |
BindingService.doBindConsumer(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target) |
<T> Binding<T> |
BindingService.doBindPollableConsumer(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target) |
<T> void |
BindingService.rescheduleConsumerBinding(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target,
org.springframework.cloud.stream.binding.BindingService.LateBinding<T> late,
RuntimeException exception) |
<T> void |
BindingService.reschedulePollableConsumerBinding(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target,
org.springframework.cloud.stream.binding.BindingService.LateBinding<T> late,
RuntimeException exception) |
Modifier and Type | Method and Description |
---|---|
<T> Binding<T> |
BindingService.doBindConsumer(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target) |
<T> Binding<T> |
BindingService.doBindPollableConsumer(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target) |
<T> void |
BindingService.rescheduleConsumerBinding(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target,
org.springframework.cloud.stream.binding.BindingService.LateBinding<T> late,
RuntimeException exception) |
<T> void |
BindingService.reschedulePollableConsumerBinding(T input,
String inputName,
Binder<T,ConsumerProperties,?> binder,
ConsumerProperties consumerProperties,
String target,
org.springframework.cloud.stream.binding.BindingService.LateBinding<T> late,
RuntimeException exception) |
Modifier and Type | Method and Description |
---|---|
ConsumerProperties |
BindingProperties.getConsumer() |
ConsumerProperties |
BindingServiceProperties.getConsumerProperties(String inputBindingName) |
Modifier and Type | Method and Description |
---|---|
void |
BindingProperties.setConsumer(ConsumerProperties consumer) |
Modifier and Type | Interface and Description |
---|---|
interface |
ProvisioningProvider<C extends ConsumerProperties,P extends ProducerProperties>
Provisioning SPI that allows the users to provision destinations such as queues and
topics.
|
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.