masstransit 集成hangfire

2024-10-10 23:58:12 +08:00
parent a700658132
commit 1e99374de0
3 changed files with 42 additions and 0 deletions
@@ -162,6 +162,27 @@ namespace IRaCIS.Core.Application.Service
            return ResponseOutput.Ok();
        }

+        public class MasstransitHangfireTest
+        {
+            public string value { get; set; }
+        }
+
+        public class MasstransitHangfireTestConsumer : IConsumer<MasstransitHangfireTest>
+        {
+            public Task Consume(ConsumeContext<MasstransitHangfireTest> context)
+            {
+                Console.WriteLine("Now is " + DateTime.Now.ToString());
+                Console.WriteLine($"MassTransit.Consumer1 :{context.Message.value}");
+                return Task.CompletedTask;
+            }
+        }
+        public async Task<IResponseOutput> TestMasstransitHangfire([FromServices] IMessageScheduler _scheduler)
+        {
+            await _scheduler.SchedulePublish(DateTime.Now.AddSeconds(10), new MasstransitHangfireTest() { value = "message at " + DateTime.Now.ToString() });
+
+            return ResponseOutput.Ok();
+        }
+
        public async Task<IResponseOutput> TestJson()
        {
            var model1 = new TestModel() { TestId = NewId.NextSequentialGuid(), TestName = null };