public class AmqpDecoder<T> extends AbstractMessageDecoder<T>
Constructor and Description |
---|
AmqpDecoder(AmqpMessageDecoder<T> decoder) |
Modifier and Type | Method and Description |
---|---|
T |
decode(java.io.InputStream is) |
public AmqpDecoder(AmqpMessageDecoder<T> decoder)
public T decode(java.io.InputStream is) throws java.io.IOException
java.io.IOException