throw body.getConnectionException(AMQConstant.ACCESS_REFUSED, e.getMessage());
}
MethodRegistry methodRegistry = protocolConnection.getMethodRegistry();
QueueDeleteOkBody responseBody = methodRegistry.createQueueDeleteOkBody(purged);
protocolConnection.writeFrame(responseBody.generateFrame(channelId));
}
}
}
}