org.springframework.cloud.stream.binder

Class AbstractBinder<T,C extends ConsumerProperties,P extends ProducerProperties>

java.lang.Object

org.springframework.cloud.stream.binder.AbstractBinder<T,C,P>

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, Binder<T,C,P>, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

AbstractMessageChannelBinder

public abstract class AbstractBinder<T,C extends ConsumerProperties,P extends ProducerProperties>
extends Object
implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.InitializingBean, Binder<T,C,P>

Base class for Binder implementations.

Author:

David Turanski, Gary Russell, Ilayaperumal Gopinathan, Mark Fisher, Marius Bogoevici

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractBinder.JavaClassMimeTypeConversion Handles representing any java class as a MimeType.

Field Summary

Fields

Modifier and Type	Field and Description
protected StringConvertingContentTypeResolver	contentTypeResolver
protected org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor and Description
AbstractBinder()

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
static String	applyPrefix(String prefix, String name) For binder implementations that support a prefix, apply the prefix to the name.
Binding<T>	bindConsumer(String name, String group, T target, C properties) Bind the target component as a message consumer to the logical entity identified by the name.
Binding<T>	bindProducer(String name, T outboundBindTarget, P properties) Bind the target component as a message producer to the logical entity identified by the name.
protected String	buildPartitionRoutingExpression(String expressionRoot)
org.springframework.retry.support.RetryTemplate	buildRetryTemplate(ConsumerProperties properties) Create and configure a retry template.
static String	constructDLQName(String name) For binder implementations that support dead lettering, construct the name of the dead letter entity for the underlying pipe name.
protected MessageValues	deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message)
protected MessageValues	deserializePayloadIfNecessary(MessageValues messageValues)
protected abstract Binding<T>	doBindConsumer(String name, String group, T inputTarget, C properties)
protected abstract Binding<T>	doBindProducer(String name, T outboundBindTarget, P properties)
protected org.springframework.context.support.AbstractApplicationContext	getApplicationContext()
protected org.springframework.beans.factory.config.ConfigurableListableBeanFactory	getBeanFactory()
protected String	groupedName(String name, String group) Construct a name comprised of the name and group.
protected void	onInit() Subclasses may implement this method to perform any necessary initialization.
protected MessageValues	serializePayloadIfNecessary(org.springframework.messaging.Message<?> message)
protected byte[]	serializePayloadIfNecessary(Object originalPayload)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setCodec(org.springframework.integration.codec.Codec codec)
void	setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.apache.commons.logging.Log logger

contentTypeResolver

protected final StringConvertingContentTypeResolver contentTypeResolver

Constructor Detail

AbstractBinder

public AbstractBinder()

Method Detail

applyPrefix

public static String applyPrefix(String prefix,
                                 String name)

For binder implementations that support a prefix, apply the prefix to the name.

Parameters:

prefix - the prefix.

name - the name.

constructDLQName

public static String constructDLQName(String name)

For binder implementations that support dead lettering, construct the name of the dead letter entity for the underlying pipe name.

Parameters:

name - the name.

getApplicationContext

protected org.springframework.context.support.AbstractApplicationContext getApplicationContext()

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

getBeanFactory

protected org.springframework.beans.factory.config.ConfigurableListableBeanFactory getBeanFactory()

setCodec

public void setCodec(org.springframework.integration.codec.Codec codec)

setIntegrationEvaluationContext

public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext evaluationContext)

afterPropertiesSet

public final void afterPropertiesSet()
                              throws Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

Exception

onInit

protected void onInit()
               throws Exception

Subclasses may implement this method to perform any necessary initialization. It will be invoked from afterPropertiesSet() which is itself final.

Throws:

Exception

bindConsumer

public final Binding<T> bindConsumer(String name,
                                     String group,
                                     T target,
                                     C properties)

Description copied from interface: Binder

Bind the target component as a message consumer to the logical entity identified by the name.

Specified by:

bindConsumer in interface Binder<T,C extends ConsumerProperties,P extends ProducerProperties>

Parameters:

name - the logical identity of the message source

group - the consumer group to which this consumer belongs - subscriptions are shared among consumers in the same group (a null or empty String, must be treated as an anonymous group that doesn't share the subscription with any other consumer)

target - the app interface to be bound as a consumer

properties - the consumer properties

doBindConsumer

protected abstract Binding<T> doBindConsumer(String name,
                                             String group,
                                             T inputTarget,
                                             C properties)

bindProducer

public final Binding<T> bindProducer(String name,
                                     T outboundBindTarget,
                                     P properties)

Description copied from interface: Binder

Bind the target component as a message producer to the logical entity identified by the name.

Specified by:

bindProducer in interface Binder<T,C extends ConsumerProperties,P extends ProducerProperties>

Parameters:

name - the logical identity of the message target

outboundBindTarget - the app interface to be bound as a producer

properties - the producer properties

doBindProducer

protected abstract Binding<T> doBindProducer(String name,
                                             T outboundBindTarget,
                                             P properties)

groupedName

protected final String groupedName(String name,
                                   String group)

Construct a name comprised of the name and group.

Parameters:

name - the name.

group - the group.

Returns:

the constructed name.

serializePayloadIfNecessary

protected final MessageValues serializePayloadIfNecessary(org.springframework.messaging.Message<?> message)

serializePayloadIfNecessary

protected final byte[] serializePayloadIfNecessary(Object originalPayload)

deserializePayloadIfNecessary

protected final MessageValues deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message)

deserializePayloadIfNecessary

protected final MessageValues deserializePayloadIfNecessary(MessageValues messageValues)

buildPartitionRoutingExpression

protected String buildPartitionRoutingExpression(String expressionRoot)

buildRetryTemplate

public org.springframework.retry.support.RetryTemplate buildRetryTemplate(ConsumerProperties properties)

Create and configure a retry template.

Parameters:

properties - The properties.

Returns:

The retry template