/**
 * XadillaX created at 2015-12-18 17:24:31 With ♥
 *
 * Copyright (c) 2017 Souche.com, all rights
 * reserved.
 */
"use strict";

var config = require("../test/_config");
var Consumer = require("../lib/consumer");

if(process.env.NODE_ONS_LOG === "true") {
    require("../lib/orig_log").on("data", function(data) {
        console.log("[ORIG]", data);
    });
}

var consumer = new Consumer(
    config.consumerId,
    config.topic,
    "*",
    config.accessKey,
    config.secretKey, {
        onsAddr: "http://onsaddr-internet.aliyun.com:80/rocketmq/nsaddr4client-internet",
        threadNum: 10
    });

var consumed = 0;
consumer.on("message", function(message, ack) {
    console.log(message, ++consumed);
    ack.done();
});

consumer.on("error", function(err) {
    console.log(err);
});

console.log("Connecting to Aliyun ONS...");
consumer.init(function() {
    console.log("Initialized.");
    consumer.listen();
    console.log("Listened.");
});

process.on("SIGINT", function() {
    consumer.stop(function() {
        process.exit(0);
    });
});