Skip to content

Commit 9ea0d23

Browse files
committed
Add the dash as the delimiter
1 parent 5f3d4cb commit 9ea0d23

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

pulsar-broker/src/test/java/org/apache/pulsar/client/api/MutualAuthenticationTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -269,7 +269,7 @@ public void testClientVersion() throws Exception {
269269
assertEquals(stats.getPublishers().size(), 2);
270270

271271
assertEquals(stats.getPublishers().stream().map(PublisherStats::getClientVersion).collect(Collectors.toSet()),
272-
Sets.newHashSet(defaultClientVersion, defaultClientVersion + "my-java-client"));
272+
Sets.newHashSet(defaultClientVersion, defaultClientVersion + "-my-java-client"));
273273

274274
producer1.close();
275275
producer2.close();

pulsar-broker/src/test/java/org/apache/pulsar/client/api/SimpleProducerConsumerTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4607,7 +4607,7 @@ public void testClientVersion() throws Exception {
46074607
assertEquals(stats.getPublishers().size(), 2);
46084608

46094609
assertEquals(stats.getPublishers().stream().map(PublisherStats::getClientVersion).collect(Collectors.toSet()),
4610-
Sets.newHashSet(defaultClientVersion, defaultClientVersion + "my-java-client"));
4610+
Sets.newHashSet(defaultClientVersion, defaultClientVersion + "-my-java-client"));
46114611

46124612
producer1.close();
46134613
producer2.close();

pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,7 +255,7 @@ public ClientCnx(ClientConfigurationData conf, EventLoopGroup eventLoopGroup, in
255255
this.protocolVersion = protocolVersion;
256256
this.idleState = new ClientCnxIdleState(this);
257257
this.clientVersion = "Pulsar-Java-v" + PulsarVersion.getVersion()
258-
+ (conf.getDescription() == null ? "" : conf.getDescription());
258+
+ (conf.getDescription() == null ? "" : ("-" + conf.getDescription()));
259259
}
260260

261261
@Override

0 commit comments

Comments
 (0)