Fixed typo

Author: zubairov

lib/actions/publish.js

@@ -1,10 +1,9 @@
 'use strict';
-const eioUtils = require('elasticio-node').messages;
 const co = require('co');
 const amqp = require('amqplib');
 const encryptor = require('../encryptor.js');
 
-var connection, channel;
+var conn, channel;
 
 module.exports.process = processAction;
 
@@ -20,9 +19,9 @@ function processAction(msg, cfg, snapshot) {
   const amqpURI = process.env.ELASTICIO_AMQP_URI;
   const amqpExchange = `pubsub_${process.env.ELASTICIO_TASK_ID}_${process.env.ELASTICIO_USER_ID}`;
   co(function*() {
-    if (!connection) {
+    if (!conn) {
       console.log('Connecting to amqpURI=%s', amqpURI);
-      connection = yield amqp.connect(amqpURI);
+      conn = yield amqp.connect(amqpURI);
     }
     if (!channel) {
       console.log('Creating a confirm channel');