Added missing tests removed skips

FoundatioFx · Sep 26, 2024 · 6f8e7d5 · 6f8e7d5
1 parent ed21f02
commit 6f8e7d5
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 7 deletions.
diff --git a/docker-compose.yml b/docker-compose.yml
@@ -1,16 +1,24 @@
-version: '2'
-
 services:
   rabbitmq:
     image: rabbitmq:3.10-management
     ports:
       - "5672:5672"
       - "8080:15672" # management ui - login with guest:guest
+    deploy:
+      resources:
+        limits:
+          memory: 512m
+
   rabbitmq-delayed:
     build: ./build # use RabbitMQ docker image with delay plugin installed
     ports:
       - "5673:5672"
       - "8081:15672" # management ui - login with guest:guest
+    deploy:
+      resources:
+        limits:
+          memory: 512m
+
   ready:
     image: andrewlock/wait-for-dependencies
     command: rabbitmq:15672 rabbitmq-delayed:15672

diff --git a/samples/Foundatio.RabbitMQ.Publish/Program.cs b/samples/Foundatio.RabbitMQ.Publish/Program.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Threading.Tasks;
 using Foundatio.Messaging;
 

diff --git a/samples/Foundatio.RabbitMQ.Subscribe/Program.cs b/samples/Foundatio.RabbitMQ.Subscribe/Program.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Collections.Generic;
 using System.Threading.Tasks;
 using Foundatio.Messaging;

diff --git a/tests/Foundatio.RabbitMQ.Tests/Messaging/RabbitMqMessageBusTests.cs b/tests/Foundatio.RabbitMQ.Tests/Messaging/RabbitMqMessageBusTests.cs
@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Threading;
 using System.Threading.Tasks;
 using Foundatio.AsyncEx;
@@ -16,6 +16,7 @@ public class RabbitMqMessageBusTests : MessageBusTestBase
     private readonly string _topic = $"test_topic_{DateTime.UtcNow.Ticks}";
 
     public RabbitMqMessageBusTests(ITestOutputHelper output) : base(output) { }
+
     protected override IMessageBus GetMessageBus(Func<SharedMessageBusOptions, SharedMessageBusOptions> config = null)
     {
         return new RabbitMQMessageBus(o =>
@@ -53,6 +54,12 @@ public override Task CanSendDerivedMessageAsync()
         return base.CanSendDerivedMessageAsync();
     }
 
+    [Fact]
+    public override Task CanSendMappedMessageAsync()
+    {
+        return base.CanSendMappedMessageAsync();
+    }
+
     [Fact]
     public override Task CanSendDelayedMessageAsync()
     {
@@ -65,7 +72,7 @@ public override Task CanSubscribeConcurrentlyAsync()
         return base.CanSubscribeConcurrentlyAsync();
     }
 
-    [Fact(Skip = "TODO: Ensure this is not broken")]
+    [Fact]
     public override Task CanReceiveMessagesConcurrentlyAsync()
     {
         return base.CanReceiveMessagesConcurrentlyAsync();
@@ -119,7 +126,7 @@ public override Task WontKeepMessagesWithNoSubscribersAsync()
         return base.WontKeepMessagesWithNoSubscribersAsync();
     }
 
-    [Fact(Skip = "TODO: Ensure this is not broken")]
+    [Fact]
     public override Task CanReceiveFromMultipleSubscribersAsync()
     {
         return base.CanReceiveFromMultipleSubscribersAsync();