commit 14845bc8e59eb132dcfb6616d74dde9978d82dc0
author jan kaufman <jan.kaufman@tcpcloud.eu> Wed Nov 04 16:23:00 2015 +0100
committer jan kaufman <jan.kaufman@tcpcloud.eu> Wed Nov 04 16:23:00 2015 +0100
tree 9545b9ce03770e80b6bdbd85c4e672abc368ed59
parent 4827485ea79a26ad8010f9c79cc42d591de3e22a

add prefetch_count for amqp input

metadata/service/server/amqp/router.yml

diff --git a/metadata/service/server/amqp/router.yml b/metadata/service/server/amqp/router.yml
index 3cc679f..5d910b2 100644
--- a/metadata/service/server/amqp/router.yml
+++ b/metadata/service/server/amqp/router.yml
@@ -14,6 +14,7 @@
           vhost: ${_param:heka_router_input_vhost}
           port: 5672
           exchange: ${_param:heka_router_input_exchange}
+          prefetch_count: ${_param:heka_router_input_prefetch_count}
           exchange_type: fanout
           decoder: ProtoBufDecoder
           splitter: HekaFramingSplitter