我们可以通过明确设置ActiveMQ的Systemusage来避免存储被限制为100 GB的问题。以下是示例代码:
SystemUsage systemUsage = new SystemUsage(); systemUsage.getStoreUsage().setLimit(500 * 1024 * 1024); //设置存储使用的限制 systemUsage.getTempUsage().setLimit(100 * 1024 * 1024); //设置临时使用的限制
ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(); ((ActiveMQConnectionFactory) connectionFactory).setBrokerURL("tcp://localhost:61616"); ((ActiveMQConnectionFactory) connectionFactory).setSystemUsage(systemUsage); //将设置好的Systemusage传递给连接工厂
Connection connection = connectionFactory.createConnection(); connection.start();
//之后的消息生产过程与平常一样即可