org.springframework.cloud.stream.binder.rocketmq

Class RocketMQMessageChannelBinder

java.lang.Object

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

org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>,RocketMQTopicProvisioner>

org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.cloud.stream.binder.Binder<org.springframework.messaging.MessageChannel,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>>, org.springframework.cloud.stream.binder.ExtendedBindingProperties<RocketMQConsumerProperties,RocketMQProducerProperties>, org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,RocketMQConsumerProperties,RocketMQProducerProperties>, org.springframework.cloud.stream.binder.PollableConsumerBinder<org.springframework.messaging.MessageHandler,org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>>, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationEventPublisherAware

public class RocketMQMessageChannelBinder
extends org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>,RocketMQTopicProvisioner>
implements org.springframework.cloud.stream.binder.ExtendedPropertiesBinder<org.springframework.messaging.MessageChannel,RocketMQConsumerProperties,RocketMQProducerProperties>

Author:

Timur Valiev, Jim

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.ErrorInfrastructure, org.springframework.cloud.stream.binder.AbstractMessageChannelBinder.PolledConsumerResources

Field Summary

Fields inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

provisioningProvider

Constructor Summary

Constructors

Constructor and Description
RocketMQMessageChannelBinder(ConsumersManager consumersManager, RocketMQExtendedBindingProperties extendedBindingProperties, RocketMQTopicProvisioner provisioningProvider, RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties, InstrumentationManager instrumentationManager)

Method Summary

Modifier and Type	Method and Description
protected org.springframework.integration.core.MessageProducer	createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination, String group, org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties)
protected org.springframework.messaging.MessageHandler	createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination, org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties> producerProperties, org.springframework.messaging.MessageChannel errorChannel)
RocketMQConsumerProperties	getExtendedConsumerProperties(String channelName)
RocketMQProducerProperties	getExtendedProducerProperties(String channelName)

Methods inherited from class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

afterUnbindConsumer, afterUnbindProducer, bindPollableConsumer, createPolledConsumerResources, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getApplicationEventPublisher, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandler, getErrorMessageHandlerName, getErrorMessageStrategy, getErrorRecovererName, getPolledConsumerErrorMessageHandler, getPolledConsumerRecoveryCallback, postProcessOutputChannel, postProcessPollableSource, registerErrorInfrastructure, registerErrorInfrastructure, setApplicationEventPublisher

Methods inherited from class org.springframework.cloud.stream.binder.AbstractBinder

afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildPartitionRoutingExpression, buildRetryTemplate, constructDLQName, getApplicationContext, getBeanFactory, getEvaluationContext, groupedName, onInit, serializePayloadIfNecessary, setApplicationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.cloud.stream.binder.Binder

bindConsumer, bindProducer

Constructor Detail

RocketMQMessageChannelBinder

public RocketMQMessageChannelBinder(ConsumersManager consumersManager,
                                    RocketMQExtendedBindingProperties extendedBindingProperties,
                                    RocketMQTopicProvisioner provisioningProvider,
                                    RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
                                    InstrumentationManager instrumentationManager)

Method Detail

createProducerMessageHandler

protected org.springframework.messaging.MessageHandler createProducerMessageHandler(org.springframework.cloud.stream.provisioning.ProducerDestination destination,
                                                                                    org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties> producerProperties,
                                                                                    org.springframework.messaging.MessageChannel errorChannel)
                                                                             throws Exception

Specified by:

createProducerMessageHandler in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>,RocketMQTopicProvisioner>

Throws:

Exception

createConsumerEndpoint

protected org.springframework.integration.core.MessageProducer createConsumerEndpoint(org.springframework.cloud.stream.provisioning.ConsumerDestination destination,
                                                                                      String group,
                                                                                      org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties)
                                                                               throws Exception

Specified by:

createConsumerEndpoint in class org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>,RocketMQTopicProvisioner>

Throws:

Exception

getExtendedConsumerProperties

public RocketMQConsumerProperties getExtendedConsumerProperties(String channelName)

Specified by:

getExtendedConsumerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<RocketMQConsumerProperties,RocketMQProducerProperties>

getExtendedProducerProperties

public RocketMQProducerProperties getExtendedProducerProperties(String channelName)

Specified by:

getExtendedProducerProperties in interface org.springframework.cloud.stream.binder.ExtendedBindingProperties<RocketMQConsumerProperties,RocketMQProducerProperties>