Skip to content

Commit a6be1ee

Browse files
authored
[ISSUE # 10086] Fix timer engine switch to persist correct config key (#10085)
1 parent 35d69cb commit a6be1ee

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3466,13 +3466,13 @@ private synchronized RemotingCommand switchTimerEngine(ChannelHandlerContext ctx
34663466
if (MessageConst.TIMER_ENGINE_ROCKSDB_TIMELINE.equals(engineType)) {
34673467
if (this.brokerController.getTimerMessageRocksDBStore() == null) {
34683468
response.setCode(ResponseCode.INVALID_PARAMETER);
3469-
response.setRemark("timerUseRocksDB muse be configured true when broker start");
3469+
response.setRemark("timerRocksDBEnable must be configured true when broker start");
34703470
return response;
34713471
}
34723472
result = this.brokerController.getTimerMessageRocksDBStore().restart();
34733473
if (result) {
34743474
properties.put("timerStopEnqueue", Boolean.TRUE.toString());
3475-
properties.put("timerUseRocksDB", Boolean.TRUE.toString());
3475+
properties.put("timerRocksDBEnable", Boolean.TRUE.toString());
34763476
properties.put("timerRocksDBStopScan", Boolean.FALSE.toString());
34773477
}
34783478
} else {

0 commit comments

Comments
 (0)