AMQPObject.m

//
//  AMQPUtils.c
//  Objective-C wrapper for librabbitmq-c
//
//  Copyright 2009 Max Wolter. All rights reserved.
//  This program is free software: you can redistribute it and/or modify
//  it under the terms of the GNU 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 General Public License for more details.
//
//  You should have received a copy of the GNU General Public License
//  along with this program.  If not, see <http://www.gnu.org/licenses/>.
//

#import "AMQPObject.h"

#import <stdio.h>

@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: {
            return [NSString stringWithUTF8String:amqp_error_string2(reply.library_error)];
			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 [[NSString alloc] initWithBytes:connectionClose->reply_text.bytes
                                                    length:connectionClose->reply_text.len
                                                  encoding:NSUTF8StringEncoding];
                    break;
                }
                case AMQP_CHANNEL_CLOSE_METHOD: {
                    amqp_channel_close_t *channelClose = (amqp_channel_close_t *) reply.reply.decoded;
                    return [[NSString alloc] initWithBytes:channelClose->reply_text.bytes
                                                    length:channelClose->reply_text.len
                                                  encoding:NSUTF8StringEncoding];
                    break;
                }
                default:
                    return [NSString stringWithFormat:@"unknown error %u", reply.reply.id];
                    break;
            }
			break;
        }
            
        default:
            break;
	}
}

@end