如何通过JNDI设置ActiveMQ连接用户名和密码

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">
    ...
    <plugins>
        ...
    </plugins>

    <jndiContext>
        <resource-ref>
            <res-ref-name>jdbc/TestDB</res-ref-name>
            <res-type>javax.sql.DataSource</res-type>
            <res-auth>Container</res-auth>
        </resource-ref>
        <resource-ref>
            <res-ref-name>ConnectionFactory</res-ref-name>
            <res-type>org.apache.activemq.ActiveMQConnectionFactory</res-type>
            <res-auth>Container</res-auth>
        </resource-ref>
    </jndiContext>

    ...
</broker>

<bean id="connectionFactory" class="org.apache.activemq.jndi.JNDIReferenceFactory">
    <property name="jndiName" value="ConnectionFactory"/>
</bean>

java.naming.factory.url.pkgs=org.apache.activemq.jndi
java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory
connectionFactoryNames=ConnectionFactory

<Context>
    <Resource name="jdbc/TestDB" auth="Container" type="javax.sql.DataSource"
              maxTotal="100" maxIdle="30" maxWaitMillis="10000"
              username="db_username" password="db_password" driverClassName="com.mysql.jdbc.Driver"
              url="jdbc:mysql://localhost:3306/testdb"/>

    <Resource name="ConnectionFactory" auth="Container" type="org.apache.activemq.ActiveMQConnectionFactory"
              factory="org.apache.activemq.jndi.JNDIReferenceFactory"
              description="JMS Connection Factory"
              brokerURL="tcp://localhost:61616"
              userName="amq_username" password="amq_password"/>
</Context>

import javax.jms.*;
import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;

public class JNDIExample {
    public static void main(String[] args) {
        try {
            // 初始化JNDI上下文
            Context context = new InitialContext();

            // 查找连接工厂
            ConnectionFactory connectionFactory = (ConnectionFactory) context.lookup("ConnectionFactory");

            // 创建连接
            Connection connection = connectionFactory.createConnection("amq_username", "amq_password");

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

            // 创建目标
            Destination destination = session.createQueue("TestQueue");

            // 创建生产者
            MessageProducer producer = session.createProducer(destination);

            // 创建消息
            TextMessage message = session.createTextMessage("Hello, ActiveMQ!");

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

            // 关闭资源
            producer.close();
            session.close();
            connection.close();
        } catch (NamingException | JMSException e) {
            e.printStackTrace();
        }
    }
}