}
private ByteBuffer createEncodedGetOkFrame(AMQMessage message, int channelId, long deliveryTag, int queueSize)
throws AMQException
{
final MessagePublishInfo pb = message.getMessagePublishInfo();
final AMQMessageHandle messageHandle = message.getMessageHandle();
AMQFrame getOkFrame = BasicGetOkBody.createAMQFrame(channelId,
getProtocolMajorVersion(),
getProtocolMinorVersion(),
deliveryTag, pb.getExchange(),
queueSize,
messageHandle.isRedelivered(),
pb.getRoutingKey());
return getOkFrame.toByteBuffer();
}