如何将项目入队到akka.net队列源

using System;
using Akka.Actor;
using Akka.Streams;
using Akka.Streams.Dsl;

// 定义项目消息类型
public class ProjectMessage
{
    public string Name { get; set; }
    public string Description { get; set; }
    // 其他必要的项目信息
}

// 创建项目Actor
public class ProjectActor : ReceiveActor
{
    public ProjectActor()
    {
        Receive<ProjectMessage>(message =>
        {
            // 处理项目消息的逻辑
            Console.WriteLine($"Received project: {message.Name}");
        });
    }
}

class Program
{
    static void Main(string[] args)
    {
        // 创建Actor系统
        var system = ActorSystem.Create("MySystem");

        // 创建项目Actor
        var projectActor = system.ActorOf<ProjectActor>("ProjectActor");

        // 创建队列源
        var queueSource = Source.Queue<ProjectMessage>(bufferSize: 100, OverflowStrategy.DropHead);

        // 将项目消息发送到队列源
        var queue = queueSource.To(Sink.ActorRef<ProjectMessage>(projectActor, onCompleteMessage: StreamCompleted.Instance)).Run();

        // 发送项目消息
        var project = new ProjectMessage { Name = "MyProject", Description = "This is my project" };
        queue.OfferAsync(project);

        // 等待消息处理完成
        system.WhenTerminated.Wait();
    }
}