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:

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

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

logger

Constructor Summary

Constructors

Constructor and Description
RocketMQMessageChannelBinder(RocketMQTopicProvisioner provisioningProvider, RocketMQExtendedBindingProperties extendedBindingProperties, RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties, org.apache.rocketmq.spring.autoconfigure.RocketMQProperties rocketMQProperties, 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)
String	getDefaultsPrefix()
RocketMQConsumerProperties	getExtendedConsumerProperties(String channelName)
RocketMQProducerProperties	getExtendedProducerProperties(String channelName)
Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider>	getExtendedPropertiesEntryClass()
Map<String,String>	getTopicInUse()
void	setExtendedBindingProperties(RocketMQExtendedBindingProperties extendedBindingProperties)

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

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

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

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

getBindings

Constructor Detail

RocketMQMessageChannelBinder

public RocketMQMessageChannelBinder(RocketMQTopicProvisioner provisioningProvider,
                                    RocketMQExtendedBindingProperties extendedBindingProperties,
                                    RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
                                    org.apache.rocketmq.spring.autoconfigure.RocketMQProperties rocketMQProperties,
                                    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>

getTopicInUse

public Map<String,String> getTopicInUse()

getDefaultsPrefix

public String getDefaultsPrefix()

Specified by:

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

getExtendedPropertiesEntryClass

public Class<? extends org.springframework.cloud.stream.binder.BinderSpecificPropertiesProvider> getExtendedPropertiesEntryClass()

Specified by:

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

setExtendedBindingProperties

public void setExtendedBindingProperties(RocketMQExtendedBindingProperties extendedBindingProperties)