|
|
|
@ -19,16 +19,18 @@ package com.alibaba.cloud.stream.binder.rocketmq.consuming;
|
|
|
|
|
import static com.alibaba.cloud.stream.binder.rocketmq.RocketMQBinderConstants.ROCKETMQ_RECONSUME_TIMES;
|
|
|
|
|
|
|
|
|
|
import java.util.List;
|
|
|
|
|
import java.util.Map;
|
|
|
|
|
import java.util.Objects;
|
|
|
|
|
|
|
|
|
|
import com.alibaba.cloud.stream.binder.rocketmq.support.RocketMQHeaderMapper;
|
|
|
|
|
import com.google.common.collect.Maps;
|
|
|
|
|
import org.apache.rocketmq.acl.common.AclClientRPCHook;
|
|
|
|
|
import org.apache.rocketmq.acl.common.SessionCredentials;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.MessageSelector;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.*;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyContext;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.listener.MessageListenerOrderly;
|
|
|
|
|
import org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely;
|
|
|
|
|
import org.apache.rocketmq.client.exception.MQClientException;
|
|
|
|
|
import org.apache.rocketmq.common.UtilAll;
|
|
|
|
@ -47,7 +49,6 @@ import org.springframework.beans.factory.InitializingBean;
|
|
|
|
|
import org.springframework.cloud.stream.binder.ExtendedConsumerProperties;
|
|
|
|
|
import org.springframework.context.SmartLifecycle;
|
|
|
|
|
import org.springframework.integration.support.MessageBuilder;
|
|
|
|
|
import org.springframework.integration.support.MutableMessageHeaders;
|
|
|
|
|
import org.springframework.messaging.Message;
|
|
|
|
|
import org.springframework.util.Assert;
|
|
|
|
|
import org.springframework.util.StringUtils;
|
|
|
|
@ -55,6 +56,7 @@ import org.springframework.util.StringUtils;
|
|
|
|
|
import com.alibaba.cloud.stream.binder.rocketmq.RocketMQMessageChannelBinder;
|
|
|
|
|
import com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQBinderConfigurationProperties;
|
|
|
|
|
import com.alibaba.cloud.stream.binder.rocketmq.properties.RocketMQConsumerProperties;
|
|
|
|
|
import com.alibaba.cloud.stream.binder.rocketmq.support.RocketMQHeaderMapper;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* A class that Listen on rocketmq message
|
|
|
|
|