AMQPObject.m

//
//  AMQPObject.m
//  This file is part of librabbitmq-objc.
//  Copyright (C) 2014 *Prof. MAAD* aka Max Wolter
//  librabbitmq-objc is released under the terms of the GNU Lesser General Public License Version 3.
//
//  This program is free software: you can redistribute it and/or modify
//  it under the terms of the GNU Lesser General Public License as published by
//  the Free Software Foundation, either version 3 of the License, or
//  (at your option) any later version.
//  
//  This program is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU Lesser General Public License for more details.
//  
//  You should have received a copy of the GNU Lesser General Public License
//  along with this program.  If not, see <http://www.gnu.org/licenses/>.

#import "AMQPObject.h"

# import <stdio.h>
# import <amqp.h>
# import <amqp_framing.h>

# define AMQP_BYTES_TO_NSSTRING(x) [[NSString alloc] initWithBytes:x.bytes length:x.len encoding:NSUTF8StringEncoding]

@implementation AMQPObject

- (NSString*)errorDescriptionForReply:(amqp_rpc_reply_t)reply
{
	switch (reply.reply_type)
	{
		case AMQP_RESPONSE_NORMAL:
			return @"";
			break;
		case AMQP_RESPONSE_NONE:
			return @"missing RPC reply type";
			break;
			
		case AMQP_RESPONSE_LIBRARY_EXCEPTION:
			if(reply.library_errno)
			{
				return [NSString stringWithUTF8String:strerror(reply.library_errno)];
			}
			else
			{
				return @"(end-of-stream)";
			}
			break;
		case AMQP_RESPONSE_SERVER_EXCEPTION:
			switch (reply.reply.id)
			{
				case AMQP_CONNECTION_CLOSE_METHOD:
				{
					amqp_connection_close_t *connectionClose = (amqp_connection_close_t *) reply.reply.decoded;
					return AMQP_BYTES_TO_NSSTRING(connectionClose->reply_text);
					break;
				}
				case AMQP_CHANNEL_CLOSE_METHOD:
				{
					amqp_channel_close_t *channelClose = (amqp_channel_close_t *) reply.reply.decoded;
					return AMQP_BYTES_TO_NSSTRING(channelClose->reply_text);
					break;
				}
				default:
					return [NSString stringWithFormat:@"unknown error %d", reply.reply.id];
					break;
			}
			break;
	}
}

@end