amqp plugin: Use "service_name_to_port_number" to parse the "Port" config option.

diff --git a/src/amqp.c b/src/amqp.c
index 23526e2eb1c820196c03c57aca0bfb6e611936b7..95cded7a42d4da97e97dc93e2f0bab644c28ec90 100644 (file)
--- a/src/amqp.c
+++ b/src/amqp.c
@@ -82,7 +82,17 @@ static int config(const char *key, const char *value)
         return (config_set(&host, value));
     else if(strcasecmp(key, "port") == 0)
     {
-        port = atoi(value);
+        int tmp;
+
+        tmp = service_name_to_port_number (value);
+        if (tmp <= 0)
+        {
+            ERROR ("AMQP plugin: Cannot parse `%s' as a "
+                    "service name (port number).", value);
+            return (1);
+        }
+
+        port = tmp;
         return (0);
     }
     else if (strcasecmp(key, "vhost") == 0)