public class BrokerDecoder extends ServerDecoder
Constructor and Description |
---|
BrokerDecoder(AMQPConnection_0_8 connection)
Creates a new AMQP decoder.
|
Modifier and Type | Method and Description |
---|---|
protected void |
processFrame(int channelId,
byte type,
long bodySize,
MarkableDataInput in) |
decodeBuffer
decode, getMethodProcessor, setExpectProtocolInitiation, setMaxFrameSize
public BrokerDecoder(AMQPConnection_0_8 connection)
connection
- protected void processFrame(int channelId, byte type, long bodySize, MarkableDataInput in) throws AMQFrameDecodingException, IOException
processFrame
in class AMQDecoder<ServerMethodProcessor<? extends ServerChannelMethodProcessor>>
AMQFrameDecodingException
IOException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.