Skip to content

Commit 65156f8

Browse files
committed
Clean up
1 parent 0e0b982 commit 65156f8

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

opamp-client/src/main/java/io/opentelemetry/opamp/client/internal/request/service/WebSocketRequestService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -158,8 +158,7 @@ public void onMessage(byte[] data) {
158158
}
159159

160160
private static ServerToAgent readServerToAgent(byte[] data) throws IOException {
161-
Long header = ProtoAdapter.UINT64.decode(data);
162-
int headerSize = ProtoAdapter.UINT64.encodedSize(header);
161+
int headerSize = ProtoAdapter.UINT64.encodedSize(ProtoAdapter.UINT64.decode(data));
163162
int payloadSize = data.length - headerSize;
164163
byte[] payload = new byte[payloadSize];
165164
System.arraycopy(data, headerSize, payload, 0, payloadSize);

0 commit comments

Comments
 (0)