A B C D E G H I L M O P R S T W

A

Acknowledgement - Class in org.springframework.cloud.stream.binder.rocketmq.consuming

Acknowledgement() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

ACKNOWLEDGEMENT_KEY - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

addHealthInstrumentation(Instrumentation) - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

B

buildConcurrentlyInstance() - Static method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

buildOrderlyInstance() - Static method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

C

close(RetryContext, RetryCallback<T, E>, Throwable) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListener

CloudStreamMessageListener() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListener

CloudStreamMessageListenerConcurrently() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListenerConcurrently

CloudStreamMessageListenerOrderly() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListenerOrderly

CONSUMED_FAILURES_PER_SECOND - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Consumer

CONSUMED_PER_SECOND - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Consumer

consumeMessage(List<MessageExt>, ConsumeConcurrentlyContext) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListenerConcurrently

consumeMessage(List<MessageExt>, ConsumeOrderlyContext) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListenerOrderly

ConsumerGroupInstrumentation - Class in org.springframework.cloud.stream.binder.rocketmq.metrics

ConsumerGroupInstrumentation(MetricRegistry, String) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.metrics.ConsumerGroupInstrumentation

ConsumerInstrumentation - Class in org.springframework.cloud.stream.binder.rocketmq.metrics

ConsumerInstrumentation(MetricRegistry, String) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.metrics.ConsumerInstrumentation

consumersManager() - Method in class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderAutoConfiguration

ConsumersManager - Class in org.springframework.cloud.stream.binder.rocketmq.consuming

