Mike Gerwitz

Activist for User Freedom

aboutsummaryrefslogtreecommitdiffstats
path: root/bin
diff options
context:
space:
mode:
authorMike Gerwitz <mike.gerwitz@ryansg.com>2019-12-09 11:40:02 -0500
committerAustin Schaffer <austin.schaffer@ryansg.com>2019-12-12 10:27:09 -0500
commit9d6cb23e161eb333b6a7cbc25fa6db03b1ac10dc (patch)
treec3cf1c73ea707eff43fa7ca518b8d3a52963f550 /bin
parentd9ee999adbfbd22ed7a9f67766d0ce243c30bd90 (diff)
downloadliza-9d6cb23e161eb333b6a7cbc25fa6db03b1ac10dc.tar.gz
liza-9d6cb23e161eb333b6a7cbc25fa6db03b1ac10dc.tar.bz2
liza-9d6cb23e161eb333b6a7cbc25fa6db03b1ac10dc.zip
AmqpConnection: Propagate assertExchange promise
Failures were being ignored.
Diffstat (limited to 'bin')
-rw-r--r--bin/delta-processor.ts3
1 files changed, 2 insertions, 1 deletions
diff --git a/bin/delta-processor.ts b/bin/delta-processor.ts
index 522b98b..e8a4a92 100644
--- a/bin/delta-processor.ts
+++ b/bin/delta-processor.ts
@@ -18,6 +18,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
+import * as amqplib from "amqplib";
import { createAmqpConfig } from '../src/system/AmqpPublisher';
import { MongoDeltaDao } from '../src/system/db/MongoDeltaDao';
import { DeltaProcessor } from '../src/system/DeltaProcessor';
@@ -48,7 +49,7 @@ const process_interval_ms = +( process.env.process_interval_ms || 2000 );
const env = process.env.NODE_ENV || 'Unknown Environment';
const emitter = new EventEmitter();
const log = new StandardLogger( console, ts_ctr, env );
-const amqp_connection = new AmqpConnection( amqp_conf, emitter );
+const amqp_connection = new AmqpConnection( amqplib, amqp_conf, emitter );
const publisher = new DeltaPublisher(
emitter,
ts_ctr,