Fix tests

azure-pipelines.yml

@@ -21,6 +21,8 @@ jobs:
           command: test
           projects: src/**/*.Tests.csproj
           arguments: --configuration $(BuildConfiguration)
+          publishTestResults: true
+          testRunTitle: Windows
 
       - task: DotNetCoreCLI@2
         displayName: Pack
@@ -55,3 +57,5 @@ jobs:
           command: test
           projects: src/**/*.Tests.csproj
           arguments: --configuration $(BuildConfiguration) --framework $(LinuxTargetFramework)
+          publishTestResults: true
+          testRunTitle: Linux

src/Abc.Zebus.Directory.RocksDb.Tests/Abc.Zebus.Directory.RocksDb.Tests.csproj

@@ -13,4 +13,8 @@
     <ProjectReference Include="..\Abc.Zebus.Testing\Abc.Zebus.Testing.csproj" />
   </ItemGroup>
 
+  <ItemGroup>
+    <PackageReference Include="RocksDbNative" Version="6.2.2" />
+  </ItemGroup>
+
 </Project>

src/Abc.Zebus.Tests/Transport/ZmqTransportTests.cs

@@ -278,7 +278,7 @@ namespace Abc.Zebus.Tests.Transport
             senderTransport.Send(new FakeCommand(0).ToTransportMessage(), new[] { receiver });
             Wait.Until(() => receivedMessages.Count == 2, 2.Seconds(), "unable to receive message");
         }
-       
+
         [Test, Repeat(10)]
         public void should_not_reuse_a_port_used_in_another_envionment()
         {
@@ -296,7 +296,7 @@ namespace Abc.Zebus.Tests.Transport
             Console.WriteLine("{0} => {1}", endpoint.GetPort(), expectedPort);
         }
 
-        [Test, Repeat(5)] 
+        [Test, Repeat(5)]
         public void should_terminate_zmq_connection_of_a_forgotten_peer_after_some_time()
         {
             var senderTransport = CreateAndStartZmqTransport();
@@ -416,7 +416,7 @@ namespace Abc.Zebus.Tests.Transport
             }
 
             var receiverStopwatch = Stopwatch.StartNew();
-            Wait.Until(() => receivedMessages.Count == 10, 2.Seconds(), "Timed out while waiting for messages");
+            Wait.Until(() => receivedMessages.Count == 10, 10.Seconds(), "Timed out while waiting for messages");
             receiverStopwatch.Stop();
             Console.WriteLine("Elapsed time to get messages: " + receiverStopwatch.Elapsed);
             receiverStopwatch.ElapsedMilliseconds.ShouldBeLessOrEqualThan(200, "Throughput is too low");
@@ -586,7 +586,7 @@ namespace Abc.Zebus.Tests.Transport
             transport2.Send(new FakeCommand(0).ToTransportMessage(), new[] { peer1 });
             Wait.Until(() => transport1.OutboundSocketCount == 1, 10.Seconds());
             Wait.Until(() => transport2.OutboundSocketCount == 1, 10.Seconds());
-            
+
             transport2.Stop();
 
             Wait.Until(() => transport1.OutboundSocketCount == 0, 10.Seconds());