diff options
| author | Mike Gerwitz <mike.gerwitz@ryansg.com> | 2019-12-09 11:40:02 -0500 |
|---|---|---|
| committer | Austin Schaffer <austin.schaffer@ryansg.com> | 2019-12-12 10:27:09 -0500 |
| commit | 9d6cb23e161eb333b6a7cbc25fa6db03b1ac10dc (patch) | |
| tree | c3cf1c73ea707eff43fa7ca518b8d3a52963f550 /bin | |
| parent | d9ee999adbfbd22ed7a9f67766d0ce243c30bd90 (diff) | |
| download | liza-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.ts | 3 |
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, |