From 3231731e0842728365e340900f07b69f0f61ad4f Mon Sep 17 00:00:00 2001 From: Mateusz Skoczek Date: Wed, 28 Jan 2026 20:21:58 +0100 Subject: [PATCH] new events nuget version --- .../RabbitMQEventQueuePublisher.cs | 12 +++++------- ...Designer.Backend.Events.Providers.RabbitMQ.csproj | 2 +- 2 files changed, 6 insertions(+), 8 deletions(-) diff --git a/TimetableDesigner.Backend.Events.Providers.RabbitMQ/RabbitMQEventQueuePublisher.cs b/TimetableDesigner.Backend.Events.Providers.RabbitMQ/RabbitMQEventQueuePublisher.cs index d3e693a..21df149 100644 --- a/TimetableDesigner.Backend.Events.Providers.RabbitMQ/RabbitMQEventQueuePublisher.cs +++ b/TimetableDesigner.Backend.Events.Providers.RabbitMQ/RabbitMQEventQueuePublisher.cs @@ -13,22 +13,20 @@ public class RabbitMQEventQueuePublisher : IEventQueuePublisher _connection = connection; _exchangeName = exchangeName; } - - public async Task PublishAsync(T eventData) where T : class + + public async Task PublishAsync(string data, Type dataType) { - string routingKey = typeof(T).FullName!; BasicProperties properties = new BasicProperties { ContentType = "application/json", DeliveryMode = DeliveryModes.Persistent, - Type = typeof(T).FullName, - + Type = dataType.FullName, }; - ReadOnlyMemory body = JsonSerializer.SerializeToUtf8Bytes(eventData); + ReadOnlyMemory body = JsonSerializer.SerializeToUtf8Bytes(data); await using (IChannel channel = await _connection.CreateChannelAsync()) { await channel.ExchangeDeclareAsync(_exchangeName, ExchangeType.Direct); - await channel.BasicPublishAsync(_exchangeName, routingKey, true, properties, body); + await channel.BasicPublishAsync(_exchangeName, dataType.FullName!, true, properties, body); } } } \ No newline at end of file diff --git a/TimetableDesigner.Backend.Events.Providers.RabbitMQ/TimetableDesigner.Backend.Events.Providers.RabbitMQ.csproj b/TimetableDesigner.Backend.Events.Providers.RabbitMQ/TimetableDesigner.Backend.Events.Providers.RabbitMQ.csproj index c3ca9ef..d041789 100644 --- a/TimetableDesigner.Backend.Events.Providers.RabbitMQ/TimetableDesigner.Backend.Events.Providers.RabbitMQ.csproj +++ b/TimetableDesigner.Backend.Events.Providers.RabbitMQ/TimetableDesigner.Backend.Events.Providers.RabbitMQ.csproj @@ -14,7 +14,7 @@ - +