projects
/
collectd.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
7554d50
)
amqp: new Queue{Durable,AutoDelete} options are subscribe-only options
author
Marc Fournier
<marc.fournier@camptocamp.com>
Tue, 24 Jun 2014 14:38:28 +0000
(16:38 +0200)
committer
Marc Fournier
<marc.fournier@camptocamp.com>
Tue, 24 Jun 2014 14:39:52 +0000
(16:39 +0200)
src/amqp.c
patch
|
blob
|
history
diff --git
a/src/amqp.c
b/src/amqp.c
index
3f33ff7
..
a1fb794
100644
(file)
--- a/
src/amqp.c
+++ b/
src/amqp.c
@@
-928,9
+928,9
@@
static int camqp_config_connection (oconfig_item_t *ci, /* {{{ */
status = cf_util_get_string (child, &conf->exchange_type);
else if ((strcasecmp ("Queue", child->key) == 0) && !publish)
status = cf_util_get_string (child, &conf->queue);
status = cf_util_get_string (child, &conf->exchange_type);
else if ((strcasecmp ("Queue", child->key) == 0) && !publish)
status = cf_util_get_string (child, &conf->queue);
- else if (
strcasecmp ("QueueDurable", child->key) == 0
)
+ else if (
(strcasecmp ("QueueDurable", child->key) == 0) && !publish
)
status = cf_util_get_boolean (child, &conf->queue_durable);
status = cf_util_get_boolean (child, &conf->queue_durable);
- else if (
strcasecmp ("QueueAutoDelete", child->key) == 0
)
+ else if (
(strcasecmp ("QueueAutoDelete", child->key) == 0) && !publish
)
status = cf_util_get_boolean (child, &conf->queue_auto_delete);
else if (strcasecmp ("RoutingKey", child->key) == 0)
status = cf_util_get_string (child, &conf->routing_key);
status = cf_util_get_boolean (child, &conf->queue_auto_delete);
else if (strcasecmp ("RoutingKey", child->key) == 0)
status = cf_util_get_string (child, &conf->routing_key);