|
@@ -36,22 +36,22 @@ public class PulsarClientService {
|
|
|
|
|
|
// @Value("${mq.service-url}")
|
|
// @Value("${mq.service-url}")
|
|
// private String serviceUrl;
|
|
// private String serviceUrl;
|
|
-//
|
|
|
|
|
|
+
|
|
// @Value("${mq.auth-token}")
|
|
// @Value("${mq.auth-token}")
|
|
// private String authToken;
|
|
// private String authToken;
|
|
-//
|
|
|
|
|
|
+
|
|
// @Value("${mq.topic-ticket-generate}")
|
|
// @Value("${mq.topic-ticket-generate}")
|
|
// private String topicTicketGenerate;
|
|
// private String topicTicketGenerate;
|
|
-//
|
|
|
|
|
|
+
|
|
// @Value("${mq.topic-ticket-pay}")
|
|
// @Value("${mq.topic-ticket-pay}")
|
|
// private String topicTicketPay;
|
|
// private String topicTicketPay;
|
|
-//
|
|
|
|
|
|
+
|
|
// @Value("${mq.consumer-conn}")
|
|
// @Value("${mq.consumer-conn}")
|
|
// private boolean consumerConn;
|
|
// private boolean consumerConn;
|
|
-//
|
|
|
|
|
|
+
|
|
// @Value("${mq.consumer-topics}")
|
|
// @Value("${mq.consumer-topics}")
|
|
// private String topics;
|
|
// private String topics;
|
|
-//
|
|
|
|
|
|
+
|
|
@Autowired
|
|
@Autowired
|
|
private PulsarConsumer pulsarConsumer;
|
|
private PulsarConsumer pulsarConsumer;
|
|
|
|
|
|
@@ -63,7 +63,7 @@ public class PulsarClientService {
|
|
// .serviceUrl(serviceUrl)//【集群管理】接入地址处复制
|
|
// .serviceUrl(serviceUrl)//【集群管理】接入地址处复制
|
|
// .authentication(AuthenticationFactory.token(authToken))
|
|
// .authentication(AuthenticationFactory.token(authToken))
|
|
// .build();
|
|
// .build();
|
|
-//
|
|
|
|
|
|
+
|
|
// if (consumerConn) {
|
|
// if (consumerConn) {
|
|
// consumer = client.newConsumer()
|
|
// consumer = client.newConsumer()
|
|
// .topic(topics.split(","))//topic完整路径,格式为persistent://集群(租户)ID/命名空间/Topic名称
|
|
// .topic(topics.split(","))//topic完整路径,格式为persistent://集群(租户)ID/命名空间/Topic名称
|