opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 05:44:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(broker): mark unless attribute with @Deprecated

Browse Source 
1. mark unless attribute with @Deprecated
This commit is contained in:
TheR1sing3un
2023-03-14 09:40:15 +08:00
committed by rongtong
parent 3a69aae701
commit 0c2f480c3a
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java
+2 -1
View File
@@ -86,6 +86,7 @@ public class AutoSwitchHAClient extends ServiceThread implements HAClient {
* │ HANDSHAKE Header │ body │
* </pre>
*/
@Deprecated
public static final int HANDSHAKE_SIZE = HANDSHAKE_HEADER_SIZE + 50;
/**
@@ -105,7 +106,7 @@ public class AutoSwitchHAClient extends ServiceThread implements HAClient {
private static final int READ_MAX_BUFFER_SIZE = 1024 * 1024 * 4;
private final AtomicReference<String> masterHaAddress = new AtomicReference<>();
private final AtomicReference<String> masterAddress = new AtomicReference<>();
private final ByteBuffer handshakeHeaderBuffer = ByteBuffer.allocate(HANDSHAKE_SIZE);
private final ByteBuffer handshakeHeaderBuffer = ByteBuffer.allocate(HANDSHAKE_HEADER_SIZE);
private final ByteBuffer transferHeaderBuffer = ByteBuffer.allocate(TRANSFER_HEADER_SIZE);
private final AutoSwitchHAService haService;
private final ByteBuffer byteBufferRead = ByteBuffer.allocate(READ_MAX_BUFFER_SIZE);