10 Commits (84c2601f1c8a0ac97ce6c35b05c913521ba47a89)

Author	SHA1	Message	Date
Mike Gerwitz	e885026e0a	DeltaPublisher: Remove parsing from constructor	2019-12-12 10:27:09 -05:00
Mike Gerwitz	9d6cb23e16	AmqpConnection: Propagate assertExchange promise ... Failures were being ignored.	2019-12-12 10:27:09 -05:00
Austin Schaffer	d9ee999adb	[DEV-5312] Refactor class dependencies ... Move create config functions out of the main delta-processor.ts file. Change some any types to more specific types. Define document structure better. Move prometheus logic out of processor class. Do not call logger directly, listen for events and log them. Change logger to more PSR-3 compliant style. Extract amqp connection into its own class. Create avro and mongo objects in factory.	2019-12-12 10:14:54 -05:00
Austin Schaffer	1ddb6f29eb	[DEV-5312] Add logic to apply delta to bucket then publish modified bucket	2019-12-12 10:13:27 -05:00
Austin Schaffer	1b96cd9147	[DEV-5312] Refactor references from 'self' to 'this', pass console into event logger, and add factory for prometheus	2019-12-12 10:10:45 -05:00
Austin Schaffer	5ee9a5d340	[DEV-5312] Generalize event subscribers and dispatchers	2019-11-25 12:42:03 -05:00
Austin Schaffer	e781a841b1	[DEV-5312] Reconnect AMQP when connection drops	2019-11-25 12:26:39 -05:00
Austin Schaffer	faa7e15760	[DEV-5312] Add signal handling and prometheus monitoring	2019-11-22 16:37:57 -05:00
Austin Schaffer	9b5cd4e89f	[DEV-5312] Call data-processor and instantiate classes	2019-11-20 09:48:28 -05:00
Mike Gerwitz	e450bbb3d6	bin/delta-processor: Placeholder script	2019-11-11 16:53:58 -05:00