如何将对象发送到ActiveMQ (C#)

using Apache.NMS;
using Apache.NMS.ActiveMQ;

public class ObjectSender
{
    private IConnectionFactory factory;
    private IConnection connection;
    private ISession session;
    private IMessageProducer producer;

    public ObjectSender()
    {
        // 创建连接工厂
        factory = new ConnectionFactory("tcp://localhost:61616");

        // 创建连接
        connection = factory.CreateConnection();

        // 创建会话
        session = connection.CreateSession();

        // 创建消息生产者
        producer = session.CreateProducer(null);
    }

    public void SendMessage(object obj)
    {
        // 创建消息
        IObjectMessage message = session.CreateObjectMessage(obj);

        // 发送消息
        producer.Send(message);
    }

    public void Close()
    {
        // 关闭连接和会话
        producer.Close();
        session.Close();
        connection.Close();
    }
}

ObjectSender sender = new ObjectSender();
sender.SendMessage(new MyObject());
sender.Close();