activeMQ.producer消息生产者,调整消息预读取条数1

jms.prefetchPolicy.all=1

//连接地址
    //调整消息预读取条数1。
    private static final String BROKER_URL = "tcp://192.168.1.1:61616?jms.prefetchPolicy.all=1";

//连接工厂
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);