This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 8dd07c846 [ISSUE #4818] Fix AutoSwitchHAService code formate incorrect
(#4819)
8dd07c846 is described below
commit 8dd07c84697d3709f1f4bef5d78089b7d171b6cd
Author: mxsm <[email protected]>
AuthorDate: Sat Aug 13 00:13:10 2022 +0800
[ISSUE #4818] Fix AutoSwitchHAService code formate incorrect (#4819)
---
.../org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
b/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
index 0a5a3adc6..2ea22dc6d 100644
---
a/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
+++
b/store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java
@@ -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);
}
}