在ActiveMQ中，可以使用Prefetch Policy（预取策略）来限制正在分派的消息数量。

下面是一个示例代码，展示如何使用Prefetch Policy来限制正在分派的消息数量：

import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

public class MessageConsumerExample {
    public static void main(String[] args) {
        try {
            // 创建连接工厂
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");

            // 创建连接
            Connection connection = connectionFactory.createConnection();
            connection.start();

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

            // 创建目的地
            Destination destination = session.createQueue("myQueue");

            // 创建消息消费者
            MessageConsumer consumer = session.createConsumer(destination);

            // 设置Prefetch Policy
            ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy();
            prefetchPolicy.setQueuePrefetch(10); // 设置每个消费者的消息预取数量为10
            ((ActiveMQConnection) connection).setPrefetchPolicy(prefetchPolicy);

            // 消费消息
            while (true) {
                Message message = consumer.receive();
                if (message instanceof TextMessage) {
                    TextMessage textMessage = (TextMessage) message;
                    System.out.println("Received message: " + textMessage.getText());
                }
            }

            // 关闭连接
            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}

在上面的代码中，我们通过ActiveMQPrefetchPolicy设置了每个消费者的消息预取数量为10。这意味着每个消费者最多同时处理10条消息。当消费者处理完一条消息后，它会从ActiveMQ中获取下一条消息进行处理。

请注意，上述代码是一个简化的示例，实际使用时可能需要添加错误处理和关闭资源的代码。