com.alibaba.cloud.stream.binder.rocketmq

类 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>

com.alibaba.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

所有已实现的接口:

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.context.ApplicationContextAware

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>

作者:

Jim

嵌套类概要

从类继承的嵌套类/接口 org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

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

字段概要

从类继承的字段 org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

EXPRESSION_PARSER, provisioningProvider

从类继承的字段 org.springframework.cloud.stream.binder.AbstractBinder

contentTypeResolver, logger

构造器概要

构造器

构造器和说明
RocketMQMessageChannelBinder(RocketMQExtendedBindingProperties extendedBindingProperties, RocketMQTopicProvisioner provisioningProvider, RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties, org.apache.rocketmq.spring.autoconfigure.RocketMQProperties rocketMQProperties, InstrumentationManager instrumentationManager)

方法概要

限定符和类型	方法和说明
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)
Map<String,String>	getTopicInUse()

从类继承的方法 org.springframework.cloud.stream.binder.AbstractMessageChannelBinder

afterUnbindConsumer, afterUnbindProducer, doBindConsumer, doBindProducer, errorsBaseName, errorsBaseName, getDefaultErrorMessageHandler, getErrorBridgeName, getErrorBridgeName, getErrorMessageHandler, getErrorMessageHandlerName, getErrorMessageStrategy, getErrorRecovererName, registerErrorInfrastructure

从类继承的方法 org.springframework.cloud.stream.binder.AbstractBinder

afterPropertiesSet, applyPrefix, bindConsumer, bindProducer, buildPartitionRoutingExpression, buildRetryTemplate, constructDLQName, deserializePayloadIfNecessary, deserializePayloadIfNecessary, getApplicationContext, getBeanFactory, groupedName, onInit, serializePayloadIfNecessary, serializePayloadIfNecessary, setApplicationContext, setCodec, setIntegrationEvaluationContext

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.springframework.cloud.stream.binder.Binder

bindConsumer, bindProducer

构造器详细资料

RocketMQMessageChannelBinder

public RocketMQMessageChannelBinder(RocketMQExtendedBindingProperties extendedBindingProperties,
                                    RocketMQTopicProvisioner provisioningProvider,
                                    RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
                                    org.apache.rocketmq.spring.autoconfigure.RocketMQProperties rocketMQProperties,
                                    InstrumentationManager instrumentationManager)

方法详细资料

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

指定者:

createProducerMessageHandler 在类中 org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>,RocketMQTopicProvisioner>

抛出:

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

指定者:

createConsumerEndpoint 在类中 org.springframework.cloud.stream.binder.AbstractMessageChannelBinder<org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties>,org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties>,RocketMQTopicProvisioner>

抛出:

Exception

getExtendedConsumerProperties

public RocketMQConsumerProperties getExtendedConsumerProperties(String channelName)

指定者:

getExtendedConsumerProperties 在接口中 org.springframework.cloud.stream.binder.ExtendedBindingProperties<RocketMQConsumerProperties,RocketMQProducerProperties>

getExtendedProducerProperties

public RocketMQProducerProperties getExtendedProducerProperties(String channelName)

指定者:

getExtendedProducerProperties 在接口中 org.springframework.cloud.stream.binder.ExtendedBindingProperties<RocketMQConsumerProperties,RocketMQProducerProperties>

getTopicInUse

public Map<String,String> getTopicInUse()