17 Commits

Author SHA1 Message Date
William King
b5301688d7 FS-8306 Now command queues can specify the queue to subscribe to. This enables very interesting use cases that would involve single job queue, and multiple consumers. 2015-10-10 16:39:53 -07:00
William King
ba63cc4574 FS-8306 #resolve if the exchange doesn't exist, then create it, else
fail. This resolves several error cases.
2015-10-10 16:30:28 -07:00
William King
444b9152b2 FS-8329 #resolve Also fixes default configs to keep in line with a change made for Fs-7806 FS-7803 2015-10-10 15:38:06 -07:00
Luis Azedo
4114c1d59a FS-7806 FS-7803 #resolve
added new properties to amqp configuration
fixed - enable_fallback_format_fields usage, only worked on first event
added amqp_util_encode to fix routing key
2015-08-03 13:25:28 +01:00
William King
9410d7c602 FS-7623 Fix param name ordering bug in mod_amqp due to exposing these params 2015-06-11 12:33:16 -07:00
William King
257bb5c655 FS-7623 allow for custom exchange name and type for mod_amqp producers 2015-06-08 20:33:16 -07:00
William King
6484c6fc0a FS-7622 make sure to close the connections on destroy. Currently the connection is malloc'd from the module pool, so there is nothing to destroy. 2015-06-08 20:28:38 -07:00
William King
346f6cb6af FS-7552 #resolve 2015-05-13 15:56:18 -07:00
William King
15d8821ede FS-7060: On first startup, on a clean platform, make sure to create the amqp exchange. 2015-05-04 21:36:15 -07:00
William King
d3bac671d2 FS-7526: add enable_fallback_format_fields for mod_amqp producer profiles if the profile param is set. 2015-05-03 11:23:30 -07:00
William King
b01352c133 Fixing a typo from a last minute refactor after fixing a bug 2015-04-22 21:33:08 -07:00
William King
777c1154ee Additional fix for error case when connection succeeds, but login fails 2015-04-19 19:11:47 -07:00
William King
c620ee32c7 If we lost connection and can't reconnect, make sure to set active connection to NULL 2015-04-19 18:43:03 -07:00
William King
b51c054474 FS-7060 add configuration of the amqp command binding key 2015-04-08 16:04:00 -07:00
William King
d55c4a053b FS-7060 expanded configuration for amqp command configuration 2015-04-07 16:11:34 -07:00
William King
7b6a9efcaa FS-7060 More accurate logging, and improve handling of producer reconnect attempt interval 2015-04-07 10:52:30 -07:00
William King
1a96f23f27 Adding mod_amqp as an event_handler module
AMQP(Advanced Message Queueing Protocol) is an event bus protocol
with more info here http://www.amqp.org/about/what

mod_amqp implements the client side of the amqp protocol. Currently
the module supports two separate, but not mutually exclusive usages:

1. Sending a filtered whitelist of events to an AMQP server. The
before the events are sent an amqp routing header is generated so that
downstream subscriptions can subscribe using filters. If the
connection to the remote server is interrupted, the module will
attempt to reconnect.

2. Subscribing to a 'control' channel on the remote AMQP server. When
events are received on this channel if they match a configured filter,
the commands are run locally as api commands. If the filter for the
events being sent to the remote AMQP server include SWITCH_EVENT_API
then the results of the api commands will be sent back to the AMQP
server.

FS-7060 #resolve
Thanks-to: Daniel Bryars <danb@aeriandi.com> and Tim Brown <tim.brown@aeriandi.com>
2015-04-03 15:34:09 -07:00