如何在qpid JMS中设置ContentType

import org.apache.qpid.jms.JmsConnectionFactory;
import javax.jms.*;

public class QpidJMSExample {

    public static void main(String[] args) throws Exception {
        // 创建连接工厂
        JmsConnectionFactory factory = new JmsConnectionFactory("amqp://localhost:5672");

        // 创建连接
        Connection connection = factory.createConnection("username", "password");
        connection.start();

        // 创建会话
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        // 创建生产者
        MessageProducer producer = session.createProducer(session.createQueue("myqueue"));

        // 设置消息的ContentType
        producer.setDeliveryMode(DeliveryMode.PERSISTENT);

        // 创建消息
        TextMessage message = session.createTextMessage();
        message.setText("Hello, Qpid JMS!");
        message.setJMSType("text/plain");

        // 发送消息
        producer.send(message);

        // 关闭连接
        connection.close();
    }
}