File tree Expand file tree Collapse file tree 1 file changed +16
-0
lines changed
src/main/java/com/rabbitmq/client/impl Expand file tree Collapse file tree 1 file changed +16
-0
lines changed Original file line number Diff line number Diff line change @@ -164,6 +164,9 @@ static Object readFieldValue(DataInputStream in)
164
164
case 'I' :
165
165
value = in .readInt ();
166
166
break ;
167
+ case 'i' :
168
+ value = readUnsignedInt (in );
169
+ break ;
167
170
case 'D' :
168
171
int scale = in .readUnsignedByte ();
169
172
byte [] unscaled = new byte [4 ];
@@ -213,6 +216,19 @@ static Object readFieldValue(DataInputStream in)
213
216
return value ;
214
217
}
215
218
219
+ /** Read an unsigned int */
220
+ private static long readUnsignedInt (DataInputStream in )
221
+ throws IOException
222
+ {
223
+ long ch1 = in .read ();
224
+ long ch2 = in .read ();
225
+ long ch3 = in .read ();
226
+ long ch4 = in .read ();
227
+ if ((ch1 | ch2 | ch3 | ch4 ) < 0 )
228
+ throw new EOFException ();
229
+ return ((ch1 << 24 ) + (ch2 << 16 ) + (ch3 << 8 ) + ch4 );
230
+ }
231
+
216
232
/** Read a field-array */
217
233
private static List <Object > readArray (DataInputStream in )
218
234
throws IOException
You can’t perform that action at this time.
0 commit comments