提交 e954ab27 authored 作者: scc's avatar scc

test3

上级 fe083c5b
package com.example.rocketmqdemo.controller; package com.example.rocketmqdemo.controller;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer; import com.example.rocketmqdemo.pojo.XcRocketMq2;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQBrokerException; import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException; import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendCallback; import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.CountDownLatch2; import org.apache.rocketmq.common.CountDownLatch2;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.common.message.MessageExt;
import org.apache.rocketmq.remoting.common.RemotingHelper;
import org.apache.rocketmq.remoting.exception.RemotingException; import org.apache.rocketmq.remoting.exception.RemotingException;
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
......
package com.example.rocketmqdemo.controller; package com.example.rocketmqdemo.pojo;
import lombok.Data; import lombok.Data;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
......
rocketmq: rocketmq:
name-server: ${NAME_SERVER:rocket-nameserver-0.rocket-nameserver.pipeline-zjh:9876} name-server: ${NAME_SERVER:rocket-nameserver-0.rocket-nameserver.pipeline-zjh:9876}
producer: producer:
group: string_producer_group group: ${STRING_PRODUCER_GROUP:string_producer_group}
xc: xc:
rocketmq2: rocketmq2:
topic-string: topic_string topic-string: ${TOPIC_NAME:sccTest}
topic-object: topic_object topic-object: ${TOPIC_OBJECT:sccObject}
string-consumer-group: string_consumer_group string-consumer-group: ${STRING_CONSUMER_GROUP:stringConsumerGroup}
object-consumer-group: object_consumer_group object-consumer-group: ${STRING_CONSUMER_GROUP:objectConsumerGroup}
\ No newline at end of file \ No newline at end of file
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论