Add the dash as the delimiter

BewareMyPower · Apr 4, 2023 · 2114f3a · 2114f3a
1 parent 1f3da40
commit 2114f3a
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MutualAuthenticationTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/MutualAuthenticationTest.java
@@ -269,7 +269,7 @@ public void testClientVersion() throws Exception {
         assertEquals(stats.getPublishers().size(), 2);
 
         assertEquals(stats.getPublishers().stream().map(PublisherStats::getClientVersion).collect(Collectors.toSet()),
-                Sets.newHashSet(defaultClientVersion, defaultClientVersion + "my-java-client"));
+                Sets.newHashSet(defaultClientVersion, defaultClientVersion + "-my-java-client"));
 
         producer1.close();
         producer2.close();

diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java
@@ -4607,7 +4607,7 @@ public void testClientVersion() throws Exception {
         assertEquals(stats.getPublishers().size(), 2);
 
         assertEquals(stats.getPublishers().stream().map(PublisherStats::getClientVersion).collect(Collectors.toSet()),
-                Sets.newHashSet(defaultClientVersion, defaultClientVersion + "my-java-client"));
+                Sets.newHashSet(defaultClientVersion, defaultClientVersion + "-my-java-client"));
 
         producer1.close();
         producer2.close();

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
@@ -255,7 +255,7 @@ public ClientCnx(ClientConfigurationData conf, EventLoopGroup eventLoopGroup, in
         this.protocolVersion = protocolVersion;
         this.idleState = new ClientCnxIdleState(this);
         this.clientVersion = "Pulsar-Java-v" + PulsarVersion.getVersion()
-                + (conf.getDescription() == null ? "" : conf.getDescription());
+                + (conf.getDescription() == null ? "" : ("-" + conf.getDescription()));
     }
 
     @Override