logs

Signed-off-by: Oleh Dokuka <odokuka@vmware.com>
Signed-off-by: Oleh Dokuka <oleh.dokuka@icloud.com>
Signed-off-by: OlegDokuka <odokuka@vmware.com>

Author: OlegDokuka

rsocket-transport-local/src/test/java/io/rsocket/transport/local/LocalResumableTransportTest.java

@@ -19,16 +19,27 @@
 import io.rsocket.test.TransportTest;
 import java.time.Duration;
 import java.util.UUID;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.TestInfo;
 
 final class LocalResumableTransportTest implements TransportTest {
 
-  private final TransportPair transportPair =
-      new TransportPair<>(
-          () -> "LocalResumableTransportTest-" + UUID.randomUUID(),
-          (address, server, allocator) -> LocalClientTransport.create(address, allocator),
-          (address, allocator) -> LocalServerTransport.create(address),
-          false,
-          true);
+  private TransportPair transportPair;
+
+  @BeforeEach
+  void createTestPair(TestInfo testInfo) {
+    transportPair =
+        new TransportPair<>(
+            () ->
+                "LocalResumableTransportTest-"
+                    + testInfo.getDisplayName()
+                    + "-"
+                    + UUID.randomUUID(),
+            (address, server, allocator) -> LocalClientTransport.create(address, allocator),
+            (address, allocator) -> LocalServerTransport.create(address),
+            false,
+            true);
+  }
 
   @Override
   public Duration getTimeout() {

rsocket-transport-local/src/test/java/io/rsocket/transport/local/LocalResumableWithFragmentationTransportTest.java

@@ -19,16 +19,27 @@
 import io.rsocket.test.TransportTest;
 import java.time.Duration;
 import java.util.UUID;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.TestInfo;
 
 final class LocalResumableWithFragmentationTransportTest implements TransportTest {
 
-  private final TransportPair transportPair =
-      new TransportPair<>(
-          () -> "LocalResumableWithFragmentationTransportTest-" + UUID.randomUUID(),
-          (address, server, allocator) -> LocalClientTransport.create(address, allocator),
-          (address, allocator) -> LocalServerTransport.create(address),
-          true,
-          true);
+  private TransportPair transportPair;
+
+  @BeforeEach
+  void createTestPair(TestInfo testInfo) {
+    transportPair =
+        new TransportPair<>(
+            () ->
+                "LocalResumableWithFragmentationTransportTest-"
+                    + testInfo.getDisplayName()
+                    + "-"
+                    + UUID.randomUUID(),
+            (address, server, allocator) -> LocalClientTransport.create(address, allocator),
+            (address, allocator) -> LocalServerTransport.create(address),
+            true,
+            true);
+  }
 
   @Override
   public Duration getTimeout() {

rsocket-transport-local/src/test/java/io/rsocket/transport/local/LocalTransportTest.java

@@ -19,14 +19,21 @@
 import io.rsocket.test.TransportTest;
 import java.time.Duration;
 import java.util.UUID;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.TestInfo;
 
 final class LocalTransportTest implements TransportTest {
 
-  private final TransportPair transportPair =
-      new TransportPair<>(
-          () -> "LocalTransportTest-" + UUID.randomUUID(),
-          (address, server, allocator) -> LocalClientTransport.create(address, allocator),
-          (address, allocator) -> LocalServerTransport.create(address));
+  private TransportPair transportPair;
+
+  @BeforeEach
+  void createTestPair(TestInfo testInfo) {
+    transportPair =
+        new TransportPair<>(
+            () -> "LocalTransportTest-" + testInfo.getDisplayName() + "-" + UUID.randomUUID(),
+            (address, server, allocator) -> LocalClientTransport.create(address, allocator),
+            (address, allocator) -> LocalServerTransport.create(address));
+  }
 
   @Override
   public Duration getTimeout() {

rsocket-transport-local/src/test/java/io/rsocket/transport/local/LocalTransportWithFragmentationTest.java

@@ -19,15 +19,26 @@
 import io.rsocket.test.TransportTest;
 import java.time.Duration;
 import java.util.UUID;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.TestInfo;
 
 final class LocalTransportWithFragmentationTest implements TransportTest {
 
-  private final TransportPair transportPair =
-      new TransportPair<>(
-          () -> "LocalTransportWithFragmentationTest-" + UUID.randomUUID(),
-          (address, server, allocator) -> LocalClientTransport.create(address, allocator),
-          (address, allocator) -> LocalServerTransport.create(address),
-          true);
+  private TransportPair transportPair;
+
+  @BeforeEach
+  void createTestPair(TestInfo testInfo) {
+    transportPair =
+        new TransportPair<>(
+            () ->
+                "LocalTransportWithFragmentationTest-"
+                    + testInfo.getDisplayName()
+                    + "-"
+                    + UUID.randomUUID(),
+            (address, server, allocator) -> LocalClientTransport.create(address, allocator),
+            (address, allocator) -> LocalServerTransport.create(address),
+            true);
+  }
 
   @Override
   public Duration getTimeout() {