//get initialization parameters from env, docker env parameters have priority
var rabbitUrl = process.env.RABBITMQ_PORT_5672_TCP_ADDR ? "amqp://#{process.env.RABBITMQ_PORT_5672_TCP_ADDR}:#{process.env.RABBITMQ_PORT_5672_TCP_PORT}" : process.env.RABBITMQ_URI;
var rabbitQueue = process.env.RABBITMQ_QUEUE;


var pubHub = new pubSub.PubSubRabbit();


var mongoUrl = process.env.MONGO_PORT_27017_TCP_ADDR ?
  "mongodb://#{process.env.MONGO_PORT_27017_TCP_ADDR}:#{process.env.MONGO_PORT_27017_TCP_PORT}" :
  process.env.MONGO_LOG_URI;
var log = new logger.LoggerCompose(
  {pack: require("../package.json"), tags: ["trader"]},
  {
    loggly: {token: process.env.LOGGLY_KEY, subdomain: process.env.LOGGLY_SUBDOMAIN},
    mongo: {connection: mongoUrl, collection: process.env.MONGO_LOG_COLLECTION},
    console: true
  }
);

log.write({oper: "app_start", status: "success"});

var promise = Promise.resolve();

promise.then(() => {
    pubHub.connect({
      uri: rabbitUrl,
      queue: rabbitQueue,
      type: pubSub.PubSubTypes.pub
    });
  }

 }, (err) => {
   log.write({oper: "amqp_connected", status: "error", error: err, queue: rabbitQueue, type : "pub"});
 }

).then(() => {
        log.write({oper: "amqp_connected", status: "success", queue: rabbitQueue});
    }, (err) => {

function onHandle(cmd) {
    if (cmd.extit) onExit(cmd);
    log.write({oper: "handle", status: "start", cmd: cmd});
    //insert you handle logic here
    handler.handle(null);
}

function onExit(res) {
    log.write({oper: "app_stop", status: "success", res: res});
    subHub.close();
}