Commit Graph

15 Commits

Author SHA1 Message Date
Daniel Nelson
e141518cf0 Support passive queue declaration in amqp_consumer (#5831) 2019-05-20 14:38:35 -07:00
Daniel Nelson
b5cd9a9ff2 Add support for gzip compression to amqp plugins (#5830) 2019-05-20 14:36:23 -07:00
Daniel Nelson
193aba8673 Ack delivery if it is unparseable in amqp_consumer input (#5286) 2019-01-15 11:48:36 -08:00
Daniel Nelson
6e5c2f8bb6 Remove outputs blocking inputs when output is slow (#4938) 2018-11-05 13:34:28 -08:00
Andrew
a47149765e Add queue_durability parameter to amqp_consumer input (#4628) 2018-09-05 14:27:52 -07:00
Daniel Nelson
a04cfee349 Fix incorrect option name in amqp sample configuration 2018-06-03 18:42:08 -07:00
Daniel Nelson
da6ad34fc8 Add option to disconnect after a message limit is reached in amqp output 2018-06-03 18:35:59 -07:00
Daniel Nelson
179bcfdcbb Use list of brokers in amqp output and amqp_consumer 2018-06-03 18:35:59 -07:00
Daniel Nelson
e3f1d28908 Allow configuration of amqp exchange type, durability, and arguments 2018-06-03 18:35:59 -07:00
Mike Gent
312116c101 Add passive mode exchange declaration option to amqp consumer input (#3995) 2018-06-03 15:52:59 -07:00
Daniel Nelson
de355b76d6 Simplify testing with TLS (#4095) 2018-05-04 16:33:23 -07:00
rabhis
5be1198274 Reconnect AMQP consumer to broker (#3947) 2018-03-28 14:00:56 -07:00
Daniel Nelson
656ce31d98 Fix amqp_consumer data_format documentation
closes #3164
2017-08-24 13:17:29 -07:00
Daniel Nelson
052e88ad5e Fix grammar 2017-04-27 14:59:18 -07:00
Jack Zampolin
10744646db AMQP Consumer plugin (#1678) 2017-03-03 10:24:50 -08:00