[ISSUE #157] Fix code format problem (#158)

Author: mxsm

src/main/java/io/openmessaging/storage/dledger/DLedgerLeaderElector.java

@@ -693,7 +693,8 @@ public StateMaintainer(String name, Logger logger) {
             super(name, logger);
         }
 
-        @Override public void doWork() {
+        @Override
+        public void doWork() {
             try {
                 if (DLedgerLeaderElector.this.dLedgerConfig.isEnableLeaderElector()) {
                     DLedgerLeaderElector.this.refreshIntervals(dLedgerConfig);

src/main/java/io/openmessaging/storage/dledger/DLedgerServer.java

@@ -144,7 +144,8 @@ public StateMachine getStateMachine() {
         return this.fsmCaller.map(StateMachineCaller::getStateMachine).orElse(null);
     }
 
-    @Override public CompletableFuture<HeartBeatResponse> handleHeartBeat(HeartBeatRequest request) throws Exception {
+    @Override
+    public CompletableFuture<HeartBeatResponse> handleHeartBeat(HeartBeatRequest request) throws Exception {
         try {
 
             PreConditions.check(memberState.getSelfId().equals(request.getRemoteId()), DLedgerResponseCode.UNKNOWN_MEMBER, "%s != %s", request.getRemoteId(), memberState.getSelfId());
@@ -160,7 +161,8 @@ public StateMachine getStateMachine() {
         }
     }
 
-    @Override public CompletableFuture<VoteResponse> handleVote(VoteRequest request) throws Exception {
+    @Override
+    public CompletableFuture<VoteResponse> handleVote(VoteRequest request) throws Exception {
         try {
             PreConditions.check(memberState.getSelfId().equals(request.getRemoteId()), DLedgerResponseCode.UNKNOWN_MEMBER, "%s != %s", request.getRemoteId(), memberState.getSelfId());
             PreConditions.check(memberState.getGroup().equals(request.getGroup()), DLedgerResponseCode.UNKNOWN_GROUP, "%s != %s", request.getGroup(), memberState.getGroup());
@@ -264,7 +266,8 @@ public CompletableFuture<GetEntriesResponse> handleGet(GetEntriesRequest request
         }
     }
 
-    @Override public CompletableFuture<MetadataResponse> handleMetadata(MetadataRequest request) throws Exception {
+    @Override
+    public CompletableFuture<MetadataResponse> handleMetadata(MetadataRequest request) throws Exception {
         try {
             PreConditions.check(memberState.getSelfId().equals(request.getRemoteId()), DLedgerResponseCode.UNKNOWN_MEMBER, "%s != %s", request.getRemoteId(), memberState.getSelfId());
             PreConditions.check(memberState.getGroup().equals(request.getGroup()), DLedgerResponseCode.UNKNOWN_GROUP, "%s != %s", request.getGroup(), memberState.getGroup());
@@ -289,7 +292,8 @@ public CompletableFuture<PullEntriesResponse> handlePull(PullEntriesRequest requ
         return null;
     }
 
-    @Override public CompletableFuture<PushEntryResponse> handlePush(PushEntryRequest request) throws Exception {
+    @Override
+    public CompletableFuture<PushEntryResponse> handlePush(PushEntryRequest request) throws Exception {
         try {
             PreConditions.check(memberState.getSelfId().equals(request.getRemoteId()), DLedgerResponseCode.UNKNOWN_MEMBER, "%s != %s", request.getRemoteId(), memberState.getSelfId());
             PreConditions.check(memberState.getGroup().equals(request.getGroup()), DLedgerResponseCode.UNKNOWN_GROUP, "%s != %s", request.getGroup(), memberState.getGroup());

src/main/java/io/openmessaging/storage/dledger/client/DLedgerClientRpcNettyService.java

@@ -48,7 +48,8 @@ public CompletableFuture<AppendEntryResponse> append(AppendEntryRequest request)
         return CompletableFuture.completedFuture(response);
     }
 
-    @Override public CompletableFuture<MetadataResponse> metadata(MetadataRequest request) throws Exception {
+    @Override
+    public CompletableFuture<MetadataResponse> metadata(MetadataRequest request) throws Exception {
         RemotingCommand wrapperRequest = RemotingCommand.createRequestCommand(DLedgerRequestCode.METADATA.getCode(), null);
         wrapperRequest.setBody(JSON.toJSONBytes(request));
         RemotingCommand wrapperResponse = this.remotingClient.invokeSync(getPeerAddr(request.getRemoteId()), wrapperRequest, 3000);

src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java

@@ -522,7 +522,8 @@ public long getLedgerEndIndex() {
         return ledgerEndIndex;
     }
 
-    @Override public long getLedgerBeginIndex() {
+    @Override
+    public long getLedgerBeginIndex() {
         return ledgerBeginIndex;
     }
 

src/main/java/io/openmessaging/storage/dledger/store/file/DefaultMmapFile.java

@@ -245,11 +245,13 @@ public void setFlushedPosition(int pos) {
         this.flushedPosition.set(pos);
     }
 
-    @Override public int getStartPosition() {
+    @Override
+    public int getStartPosition() {
         return startPosition.get();
     }
 
-    @Override public void setStartPosition(int startPosition) {
+    @Override
+    public void setStartPosition(int startPosition) {
         this.startPosition.set(startPosition);
     }