| Constructor and Description |
|---|
RocketMQMessageChannelBinder(ConsumersManager consumersManager,
RocketMQExtendedBindingProperties extendedBindingProperties,
RocketMQTopicProvisioner provisioningProvider,
RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
InstrumentationManager instrumentationManager) |
| Modifier and Type | Method and Description |
|---|---|
InstrumentationManager |
RocketMQBinderEndpointAutoConfiguration.instrumentationManager() |
| Constructor and Description |
|---|
ConsumersManager(InstrumentationManager instrumentationManager,
RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties) |
| Constructor and Description |
|---|
RocketMQInboundChannelAdapter(ConsumersManager consumersManager,
org.springframework.cloud.stream.binder.ExtendedConsumerProperties<RocketMQConsumerProperties> consumerProperties,
String destination,
String group,
InstrumentationManager instrumentationManager) |
RocketMQMessageHandler(String destination,
org.springframework.cloud.stream.binder.ExtendedProducerProperties<RocketMQProducerProperties> producerProperties,
RocketMQBinderConfigurationProperties rocketBinderConfigurationProperties,
InstrumentationManager instrumentationManager) |
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.