Skip to content

Commit 61af2ff

Browse files
DonnerbartDonnerbart
committed
Fix warnings in tests
1 parent 7299a26 commit 61af2ff

File tree

69 files changed

+827
-1004
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

69 files changed

+827
-1004
lines changed

‎reactor/src/test/java/com/hivemq/client/rx/reactor/FluxWithSingleTest.java‎

Lines changed: 198 additions & 191 deletions
Large diffs are not rendered by default.

‎src/test/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt3/Mqtt3ConnAckDecoderTest.java‎

Lines changed: 41 additions & 47 deletions
Original file line numberDiff line numberDiff line change
@@ -33,34 +33,34 @@
3333
*/
3434
class Mqtt3ConnAckDecoderTest extends AbstractMqtt3DecoderTest {
3535

36-
private static final @NotNull byte[] WELLFORMED_CONNACK_BEGIN = {
36+
private static final byte @NotNull [] WELLFORMED_CONNACK_BEGIN = {
3737
// type, flags
3838
0b0010_0000,
3939
//remaining length
4040
0b0000_0010
4141
};
42-
private static final @NotNull byte[] MALFORMED_CONNACK_BEGIN_WORNG_FLAGS = {
42+
private static final byte @NotNull [] MALFORMED_CONNACK_BEGIN_WORNG_FLAGS = {
4343
// type, flags
4444
0b0010_0100,
4545
//remaining length
4646
0b0000_0010
4747
};
48-
private static final @NotNull byte[] MALFORMED_CONNACK_BEGIN_TOO_LONG_LENGTH = {
48+
private static final byte @NotNull [] MALFORMED_CONNACK_BEGIN_TOO_LONG_LENGTH = {
4949
// type, flags
5050
0b0010_0100,
5151
//remaining length
5252
0b0000_0011
5353
};
54-
private static final @NotNull byte[] ENDING_TOO_LONG_MALFORMED = {0x01};
55-
private static final @NotNull byte[] SESSION_PRESENT_TRUE = {0b0000_0001};
56-
private static final @NotNull byte[] SESSION_PRESENT_FALSE = {0b0000_0000};
57-
private static final @NotNull byte[] REASON_CODE_SUCCESS = {0x00};
58-
private static final @NotNull byte[] REASON_CODE_UNACCEPTED_PROTOCOL_VERSION = {0x01};
59-
private static final @NotNull byte[] REASON_CODE_IDENTIFIER_REJECTED = {0x02};
60-
private static final @NotNull byte[] REASON_CODE_SERVER_UNAVAILABLE = {0x03};
61-
private static final @NotNull byte[] REASON_CODE_SERVER_BAD_USERNAME_OR_PASSWORD = {0x04};
62-
private static final @NotNull byte[] REASON_CODE_NOT_AUTHORIZED = {0x05};
63-
private static final @NotNull byte[] REASON_CODE_BAD = {0x13};
54+
private static final byte @NotNull [] ENDING_TOO_LONG_MALFORMED = {0x01};
55+
private static final byte @NotNull [] SESSION_PRESENT_TRUE = {0b0000_0001};
56+
private static final byte @NotNull [] SESSION_PRESENT_FALSE = {0b0000_0000};
57+
private static final byte @NotNull [] REASON_CODE_SUCCESS = {0x00};
58+
private static final byte @NotNull [] REASON_CODE_UNACCEPTED_PROTOCOL_VERSION = {0x01};
59+
private static final byte @NotNull [] REASON_CODE_IDENTIFIER_REJECTED = {0x02};
60+
private static final byte @NotNull [] REASON_CODE_SERVER_UNAVAILABLE = {0x03};
61+
private static final byte @NotNull [] REASON_CODE_SERVER_BAD_USERNAME_OR_PASSWORD = {0x04};
62+
private static final byte @NotNull [] REASON_CODE_NOT_AUTHORIZED = {0x05};
63+
private static final byte @NotNull [] REASON_CODE_BAD = {0x13};
6464

6565
Mqtt3ConnAckDecoderTest() {
6666
super(new MqttMessageDecoders() {{
@@ -71,9 +71,9 @@ class Mqtt3ConnAckDecoderTest extends AbstractMqtt3DecoderTest {
7171
@ParameterizedTest
7272
@ValueSource(strings = {"true", "false"})
7373
void decode_SUCCESS(final boolean sessionPresent) {
74-
final byte[] encoded =
75-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
76-
REASON_CODE_SUCCESS);
74+
final byte[] encoded = Bytes.concat(
75+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
76+
REASON_CODE_SUCCESS);
7777
final ByteBuf byteBuf = channel.alloc().buffer();
7878
byteBuf.writeBytes(encoded);
7979
channel.writeInbound(byteBuf);
@@ -86,9 +86,9 @@ void decode_SUCCESS(final boolean sessionPresent) {
8686
@ParameterizedTest
8787
@ValueSource(strings = {"true", "false"})
8888
void decode_WRONG_PROTOCOL(final boolean sessionPresent) {
89-
final byte[] encoded =
90-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
91-
REASON_CODE_UNACCEPTED_PROTOCOL_VERSION);
89+
final byte[] encoded = Bytes.concat(
90+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
91+
REASON_CODE_UNACCEPTED_PROTOCOL_VERSION);
9292
final ByteBuf byteBuf = channel.alloc().buffer();
9393
byteBuf.writeBytes(encoded);
9494
channel.writeInbound(byteBuf);
@@ -106,9 +106,9 @@ void decode_WRONG_PROTOCOL(final boolean sessionPresent) {
106106
@ParameterizedTest
107107
@ValueSource(strings = {"true", "false"})
108108
void decode_SERVER_IDENTFIER_REJECTED(final boolean sessionPresent) {
109-
final byte[] encoded =
110-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
111-
REASON_CODE_IDENTIFIER_REJECTED);
109+
final byte[] encoded = Bytes.concat(
110+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
111+
REASON_CODE_IDENTIFIER_REJECTED);
112112
final ByteBuf byteBuf = channel.alloc().buffer();
113113
byteBuf.writeBytes(encoded);
114114
channel.writeInbound(byteBuf);
@@ -126,9 +126,9 @@ void decode_SERVER_IDENTFIER_REJECTED(final boolean sessionPresent) {
126126
@ParameterizedTest
127127
@ValueSource(strings = {"true", "false"})
128128
void decode_SERVER_UNAVAILABLE(final boolean sessionPresent) {
129-
final byte[] encoded =
130-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
131-
REASON_CODE_SERVER_UNAVAILABLE);
129+
final byte[] encoded = Bytes.concat(
130+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
131+
REASON_CODE_SERVER_UNAVAILABLE);
132132
final ByteBuf byteBuf = channel.alloc().buffer();
133133
byteBuf.writeBytes(encoded);
134134
channel.writeInbound(byteBuf);
@@ -146,9 +146,9 @@ void decode_SERVER_UNAVAILABLE(final boolean sessionPresent) {
146146
@ParameterizedTest
147147
@ValueSource(strings = {"true", "false"})
148148
void decode_SERVER_BAD_USERNAME_OR_PASSWORD(final boolean sessionPresent) {
149-
final byte[] encoded =
150-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
151-
REASON_CODE_SERVER_BAD_USERNAME_OR_PASSWORD);
149+
final byte[] encoded = Bytes.concat(
150+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
151+
REASON_CODE_SERVER_BAD_USERNAME_OR_PASSWORD);
152152
final ByteBuf byteBuf = channel.alloc().buffer();
153153
byteBuf.writeBytes(encoded);
154154
channel.writeInbound(byteBuf);
@@ -166,9 +166,9 @@ void decode_SERVER_BAD_USERNAME_OR_PASSWORD(final boolean sessionPresent) {
166166
@ParameterizedTest
167167
@ValueSource(strings = {"true", "false"})
168168
void decode_NOT_AUTHORIZED(final boolean sessionPresent) {
169-
final byte[] encoded =
170-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
171-
REASON_CODE_NOT_AUTHORIZED);
169+
final byte[] encoded = Bytes.concat(
170+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
171+
REASON_CODE_NOT_AUTHORIZED);
172172
final ByteBuf byteBuf = channel.alloc().buffer();
173173
byteBuf.writeBytes(encoded);
174174
channel.writeInbound(byteBuf);
@@ -186,9 +186,9 @@ void decode_NOT_AUTHORIZED(final boolean sessionPresent) {
186186
@ParameterizedTest
187187
@ValueSource(strings = {"true", "false"})
188188
void decode_BAD_RETURNCODE(final boolean sessionPresent) {
189-
final byte[] encoded =
190-
Bytes.concat(WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
191-
REASON_CODE_BAD);
189+
final byte[] encoded = Bytes.concat(
190+
WELLFORMED_CONNACK_BEGIN, sessionPresent ? SESSION_PRESENT_TRUE : SESSION_PRESENT_FALSE,
191+
REASON_CODE_BAD);
192192
final ByteBuf byteBuf = channel.alloc().buffer();
193193
byteBuf.writeBytes(encoded);
194194
channel.writeInbound(byteBuf);
@@ -199,19 +199,13 @@ void decode_BAD_RETURNCODE(final boolean sessionPresent) {
199199
@ParameterizedTest
200200
@ValueSource(strings = {"1", "2"})
201201
void decode_ERROR_CASES(final int errorcase) throws Exception {
202-
final byte[] encoded;
203-
switch (errorcase) {
204-
case 1:
205-
encoded = Bytes.concat(MALFORMED_CONNACK_BEGIN_WORNG_FLAGS, SESSION_PRESENT_FALSE, REASON_CODE_BAD);
206-
break;
207-
case 2:
208-
encoded = Bytes.concat(MALFORMED_CONNACK_BEGIN_TOO_LONG_LENGTH, SESSION_PRESENT_FALSE, REASON_CODE_BAD,
209-
ENDING_TOO_LONG_MALFORMED);
210-
break;
211-
default:
212-
throw new Exception();
213-
}
214-
202+
final byte[] encoded = switch (errorcase) {
203+
case 1 -> Bytes.concat(MALFORMED_CONNACK_BEGIN_WORNG_FLAGS, SESSION_PRESENT_FALSE, REASON_CODE_BAD);
204+
case 2 -> Bytes.concat(
205+
MALFORMED_CONNACK_BEGIN_TOO_LONG_LENGTH, SESSION_PRESENT_FALSE, REASON_CODE_BAD,
206+
ENDING_TOO_LONG_MALFORMED);
207+
default -> throw new Exception();
208+
};
215209
final ByteBuf byteBuf = channel.alloc().buffer();
216210
byteBuf.writeBytes(encoded);
217211
channel.writeInbound(byteBuf);

‎src/test/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt3/Mqtt3PubAckDecoderTest.java‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -30,27 +30,27 @@
3030

3131
class Mqtt3PubAckDecoderTest extends AbstractMqtt3DecoderTest {
3232

33-
private static final @NotNull byte[] WELLFORMED_PUBACK_BEGIN = {
33+
private static final byte @NotNull [] WELLFORMED_PUBACK_BEGIN = {
3434
// type, flags
3535
0b0100_0000,
3636
//remaining length
3737
0b0000_0010
3838
};
39-
private static final @NotNull byte[] MALFORMED_PUBACK_BEGIN_WRONG_FLAGS = {
39+
private static final byte @NotNull [] MALFORMED_PUBACK_BEGIN_WRONG_FLAGS = {
4040
// type, flags
4141
0b0100_0100,
4242
//remaining length
4343
0b0000_0010
4444
};
45-
private static final @NotNull byte[] MALFORMED_PUBACK_BEGIN_TOO_LONG_LENGTH = {
45+
private static final byte @NotNull [] MALFORMED_PUBACK_BEGIN_TOO_LONG_LENGTH = {
4646
// type, flags
4747
0b0100_0000,
4848
//remaining length
4949
0b0000_0011
5050
};
51-
private static final @NotNull byte[] ENDING_TOO_LONG_MALFORMED = {0x01};
52-
private static final @NotNull byte[] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
53-
private static final @NotNull byte[] MIN_PACKET_ID = {0x00, 0x00};
51+
private static final byte @NotNull [] ENDING_TOO_LONG_MALFORMED = {0x01};
52+
private static final byte @NotNull [] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
53+
private static final byte @NotNull [] MIN_PACKET_ID = {0x00, 0x00};
5454

5555
Mqtt3PubAckDecoderTest() {
5656
super(new MqttMessageDecoders() {{

‎src/test/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt3/Mqtt3PubCompDecoderTest.java‎

Lines changed: 11 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -29,27 +29,27 @@
2929

3030
class Mqtt3PubCompDecoderTest extends AbstractMqtt3DecoderTest {
3131

32-
private static final @NotNull byte[] WELLFORMED_PUBCOMP_BEGIN = {
32+
private static final byte @NotNull [] WELLFORMED_PUBCOMP_BEGIN = {
3333
// type, flags
3434
0b0111_0000,
3535
//remaining length
3636
0b0000_0010
3737
};
38-
private static final @NotNull byte[] MALFORMED_PUBCOMP_BEGIN_WRONG_FLAGS = {
38+
private static final byte @NotNull [] MALFORMED_PUBCOMP_BEGIN_WRONG_FLAGS = {
3939
// type, flags
4040
0b0111_0100,
4141
//remaining length
4242
0b0000_0010
4343
};
44-
private static final @NotNull byte[] MALFORMED_PUBCOMP_BEGIN_TOO_LONG_LENGTH = {
44+
private static final byte @NotNull [] MALFORMED_PUBCOMP_BEGIN_TOO_LONG_LENGTH = {
4545
// type, flags
4646
0b0111_0100,
4747
//remaining length
4848
0b0000_0011
4949
};
50-
private static final @NotNull byte[] ENDING_TOO_LONG_MALFORMED = {0x01};
51-
private static final @NotNull byte[] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
52-
private static final @NotNull byte[] MIN_PACKET_ID = {0x00, 0x00};
50+
private static final byte @NotNull [] ENDING_TOO_LONG_MALFORMED = {0x01};
51+
private static final byte @NotNull [] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
52+
private static final byte @NotNull [] MIN_PACKET_ID = {0x00, 0x00};
5353

5454
Mqtt3PubCompDecoderTest() {
5555
super(new MqttMessageDecoders() {{
@@ -72,19 +72,11 @@ void decode_SUCESS(final boolean useMaxPacketId) {
7272
@ParameterizedTest
7373
@ValueSource(strings = {"1", "2"})
7474
void decode_ERROR_CASES(final int errorcase) throws Exception {
75-
final byte[] encoded;
76-
switch (errorcase) {
77-
case 1:
78-
encoded = Bytes.concat(MALFORMED_PUBCOMP_BEGIN_WRONG_FLAGS, MAX_PACKET_ID);
79-
break;
80-
case 2:
81-
encoded =
82-
Bytes.concat(MALFORMED_PUBCOMP_BEGIN_TOO_LONG_LENGTH, MIN_PACKET_ID, ENDING_TOO_LONG_MALFORMED);
83-
break;
84-
default:
85-
throw new Exception();
86-
}
87-
75+
final byte[] encoded = switch (errorcase) {
76+
case 1 -> Bytes.concat(MALFORMED_PUBCOMP_BEGIN_WRONG_FLAGS, MAX_PACKET_ID);
77+
case 2 -> Bytes.concat(MALFORMED_PUBCOMP_BEGIN_TOO_LONG_LENGTH, MIN_PACKET_ID, ENDING_TOO_LONG_MALFORMED);
78+
default -> throw new Exception();
79+
};
8880
final ByteBuf byteBuf = channel.alloc().buffer();
8981
byteBuf.writeBytes(encoded);
9082
channel.writeInbound(byteBuf);

‎src/test/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt3/Mqtt3PubRecDecoderTest.java‎

Lines changed: 11 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -29,28 +29,28 @@
2929

3030
class Mqtt3PubRecDecoderTest extends AbstractMqtt3DecoderTest {
3131

32-
private static final @NotNull byte[] WELLFORMED_PUBREC_BEGIN = {
32+
private static final byte @NotNull [] WELLFORMED_PUBREC_BEGIN = {
3333
// type, flags
3434
0b0101_0000,
3535
//remaining length
3636
0b0000_0010
3737
};
38-
private static final @NotNull byte[] MALFORMED_PUBREC_BEGIN_WRONG_FLAGS = {
38+
private static final byte @NotNull [] MALFORMED_PUBREC_BEGIN_WRONG_FLAGS = {
3939
// type, flags
4040
0b0101_0100,
4141
//remaining length
4242
0b0000_0010
4343
};
4444

45-
private static final @NotNull byte[] MALFORMED_PUBREC_BEGIN_TOO_LONG_LENGTH = {
45+
private static final byte @NotNull [] MALFORMED_PUBREC_BEGIN_TOO_LONG_LENGTH = {
4646
// type, flags
4747
0b0101_0100,
4848
//remaining length
4949
0b0000_0001
5050
};
51-
private static final @NotNull byte[] ENDING_TOO_LONG_MALFORMED = {0x01};
52-
private static final @NotNull byte[] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
53-
private static final @NotNull byte[] MIN_PACKET_ID = {0x00, 0x00};
51+
private static final byte @NotNull [] ENDING_TOO_LONG_MALFORMED = {0x01};
52+
private static final byte @NotNull [] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
53+
private static final byte @NotNull [] MIN_PACKET_ID = {0x00, 0x00};
5454

5555
Mqtt3PubRecDecoderTest() {
5656
super(new MqttMessageDecoders() {{
@@ -73,19 +73,11 @@ void decode_SUCESS(final boolean useMaxPacketId) {
7373
@ParameterizedTest
7474
@ValueSource(strings = {"1", "2"})
7575
void decode_ERROR_CASES(final int errorcase) throws Exception {
76-
final byte[] encoded;
77-
switch (errorcase) {
78-
case 1:
79-
encoded = Bytes.concat(MALFORMED_PUBREC_BEGIN_WRONG_FLAGS, MAX_PACKET_ID);
80-
break;
81-
case 2:
82-
encoded =
83-
Bytes.concat(MALFORMED_PUBREC_BEGIN_TOO_LONG_LENGTH, MIN_PACKET_ID, ENDING_TOO_LONG_MALFORMED);
84-
break;
85-
default:
86-
throw new Exception();
87-
}
88-
76+
final byte[] encoded = switch (errorcase) {
77+
case 1 -> Bytes.concat(MALFORMED_PUBREC_BEGIN_WRONG_FLAGS, MAX_PACKET_ID);
78+
case 2 -> Bytes.concat(MALFORMED_PUBREC_BEGIN_TOO_LONG_LENGTH, MIN_PACKET_ID, ENDING_TOO_LONG_MALFORMED);
79+
default -> throw new Exception();
80+
};
8981
final ByteBuf byteBuf = channel.alloc().buffer();
9082
byteBuf.writeBytes(encoded);
9183
channel.writeInbound(byteBuf);

‎src/test/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt3/Mqtt3PubRelDecoderTest.java‎

Lines changed: 11 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -29,27 +29,27 @@
2929

3030
class Mqtt3PubRelDecoderTest extends AbstractMqtt3DecoderTest {
3131

32-
private static final @NotNull byte[] WELLFORMED_PUBREL_BEGIN = {
32+
private static final byte @NotNull [] WELLFORMED_PUBREL_BEGIN = {
3333
// type, flags
3434
0b0110_0010,
3535
//remaining length
3636
0b0000_0010
3737
};
38-
private static final @NotNull byte[] MALFORMED_PUBREL_BEGIN_WRONG_FLAGS = {
38+
private static final byte @NotNull [] MALFORMED_PUBREL_BEGIN_WRONG_FLAGS = {
3939
// type, flags
4040
0b0110_0100,
4141
//remaining length
4242
0b0000_0010
4343
};
44-
private static final @NotNull byte[] MALFORMED_PUBREL_BEGIN_TOO_LONG_LENGTH = {
44+
private static final byte @NotNull [] MALFORMED_PUBREL_BEGIN_TOO_LONG_LENGTH = {
4545
// type, flags
4646
0b0110_0100,
4747
//remaining length
4848
0b0000_0011
4949
};
50-
private static final @NotNull byte[] ENDING_TOO_LONG_MALFORMED = {0x01};
51-
private static final @NotNull byte[] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
52-
private static final @NotNull byte[] MIN_PACKET_ID = {0x00, 0x00};
50+
private static final byte @NotNull [] ENDING_TOO_LONG_MALFORMED = {0x01};
51+
private static final byte @NotNull [] MAX_PACKET_ID = {(byte) 0b1111_1111, (byte) 0b1111_1111};
52+
private static final byte @NotNull [] MIN_PACKET_ID = {0x00, 0x00};
5353

5454
Mqtt3PubRelDecoderTest() {
5555
super(new MqttMessageDecoders() {{
@@ -73,19 +73,11 @@ void decode_SUCESS(final boolean useMaxPacketId) {
7373
@ParameterizedTest
7474
@ValueSource(strings = {"1", "2"})
7575
void decode_ERROR_CASES(final int errorcase) throws Exception {
76-
final byte[] encoded;
77-
switch (errorcase) {
78-
case 1:
79-
encoded = Bytes.concat(MALFORMED_PUBREL_BEGIN_WRONG_FLAGS, MAX_PACKET_ID);
80-
break;
81-
case 2:
82-
encoded =
83-
Bytes.concat(MALFORMED_PUBREL_BEGIN_TOO_LONG_LENGTH, MIN_PACKET_ID, ENDING_TOO_LONG_MALFORMED);
84-
break;
85-
default:
86-
throw new Exception();
87-
}
88-
76+
final byte[] encoded = switch (errorcase) {
77+
case 1 -> Bytes.concat(MALFORMED_PUBREL_BEGIN_WRONG_FLAGS, MAX_PACKET_ID);
78+
case 2 -> Bytes.concat(MALFORMED_PUBREL_BEGIN_TOO_LONG_LENGTH, MIN_PACKET_ID, ENDING_TOO_LONG_MALFORMED);
79+
default -> throw new Exception();
80+
};
8981
final ByteBuf byteBuf = channel.alloc().buffer();
9082
byteBuf.writeBytes(encoded);
9183
channel.writeInbound(byteBuf);

‎src/test/java/com/hivemq/client/internal/mqtt/codec/decoder/mqtt3/Mqtt3PublishDecoderTest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ class Mqtt3PublishDecoderTest extends AbstractMqtt3DecoderTest {
4545
final boolean retained,
4646
final int packetId,
4747
final byte[] topic,
48-
final @NotNull byte[] payload) throws Exception {
48+
final byte @NotNull [] payload) throws Exception {
4949

5050
final ByteBuf byteBuf = channel.alloc().buffer();
5151

0 commit comments

Comments
 (0)