@Test public void testSkipValue() { final DecoderImpl decoder = new DecoderImpl(); final EncoderImpl encoder = new EncoderImpl(decoder); AMQPDefinedTypes.registerAllTypes(decoder, encoder); final ByteBuffer buffer = ByteBuffer.allocate(64); decoder.setByteBuffer(buffer); encoder.setByteBuffer(buffer); encoder.writeUnsignedLong(UnsignedLong.ZERO); encoder.writeUnsignedLong(UnsignedLong.valueOf(1)); buffer.clear(); TypeConstructor<?> type = decoder.readConstructor(); assertEquals(UnsignedLong.class, type.getTypeClass()); type.skipValue(); UnsignedLong result = decoder.readUnsignedLong(); assertEquals(UnsignedLong.valueOf(1), result); }
public Class<UnsignedLong> getTypeClass() { return UnsignedLong.class; }
UnsignedLongType extends AbstractPrimitiveType<UnsignedLong> { public Class<UnsignedLong> getTypeClass() { return UnsignedLong.class; } }
UnsignedLongType extends AbstractPrimitiveType<UnsignedLong> { public Class<UnsignedLong> getTypeClass() { return UnsignedLong.class; } UnsignedLongType(final EncoderImpl encoder, final DecoderImpl decoder); }
UnsignedLongType extends AbstractPrimitiveType<UnsignedLong> { public Class<UnsignedLong> getTypeClass() { return UnsignedLong.class; } UnsignedLongType(final EncoderImpl encoder, final DecoderImpl decoder); Class<UnsignedLong> getTypeClass(); UnsignedLongEncoding getEncoding(final UnsignedLong val); void fastWrite(EncoderImpl encoder, UnsignedLong value); UnsignedLongEncoding getCanonicalEncoding(); Collection<UnsignedLongEncoding> getAllEncodings(); }
UnsignedLongType extends AbstractPrimitiveType<UnsignedLong> { public Class<UnsignedLong> getTypeClass() { return UnsignedLong.class; } UnsignedLongType(final EncoderImpl encoder, final DecoderImpl decoder); Class<UnsignedLong> getTypeClass(); UnsignedLongEncoding getEncoding(final UnsignedLong val); void fastWrite(EncoderImpl encoder, UnsignedLong value); UnsignedLongEncoding getCanonicalEncoding(); Collection<UnsignedLongEncoding> getAllEncodings();  }