forked from wallabag/wallabag
Added QoS for RabbitMQ
This commit is contained in:
committed by
Jeremy Benoist
parent
24becc9717
commit
99712e5d85
@ -300,6 +300,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.pocket'
|
name: 'wallabag.import.pocket'
|
||||||
callback: wallabag_import.consumer.amqp.pocket
|
callback: wallabag_import.consumer.amqp.pocket
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_readability:
|
import_readability:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -308,6 +309,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.readability'
|
name: 'wallabag.import.readability'
|
||||||
callback: wallabag_import.consumer.amqp.readability
|
callback: wallabag_import.consumer.amqp.readability
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_instapaper:
|
import_instapaper:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -316,6 +318,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.instapaper'
|
name: 'wallabag.import.instapaper'
|
||||||
callback: wallabag_import.consumer.amqp.instapaper
|
callback: wallabag_import.consumer.amqp.instapaper
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_pinboard:
|
import_pinboard:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -324,6 +327,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.pinboard'
|
name: 'wallabag.import.pinboard'
|
||||||
callback: wallabag_import.consumer.amqp.pinboard
|
callback: wallabag_import.consumer.amqp.pinboard
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_wallabag_v1:
|
import_wallabag_v1:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -332,6 +336,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.wallabag_v1'
|
name: 'wallabag.import.wallabag_v1'
|
||||||
callback: wallabag_import.consumer.amqp.wallabag_v1
|
callback: wallabag_import.consumer.amqp.wallabag_v1
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_wallabag_v2:
|
import_wallabag_v2:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -340,6 +345,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.wallabag_v2'
|
name: 'wallabag.import.wallabag_v2'
|
||||||
callback: wallabag_import.consumer.amqp.wallabag_v2
|
callback: wallabag_import.consumer.amqp.wallabag_v2
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_firefox:
|
import_firefox:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -348,6 +354,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.firefox'
|
name: 'wallabag.import.firefox'
|
||||||
callback: wallabag_import.consumer.amqp.firefox
|
callback: wallabag_import.consumer.amqp.firefox
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
import_chrome:
|
import_chrome:
|
||||||
connection: default
|
connection: default
|
||||||
exchange_options:
|
exchange_options:
|
||||||
@ -356,6 +363,7 @@ old_sound_rabbit_mq:
|
|||||||
queue_options:
|
queue_options:
|
||||||
name: 'wallabag.import.chrome'
|
name: 'wallabag.import.chrome'
|
||||||
callback: wallabag_import.consumer.amqp.chrome
|
callback: wallabag_import.consumer.amqp.chrome
|
||||||
|
qos_options: {prefetch_count: 10}
|
||||||
|
|
||||||
fos_js_routing:
|
fos_js_routing:
|
||||||
routes_to_expose:
|
routes_to_expose:
|
||||||
|
|||||||
Reference in New Issue
Block a user