|
@@ -6,11 +6,8 @@ import com.qmth.themis.business.dto.MqDto;
|
|
|
import com.qmth.themis.business.util.JacksonUtil;
|
|
|
import com.qmth.themis.business.util.RedisUtil;
|
|
|
import com.qmth.themis.common.contanst.Constants;
|
|
|
-import com.qmth.themis.mq.templete.Concurrently;
|
|
|
import com.qmth.themis.mq.templete.Orderly;
|
|
|
import com.qmth.themis.task.listener.service.MqTaskLogicService;
|
|
|
-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.common.message.MessageExt;
|