mirror of
https://github.com/apache/rocketmq.git
synced 2026-08-30 18:10:44 +08:00
+2
-1
@@ -410,7 +410,8 @@ public class AutoSwitchHAService extends DefaultHAService {
|
||||
return AutoSwitchAcceptSocketService.class.getSimpleName();
|
||||
}
|
||||
|
||||
@Override protected HAConnection createConnection(SocketChannel sc) throws IOException {
|
||||
@Override
|
||||
protected HAConnection createConnection(SocketChannel sc) throws IOException {
|
||||
return new AutoSwitchHAConnection(AutoSwitchHAService.this, sc, AutoSwitchHAService.this.epochCache);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user