public class RedisMessageChannelBinder extends MessageChannelBinderSupport implements org.springframework.beans.factory.DisposableBean
Binder
implementation backed by Redis.MessageChannelBinderSupport.DirectHandler, MessageChannelBinderSupport.PartitioningMetadata, MessageChannelBinderSupport.SetBuilder, MessageChannelBinderSupport.SharedChannelProvider<T extends org.springframework.messaging.MessageChannel>
CONSUMER_RETRY_PROPERTIES, CONSUMER_STANDARD_PROPERTIES, defaultBackOffInitialInterval, defaultBackOffMaxInterval, defaultBackOffMultiplier, defaultBatchBufferLimit, defaultBatchingEnabled, defaultBatchSize, defaultBatchTimeout, defaultCompress, defaultConcurrency, defaultDurableSubscription, defaultMaxAttempts, directChannelProvider, evaluationContext, logger, MEDIATYPES_MEDIATYPE_ALL, PARTITION_HEADER, PRODUCER_BATCHING_ADVANCED_PROPERTIES, PRODUCER_BATCHING_BASIC_PROPERTIES, PRODUCER_PARTITIONING_PROPERTIES, PRODUCER_STANDARD_PROPERTIES
Constructor and Description |
---|
RedisMessageChannelBinder(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory) |
RedisMessageChannelBinder(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
String... headersToMap) |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
protected void |
afterUnbind(Binding<org.springframework.messaging.MessageChannel> binding) |
Binding<org.springframework.messaging.MessageChannel> |
bindProducer(String name,
org.springframework.messaging.MessageChannel moduleOutputChannel,
Properties properties) |
void |
destroy() |
protected Binding<org.springframework.messaging.MessageChannel> |
doBindConsumer(String name,
String group,
org.springframework.messaging.MessageChannel moduleInputChannel,
Properties properties) |
addBinding, applyPrefix, bindConsumer, buildPartitionRoutingExpression, buildRetryTemplateIfRetryEnabled, constructDLQName, deserializePayloadIfNecessary, deserializePayloadIfNecessary, determinePartition, doBindDynamicProducer, doManualAck, getApplicationContext, getBeanFactory, getIdGenerator, groupedName, serializePayloadIfNecessary, setApplicationContext, setCodec, setDefaultBackOffInitialInterval, setDefaultBackOffMaxInterval, setDefaultBackOffMultiplier, setDefaultBatchBufferLimit, setDefaultBatchingEnabled, setDefaultBatchSize, setDefaultBatchTimeout, setDefaultCompress, setDefaultConcurrency, setDefaultDurableSubscription, setDefaultMaxAttempts, setIntegrationEvaluationContext, setPartitionSelector, stopBindings, unbind, validateConsumerProperties, validateProducerProperties
public RedisMessageChannelBinder(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)
public RedisMessageChannelBinder(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, String... headersToMap)
public void afterPropertiesSet() throws Exception
afterPropertiesSet
in interface org.springframework.beans.factory.InitializingBean
afterPropertiesSet
in class MessageChannelBinderSupport
Exception
protected Binding<org.springframework.messaging.MessageChannel> doBindConsumer(String name, String group, org.springframework.messaging.MessageChannel moduleInputChannel, Properties properties)
doBindConsumer
in class MessageChannelBinderSupport
protected void afterUnbind(Binding<org.springframework.messaging.MessageChannel> binding)
afterUnbind
in class MessageChannelBinderSupport
public Binding<org.springframework.messaging.MessageChannel> bindProducer(String name, org.springframework.messaging.MessageChannel moduleOutputChannel, Properties properties)
bindProducer
in interface Binder<org.springframework.messaging.MessageChannel>
public void destroy()
destroy
in interface org.springframework.beans.factory.DisposableBean
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.