diff --git a/rabbitmq_consumer/CMakeLists.txt b/rabbitmq_consumer/CMakeLists.txt index 02e0e7125..30d16d630 100644 --- a/rabbitmq_consumer/CMakeLists.txt +++ b/rabbitmq_consumer/CMakeLists.txt @@ -20,9 +20,6 @@ link_directories(${CMAKE_SOURCE_DIR}/inih) if(RABBITMQ_C_LIBRARIES AND MYSQL_LIBRARIES AND MYSQL_INCLUDE_DIRS) -add_definitions(-DCONFIG_IN_ETC) -add_definitions(-DCONSUMER_CONFIG_PREFIX="${CMAKE_INSTALL_PREFIX}/share/consumer") - add_executable (consumer consumer.c ${MYSQL_LIBRARIES} ${RABBITMQ_C_LIBRARIES}) target_link_libraries(consumer mysqlclient) target_link_libraries(consumer rabbitmq) diff --git a/rabbitmq_consumer/consumer.c b/rabbitmq_consumer/consumer.c index defdbaa81..8ccabf401 100644 --- a/rabbitmq_consumer/consumer.c +++ b/rabbitmq_consumer/consumer.c @@ -12,15 +12,6 @@ #include #include #include -#ifdef CONFIG_IN_ETC -#define CONFIG 1 -#else -#define CONFIG 0 -#endif - -#ifndef CONSUMER_CONFIG_PREFIX -#define CONSUMER_CONFIG_PREFIX "/usr/share/consumer" -#endif typedef struct delivery_t { @@ -346,7 +337,11 @@ int main(int argc, char** argv) MYSQL db_inst; char ch, *cnfname = NULL, *cnfpath = NULL; static const char* fname = "consumer.cnf"; - static const char* fprefix = CONSUMER_CONFIG_PREFIX; + + if((c_inst = calloc(1,sizeof(CONSUMER))) == NULL){ + fprintf(stderr, "Fatal Error: Cannot allocate enough memory.\n"); + return 1; + } if(signal(SIGINT,sighndl) == SIG_IGN){ signal(SIGINT,SIG_IGN); @@ -374,16 +369,7 @@ int main(int argc, char** argv) strcat(cnfname,"/"); } - }else if(CONFIG){ - - /**Config file location was set at install*/ - strcat(cnfname,fprefix); - if(cnfname[strlen(cnfname) - 1] != '/'){ - strcat(cnfname,"/"); - } - - } - + } strcat(cnfname,fname); @@ -392,17 +378,14 @@ int main(int argc, char** argv) all_ok = 1; out_fd = NULL; - if((c_inst = calloc(1,sizeof(CONSUMER))) == NULL){ - fprintf(stderr, "Fatal Error: Cannot allocate enough memory.\n"); - return 1; - } + /**Parse the INI file*/ if(ini_parse(cnfname,handler,NULL) < 0){ /**Try to parse a config in the same directory*/ if(ini_parse(fname,handler,NULL) < 0){ - fprintf(out_fd, "Fatal Error: Error parsing configuration file!\n"); + fprintf(stderr, "Fatal Error: Error parsing configuration file!\n"); goto fatal_error; } @@ -514,8 +497,11 @@ int main(int argc, char** argv) amqp_connection_close(conn, AMQP_REPLY_SUCCESS); amqp_destroy_connection(conn); fatal_error: - - fclose(out_fd); + + if(out_fd){ + fclose(out_fd); + } + if(c_inst){