Skip to content

Commit 0ea3cfb

Browse files
committed
Sync ProtonJ2 with upstream
1 parent fb87dd6 commit 0ea3cfb

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

src/main/qpid/org/apache/qpid/protonj2/codec/decoders/ProtonDecoder.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -535,7 +535,7 @@ public Integer readInteger(ProtonBuffer buffer, DecoderState state) throws Decod
535535

536536
switch (encodingCode) {
537537
case EncodingCodes.SMALLINT:
538-
return buffer.readByte() & 0xff;
538+
return (int) buffer.readByte();
539539
case EncodingCodes.INT:
540540
return buffer.readInt();
541541
case EncodingCodes.NULL:
@@ -551,7 +551,7 @@ public int readInteger(ProtonBuffer buffer, DecoderState state, int defaultValue
551551

552552
switch (encodingCode) {
553553
case EncodingCodes.SMALLINT:
554-
return buffer.readByte() & 0xff;
554+
return buffer.readByte();
555555
case EncodingCodes.INT:
556556
return buffer.readInt();
557557
case EncodingCodes.NULL:

src/main/qpid/org/apache/qpid/protonj2/codec/decoders/primitives/Integer8TypeDecoder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ public int readPrimitiveValue(InputStream stream, StreamDecoderState state) thro
8080

8181
@Override
8282
public Integer readValue(ProtonBuffer buffer, DecoderState state) throws DecodeException {
83-
return buffer.readByte() & 0xff;
83+
return Integer.valueOf(buffer.readByte());
8484
}
8585

8686
@Override

src/main/qpid/org/apache/qpid/protonj2/codec/decoders/primitives/Long8TypeDecoder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public final class Long8TypeDecoder extends LongTypeDecoder {
3232

3333
@Override
3434
public Long readValue(ProtonBuffer buffer, DecoderState state) throws DecodeException {
35-
return (long) buffer.readByte() & (byte) 0xff;
35+
return (long) buffer.readByte();
3636
}
3737

3838
@Override

0 commit comments

Comments
 (0)