ConsumersManager(InstrumentationManager, RocketMQBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

createConsumerEndpoint(ConsumerDestination, String, ExtendedConsumerProperties<RocketMQConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

createProducerMessageHandler(ProducerDestination, ExtendedProducerProperties<RocketMQProducerProperties>, MessageChannel) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

D

doHealthCheck(Health.Builder) - Method in class org.springframework.cloud.stream.binder.rocketmq.actuator.RocketMQBinderHealthIndicator

doStart() - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter

doStop() - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter

E

ENDPOINT_ID - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

G

getAcknowledgement(Message) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getBindings() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQExtendedBindingProperties

getBroadcasting() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

getConsumeConcurrentlyDelayLevel() - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

getConsumeConcurrentlyStatus() - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

getConsumeOrderlyStatus() - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

getConsumeOrderlySuspendCurrentQueueTimeMill() - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

getConsumer() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBindingProperties

getConsumerGroupInstrumentation(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

getConsumerGroups() - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

getConsumerInstrumentation(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

getDelayTimeLevel() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getEnabled() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

getEnabled() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

getExecuter() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQExtendedBindingProperties

getExtendedConsumerProperties(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQExtendedBindingProperties

getExtendedProducerProperties(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

getFlag() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getHealthInstrumentations() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

getKeys() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getLogLevel() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBinderConfigurationProperties

getMaxMessageSize() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

getMetricRegistry() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

getName() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

getNamesrvAddr() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBinderConfigurationProperties

getOrCreateConsumer(String, String, ExtendedConsumerProperties<RocketMQConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

getOrderly() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

getProducer() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBindingProperties

getProducerInstrumentation(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

getRocketMessage() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getRuntime() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

getSendResult() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getSql() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

getStartException() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

getTags() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

getTags() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getTransactional() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

getTransactionalArg() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

getTransactionCheckListener() - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

getUserProperties() - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

GROUP_PREFIX - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Consumer

H

handleMessageInternal(Message<?>) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

I

Instrumentation - Class in org.springframework.cloud.stream.binder.rocketmq.metrics

instrumentationManager() - Method in class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderEndpointAutoConfiguration

InstrumentationManager - Class in org.springframework.cloud.stream.binder.rocketmq.metrics

InstrumentationManager() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.metrics.InstrumentationManager

invoke() - Method in class org.springframework.cloud.stream.binder.rocketmq.actuator.RocketMQBinderEndpoint

isDown() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

isOutOfService() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

isRunning() - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

isStarted() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

isUp() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

L

LASTSEND_TIMESTAMP - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

Instrumentation

M

markConsumed() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.ConsumerInstrumentation

markConsumedFailure() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.ConsumerInstrumentation

markSent() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.ProducerInstrumentation

markSentFailure() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.ProducerInstrumentation

markStartedSuccessfully() - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

markStartFailed(Exception) - Method in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

O

onError(RetryContext, RetryCallback<T, E>, Throwable) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListener

open(RetryContext, RetryCallback<T, E>) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter.CloudStreamMessageListener

org.springframework.cloud.stream.binder.rocketmq - package org.springframework.cloud.stream.binder.rocketmq

org.springframework.cloud.stream.binder.rocketmq.actuator - package org.springframework.cloud.stream.binder.rocketmq.actuator

org.springframework.cloud.stream.binder.rocketmq.config - package org.springframework.cloud.stream.binder.rocketmq.config

org.springframework.cloud.stream.binder.rocketmq.consuming - package org.springframework.cloud.stream.binder.rocketmq.consuming

org.springframework.cloud.stream.binder.rocketmq.integration - package org.springframework.cloud.stream.binder.rocketmq.integration

org.springframework.cloud.stream.binder.rocketmq.metrics - package org.springframework.cloud.stream.binder.rocketmq.metrics

org.springframework.cloud.stream.binder.rocketmq.properties - package org.springframework.cloud.stream.binder.rocketmq.properties

org.springframework.cloud.stream.binder.rocketmq.provisioning - package org.springframework.cloud.stream.binder.rocketmq.provisioning

ORIGINAL_ROCKET_MESSAGE - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

Header key

P

PREFIX - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Consumer

PREFIX - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Producer

ProducerInstrumentation - Class in org.springframework.cloud.stream.binder.rocketmq.metrics

ProducerInstrumentation(MetricRegistry, String) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.metrics.ProducerInstrumentation

provisionConsumerDestination(String, String, ExtendedConsumerProperties<RocketMQConsumerProperties>) - Method in class org.springframework.cloud.stream.binder.rocketmq.provisioning.RocketMQTopicProvisioner

provisioningProvider() - Method in class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderAutoConfiguration

provisionProducerDestination(String, ExtendedProducerProperties<RocketMQProducerProperties>) - Method in class org.springframework.cloud.stream.binder.rocketmq.provisioning.RocketMQTopicProvisioner

putSendResult(MutableMessage, SendResult) - Static method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

R

ROCKET_FLAG - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

ROCKET_SEND_RESULT - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

ROCKET_TRANSACTIONAL_ARG - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants

rocketBinderEndpoint() - Method in class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderEndpointAutoConfiguration

rocketBinderHealthIndicator() - Method in class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderEndpointAutoConfiguration

rocketMessageChannelBinder(RocketMQTopicProvisioner, ConsumersManager) - Method in class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderAutoConfiguration

RocketMQBinderAutoConfiguration - Class in org.springframework.cloud.stream.binder.rocketmq.config

RocketMQBinderAutoConfiguration(RocketMQExtendedBindingProperties, RocketMQBinderConfigurationProperties) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderAutoConfiguration

RocketMQBinderConfigurationProperties - Class in org.springframework.cloud.stream.binder.rocketmq.properties

RocketMQBinderConfigurationProperties() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBinderConfigurationProperties

RocketMQBinderConstants - Interface in org.springframework.cloud.stream.binder.rocketmq

RocketMQBinderConstants.Metrics - Interface in org.springframework.cloud.stream.binder.rocketmq

RocketMQBinderConstants.Metrics.Consumer - Interface in org.springframework.cloud.stream.binder.rocketmq

RocketMQBinderConstants.Metrics.Producer - Interface in org.springframework.cloud.stream.binder.rocketmq

RocketMQBinderEndpoint - Class in org.springframework.cloud.stream.binder.rocketmq.actuator

RocketMQBinderEndpoint() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.actuator.RocketMQBinderEndpoint

RocketMQBinderEndpointAutoConfiguration - Class in org.springframework.cloud.stream.binder.rocketmq.config

RocketMQBinderEndpointAutoConfiguration() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.config.RocketMQBinderEndpointAutoConfiguration

RocketMQBinderHealthIndicator - Class in org.springframework.cloud.stream.binder.rocketmq.actuator

RocketMQBinderHealthIndicator() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.actuator.RocketMQBinderHealthIndicator

RocketMQBindingProperties - Class in org.springframework.cloud.stream.binder.rocketmq.properties

RocketMQBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBindingProperties

RocketMQConsumerProperties - Class in org.springframework.cloud.stream.binder.rocketmq.properties

RocketMQConsumerProperties() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

RocketMQExtendedBindingProperties - Class in org.springframework.cloud.stream.binder.rocketmq.properties

RocketMQExtendedBindingProperties() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQExtendedBindingProperties

RocketMQInboundChannelAdapter - Class in org.springframework.cloud.stream.binder.rocketmq.integration

RocketMQInboundChannelAdapter(ConsumersManager, ExtendedConsumerProperties<RocketMQConsumerProperties>, String, String, InstrumentationManager) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter

RocketMQInboundChannelAdapter.CloudStreamMessageListener - Class in org.springframework.cloud.stream.binder.rocketmq.integration

RocketMQInboundChannelAdapter.CloudStreamMessageListenerConcurrently - Class in org.springframework.cloud.stream.binder.rocketmq.integration

RocketMQInboundChannelAdapter.CloudStreamMessageListenerOrderly - Class in org.springframework.cloud.stream.binder.rocketmq.integration

RocketMQMessageChannelBinder - Class in org.springframework.cloud.stream.binder.rocketmq

RocketMQMessageChannelBinder(ConsumersManager, RocketMQExtendedBindingProperties, RocketMQTopicProvisioner, RocketMQBinderConfigurationProperties, InstrumentationManager) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder

RocketMQMessageHandler - Class in org.springframework.cloud.stream.binder.rocketmq.integration

RocketMQMessageHandler(String, ExtendedProducerProperties<RocketMQProducerProperties>, RocketMQBinderConfigurationProperties, InstrumentationManager) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

RocketMQMessageHeaderAccessor - Class in org.springframework.cloud.stream.binder.rocketmq

RocketMQMessageHeaderAccessor() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

RocketMQMessageHeaderAccessor(Message<?>) - Constructor for class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

RocketMQProducerProperties - Class in org.springframework.cloud.stream.binder.rocketmq.properties

RocketMQProducerProperties() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

RocketMQTopicProvisioner - Class in org.springframework.cloud.stream.binder.rocketmq.provisioning

RocketMQTopicProvisioner() - Constructor for class org.springframework.cloud.stream.binder.rocketmq.provisioning.RocketMQTopicProvisioner

S

SENT_FAILURES_PER_SECOND - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Producer

SENT_PER_SECOND - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Producer

setBindings(Map<String, RocketMQBindingProperties>) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQExtendedBindingProperties

setBroadcasting(Boolean) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

setConsumeConcurrentlyDelayLevel(Integer) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

setConsumeConcurrentlyStatus(ConsumeConcurrentlyStatus) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

setConsumeOrderlyStatus(ConsumeOrderlyStatus) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

setConsumeOrderlySuspendCurrentQueueTimeMill(Long) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.Acknowledgement

setConsumer(RocketMQConsumerProperties) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBindingProperties

setEnabled(Boolean) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

setEnabled(Boolean) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

setExecuter(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

setLocalTransactionExecuter(LocalTransactionExecuter) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

setLogLevel(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBinderConfigurationProperties

setMaxMessageSize(Integer) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

setNamesrvAddr(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBinderConfigurationProperties

setOrderly(Boolean) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

setProducer(RocketMQProducerProperties) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQBindingProperties

setRecoveryCallback(RecoveryCallback<? extends Object>) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter

setRetryTemplate(RetryTemplate) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQInboundChannelAdapter

setSql(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

setTags(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties

setTransactional(Boolean) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

setTransactionCheckListener(TransactionCheckListener) - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

setTransactionCheckListener(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.properties.RocketMQProducerProperties

start() - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

startConsumer(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

startConsumers() - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

started - Variable in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

startException - Variable in class org.springframework.cloud.stream.binder.rocketmq.metrics.Instrumentation

stop() - Method in class org.springframework.cloud.stream.binder.rocketmq.integration.RocketMQMessageHandler

stopConsumer(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.consuming.ConsumersManager

T

TOTAL_CONSUMED - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Consumer

TOTAL_CONSUMED_FAILURES - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Consumer

TOTAL_SENT - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Producer

TOTAL_SENT_FAILURES - Static variable in interface org.springframework.cloud.stream.binder.rocketmq.RocketMQBinderConstants.Metrics.Producer

W

withAcknowledgment(Acknowledgement) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

withDelayTimeLevel(Integer) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

withFlag(Integer) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

withKeys(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

withRocketMessage(MessageExt) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

withTags(String) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

withTransactionalArg(Object) - Method in class org.springframework.cloud.stream.binder.rocketmq.RocketMQMessageHeaderAccessor

A B C D E G H I L M O P R S T W