continuity/Server/Consumers/PacketConsumer.cs

using MassTransit;
using Server.Packets;
using Server.Services;

namespace Server.Consumers;

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

    public PacketConsumer(PacketDistributorService distributorService) => this._distributorService = distributorService;

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