mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
@@ -86,7 +86,7 @@ public class ControllerManager {
|
||||
new ThreadFactoryImpl("ControllerRequestExecutorThread_")) {
|
||||
@Override
|
||||
protected <T> RunnableFuture<T> newTaskFor(final Runnable runnable, final T value) {
|
||||
return new FutureTaskExt<T>(runnable, value);
|
||||
return new FutureTaskExt<>(runnable, value);
|
||||
}
|
||||
};
|
||||
this.heartbeatManager = new DefaultBrokerHeartbeatManager(this.controllerConfig);
|
||||
|
||||
Reference in New Issue
Block a user