X-Git-Url: https://git.verplant.org/?a=blobdiff_plain;f=src%2Famqp.c;h=bf0f80f58498867db94f5d4534e343aba3eec001;hb=30245d7b0ad267604d3675cfba66c2eda775e236;hp=ab920a6a6dbe24ab8fa5c3599c9a284fc92c7a4c;hpb=fd7673e5e9ad074624fc23cda5d2ec4549d43659;p=collectd.git diff --git a/src/amqp.c b/src/amqp.c index ab920a6a..bf0f80f5 100644 --- a/src/amqp.c +++ b/src/amqp.c @@ -299,6 +299,10 @@ static int camqp_create_exchange (camqp_config_t *conf) /* {{{ */ /* type = */ amqp_cstring_bytes (conf->exchange_type), /* passive = */ 0, /* durable = */ 0, +#if defined(AMQP_VERSION) && AMQP_VERSION >= 0x00060000 + /* auto delete = */ 0, + /* internal = */ 0, +#endif /* arguments = */ argument_table); if ((ed_ret == NULL) && camqp_is_error (conf)) { @@ -692,7 +696,7 @@ static void *camqp_subscribe_thread (void *user_data) /* {{{ */ continue; } - status = camqp_read_header (conf); + camqp_read_header (conf); amqp_maybe_release_buffers (conf->connection); } /* while (subscriber_threads_running) */