Technoboy- commented on code in PR #21379:
URL: https://github.com/apache/pulsar/pull/21379#discussion_r1362123862
##########
pulsar-broker/src/test/java/org/apache/pulsar/websocket/proxy/ProxyPublishConsumeTest.java:
##########
@@ -1051,5 +1051,70 @@ private void stopWebSocketClient(WebSocketClient...
clients) {
log.info("proxy clients are stopped successfully");
}
+ @Test
+ public void testMultiTopics() throws Exception {
+ final String subscription1 = "my-sub1";
+ final String subscription2 = "my-sub2";
+ final String topic1 = "my-property/my-ns/testMultiTopics" +
UUID.randomUUID();
+ final String topic2 = "my-property/my-ns/testMultiTopics" +
UUID.randomUUID();
+ final String consumerUri1 = "ws://localhost:" +
proxyServer.getListenPortHTTP().get() +
+ "/ws/v3/consumer/" + subscription1 + "?topics=" + topic1 + ","
+ topic2;
+
+ final String consumerUri2 = "ws://localhost:" +
proxyServer.getListenPortHTTP().get() +
+ "/ws/v3/consumer/" + subscription2 +
"?topicsPattern=my-property/my-ns/testMultiTopics.*";
+
+ int messages = 10;
+ WebSocketClient consumerClient1 = new WebSocketClient();
+ WebSocketClient consumerClient2 = new WebSocketClient();
+ SimpleConsumerSocket consumeSocket1 = new SimpleConsumerSocket();
+ SimpleConsumerSocket consumeSocket2 = new SimpleConsumerSocket();
+ Producer<byte[]> producer1 = pulsarClient.newProducer()
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
