private void contentHeaderReceived(int channelId, ContentHeaderBody body) throws AMQException
{
AMQChannel channel = getAndAssertChannel(channelId);
channel.publishContentHeader(body, this);
}
private void contentBodyReceived(int channelId, ContentBody body) throws AMQException
{