import org.springframework.cloud.stream.binder.ExtendedPropertiesBinder; //导入依赖的package包/类
@SuppressWarnings({ "unchecked", "rawtypes" })
public <T> Binding<T> bindProducer(T output, String outputName) {
	String bindingTarget = this.bindingServiceProperties
			.getBindingDestination(outputName);
	Binder<T, ?, ProducerProperties> binder = (Binder<T, ?, ProducerProperties>) getBinder(
			outputName, output.getClass());
	ProducerProperties producerProperties = this.bindingServiceProperties
			.getProducerProperties(outputName);
	if (binder instanceof ExtendedPropertiesBinder) {
		Object extension = ((ExtendedPropertiesBinder) binder)
				.getExtendedProducerProperties(outputName);
		ExtendedProducerProperties extendedProducerProperties = new ExtendedProducerProperties<>(
				extension);
		BeanUtils.copyProperties(producerProperties, extendedProducerProperties);
		producerProperties = extendedProducerProperties;
	}
	validate(producerProperties);
	Binding<T> binding = doBindProducer(output, bindingTarget, binder, producerProperties);
	this.producerBindings.put(outputName, binding);
	return binding;
}
 

import org.springframework.cloud.stream.binder.ExtendedPropertiesBinder; //导入依赖的package包/类
@SuppressWarnings({ "unchecked", "rawtypes" })
public <T> Collection<Binding<T>> bindConsumer(T input, String inputName) {
	String bindingTarget = this.bindingServiceProperties
			.getBindingDestination(inputName);
	String[] bindingTargets = StringUtils
			.commaDelimitedListToStringArray(bindingTarget);
	Collection<Binding<T>> bindings = new ArrayList<>();
	Binder<T, ConsumerProperties, ?> binder = (Binder<T, ConsumerProperties, ?>) getBinder(
			inputName, input.getClass());
	ConsumerProperties consumerProperties = this.bindingServiceProperties
			.getConsumerProperties(inputName);
	if (binder instanceof ExtendedPropertiesBinder) {
		Object extension = ((ExtendedPropertiesBinder) binder)
				.getExtendedConsumerProperties(inputName);
		ExtendedConsumerProperties extendedConsumerProperties = new ExtendedConsumerProperties(
				extension);
		BeanUtils.copyProperties(consumerProperties, extendedConsumerProperties);
		consumerProperties = extendedConsumerProperties;
	}
	validate(consumerProperties);
	for (String target : bindingTargets) {
		Binding<T> binding;
		if (input instanceof PollableSource) {
			binding = doBindPollableConsumer(input, inputName, binder, consumerProperties, target);
		}
		else {
			binding = doBindConsumer(input, inputName, binder, consumerProperties, target);
		}
		bindings.add(binding);
	}
	bindings = Collections.unmodifiableCollection(bindings);
	this.consumerBindings.put(inputName, new ArrayList<Binding<?>>(bindings));
	return bindings;
}
 

import org.springframework.cloud.stream.binder.ExtendedPropertiesBinder; //导入依赖的package包/类
@SuppressWarnings("rawtypes")
public Object getExtendedProducerProperties(Object output, String outputName) {
	Binder binder =  getBinder(outputName, output.getClass());
	if (binder instanceof ExtendedPropertiesBinder) {
		return ((ExtendedPropertiesBinder) binder).getExtendedProducerProperties(outputName);
	}
	else {
		return null;
	}
}