continuity/Server/Consumers/PacketConsumer.cs

using MassTransit;

namespace Server;

public class PacketConsumer : IConsumer<RawPacket>
{
    private readonly PacketDistributorService _distributorService;

    public PacketConsumer(PacketDistributorService distributorService)
    {
        _distributorService = distributorService;
    }

    public Task Consume(ConsumeContext<RawPacket> context)
    {
        _distributorService.AddPacket(context.Message);
        return Task.CompletedTask;
    }
}