Class BindingService

java.lang.Object

org.springframework.cloud.stream.binding.BindingService

public class BindingService
extends Object

Handles binding of input/output targets by delegating to an underlying Binder.

Author:

Mark Fisher, Dave Syer, Marius Bogoevici, Ilayaperumal Gopinathan, Gary Russell, Janne Valkealahti, Soby Chacko, Michael Michailidis, Chris Bono, Artem Bilan, Byungjun You, Omer Celik

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BindingService.LateBinding<T>

Constructor Summary

Constructors

Constructor	Description
BindingService(BindingServiceProperties bindingServiceProperties, BinderFactory binderFactory, org.springframework.scheduling.TaskScheduler taskScheduler, tools.jackson.databind.ObjectMapper objectMapper)
BindingService(BindingServiceProperties bindingServiceProperties, BinderFactory binderFactory, tools.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
<T> Collection<Binding<T>>	bindConsumer(T input, String inputName)
<T> Binding<T>	bindProducer(T output, boolean cache, BinderWrapper binderWrapper)
<T> Binding<T>	bindProducer(T output, String outputName)
<T> Binding<T>	bindProducer(T output, String outputName, boolean cache)
BinderWrapper	createBinderWrapper(String binderName, String destinationName, Class<?> outputClass)
<T> Binding<T>	doBindConsumer(T input, String inputName, Binder<T, ConsumerProperties, ?> binder, ConsumerProperties consumerProperties, String target)
<T> Binding<T>	doBindPollableConsumer(T input, String inputName, Binder<T, ConsumerProperties, ?> binder, ConsumerProperties consumerProperties, String target)
<T> Binding<T>	doBindProducer(T output, String bindingTarget, Binder<T, ?, ProducerProperties> binder, ProducerProperties producerProperties)
protected <T> Binder<T,?,?>	getBinder(String channelName, Class<T> bindableType)
BindingServiceProperties	getBindingServiceProperties()
String[]	getConsumerBindingNames()
List<Binding<?>>	getConsumerBindings(String bindingName)
Object	getExtendedProducerProperties(Binder binder, String outputName)
Binding<?>	getProducerBinding(String bindingName)
String[]	getProducerBindingNames()
<T> void	rescheduleConsumerBinding(T input, String inputName, Binder<T, ConsumerProperties, ?> binder, ConsumerProperties consumerProperties, String target, BindingService.LateBinding<T> late, RuntimeException exception)
<T> void	reschedulePollableConsumerBinding(T input, String inputName, Binder<T, ConsumerProperties, ?> binder, ConsumerProperties consumerProperties, String target, BindingService.LateBinding<T> late, RuntimeException exception)
<T> void	rescheduleProducerBinding(T output, String bindingTarget, Binder<T, ?, ProducerProperties> binder, ProducerProperties producerProperties, BindingService.LateBinding<T> late, RuntimeException exception)
void	unbindConsumers(String inputName)
void	unbindProducers(String cacheKey)
void	unbindProducers(String binderName, String outputName)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BindingService

public BindingService(BindingServiceProperties bindingServiceProperties,
 BinderFactory binderFactory,
 tools.jackson.databind.ObjectMapper objectMapper)

BindingService

public BindingService(BindingServiceProperties bindingServiceProperties,
 BinderFactory binderFactory,
 org.springframework.scheduling.TaskScheduler taskScheduler,
 tools.jackson.databind.ObjectMapper objectMapper)

Method Details

bindConsumer

public <T> Collection<Binding<T>> bindConsumer(T input,
 String inputName)

doBindConsumer

public <T> Binding<T> doBindConsumer(T input,
 String inputName,
 Binder<T, ConsumerProperties, ?> binder,
 ConsumerProperties consumerProperties,
 String target)

rescheduleConsumerBinding

public <T> void rescheduleConsumerBinding(T input,
 String inputName,
 Binder<T, ConsumerProperties, ?> binder,
 ConsumerProperties consumerProperties,
 String target,
 BindingService.LateBinding<T> late,
 RuntimeException exception)

doBindPollableConsumer

public <T> Binding<T> doBindPollableConsumer(T input,
 String inputName,
 Binder<T, ConsumerProperties, ?> binder,
 ConsumerProperties consumerProperties,
 String target)

reschedulePollableConsumerBinding

public <T> void reschedulePollableConsumerBinding(T input,
 String inputName,
 Binder<T, ConsumerProperties, ?> binder,
 ConsumerProperties consumerProperties,
 String target,
 BindingService.LateBinding<T> late,
 RuntimeException exception)

bindProducer

public <T> Binding<T> bindProducer(T output,
 boolean cache,
 BinderWrapper binderWrapper)

bindProducer

public <T> Binding<T> bindProducer(T output,
 String outputName,
 boolean cache)

bindProducer

public <T> Binding<T> bindProducer(T output,
 String outputName)

getExtendedProducerProperties

public Object getExtendedProducerProperties(Binder binder,
 String outputName)

getProducerBindingNames

public String[] getProducerBindingNames()

getProducerBinding

@Nullable
public Binding<?> getProducerBinding(String bindingName)

getConsumerBindingNames

public String[] getConsumerBindingNames()

getConsumerBindings

public List<Binding<?>> getConsumerBindings(String bindingName)

doBindProducer

public <T> Binding<T> doBindProducer(T output,
 String bindingTarget,
 Binder<T, ?, ProducerProperties> binder,
 ProducerProperties producerProperties)

rescheduleProducerBinding

public <T> void rescheduleProducerBinding(T output,
 String bindingTarget,
 Binder<T, ?, ProducerProperties> binder,
 ProducerProperties producerProperties,
 BindingService.LateBinding<T> late,
 RuntimeException exception)

unbindConsumers

public void unbindConsumers(String inputName)

unbindProducers

public void unbindProducers(@Nullable
 String binderName,
 String outputName)

unbindProducers

public void unbindProducers(String cacheKey)

getBindingServiceProperties

public BindingServiceProperties getBindingServiceProperties()

getBinder

protected <T> Binder<T,?,?> getBinder(String channelName,
 Class<T> bindableType)

createBinderWrapper

public BinderWrapper createBinderWrapper(@Nullable
 String binderName,
 String destinationName,
 Class<?> outputClass)