Package | Description |
---|---|
org.springframework.cloud.stream.binder | |
org.springframework.cloud.stream.binding | |
org.springframework.cloud.stream.reflection |
Modifier and Type | Interface and Description |
---|---|
interface |
ExtendedPropertiesBinder<T,C,P>
Extension of
Binder that takes ExtendedConsumerProperties and
ExtendedProducerProperties as arguments. |
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. |
Modifier and Type | Method and Description |
---|---|
<T> Binder<T,?,?> |
DefaultBinderFactory.getBinder(String name,
Class<? extends T> bindingTargetType) |
<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 <T> Binder<T,?,?> |
BindingService.getBinder(String channelName,
Class<T> bindableType) |
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> Binding<T> |
BindingService.doBindProducer(T output,
String bindingTarget,
Binder<T,?,ProducerProperties> binder,
ProducerProperties producerProperties) |
<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) |
<T> void |
BindingService.rescheduleProducerBinding(T output,
String bindingTarget,
Binder<T,?,ProducerProperties> binder,
ProducerProperties producerProperties,
org.springframework.cloud.stream.binding.BindingService.LateBinding<T> late,
RuntimeException exception) |
Modifier and Type | Method and Description |
---|---|
static boolean |
GenericsUtils.checkCompatiblePollableBinder(Binder binderInstance,
Class<?> bindingTargetType)
Return the generic type of PollableSource to determine if it is appropriate
for the binder.
|
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.