refactor: update copyright header

.gitignore

@@ -46,3 +46,4 @@ Release
 note.txt
 
 test/_config.js
+tags

lib/consumer.js

@@ -29,6 +29,7 @@ var _Consumer = require("../build/Release/ons").ONSConsumer;
  * @param {String} [options.namesrvAddr] the ONS server address
  * @param {Number} [options.threadNum] the thread count
  * @param {Number} [options.sendTimeout] the send timeout (ms)
+ * @param {Boolean} [options.order] whether it will be `OrderConsumer`
  * @constructor
  */
 var Consumer = function ONSConsumer(cid, topic, tag, accessKey, secretKey, options) {
@@ -75,7 +76,8 @@ var Consumer = function ONSConsumer(cid, topic, tag, accessKey, secretKey, optio
 util.inherits(Consumer, EventEmitter);
 
 /**
- * init
+ * Initialize for the consumer
+ *
  * @param {Function} callback the callback function
  */
 Consumer.prototype.init = function(callback) {
@@ -104,7 +106,7 @@ Consumer.prototype.init = function(callback) {
 };
 
 /**
- * listen
+ * Start to listen to the queue
  */
 Consumer.prototype.listen = function() {
     this.consumer.listen();
@@ -117,7 +119,9 @@ Consumer.prototype.listen = function() {
 };
 
 /**
- * stop
+ * Stop the consumer
+ *
+ * @param {Function} callback the callback function
  */
 Consumer.prototype.stop = function(callback) {
     if(this.keepTimer) {

lib/producer.js

@@ -27,7 +27,7 @@ var __ORDER_PARSER = "parseOrderSendArguments";
  * @param {Object} [options] the options
  * @param {String} [options.onsAddr] the fetching ONS server address
  * @param {String} [options.namesrvAddr] the ONS server address
- * @param {Boolean} [options.order] whether use order producer
+ * @param {Boolean} [options.order] whether it will be `OrderProducer`
  * @constructor
  */
 var Producer = function ONSProducer(producerId, accessKey, secretKey, options) {
@@ -63,7 +63,8 @@ var Producer = function ONSProducer(producerId, accessKey, secretKey, options) {
 };
 
 /**
- * start
+ * Start the producer
+ *
  * @param {Function} callback the callback function
  */
 Producer.prototype.start = function(callback) {
@@ -80,7 +81,9 @@ Producer.prototype.start = function(callback) {
 };
 
 /**
- * stop
+ * Stop the producer
+ *
+ * @param {Function} callback the callback function
  */
 Producer.prototype.stop = function(callback) {
     if(this.keepTimer) {

src/consumer.cpp

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer.cpp
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  ONS consumer wrapper for node.js
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2015/12/18 13时23分04秒
- *       Revision:  none
- *       Compiler:  g++
- *
- *         Author:  XadillaX (ZKD), zhukaidi@souche.com
- *   Organization:  Design & Development Center, Souche Car Service Co., Ltd, HANGZHOU
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #include "log_util.h"
 #include "consumer.h"
@@ -40,6 +43,7 @@ ONSConsumerV8::ONSConsumerV8(
     tag(_tag),
     access_key(_access_key),
     secret_key(_secret_key),
+    is_order(false),
 
     initializing(false),
     inited(false),
@@ -48,8 +52,7 @@ ONSConsumerV8::ONSConsumerV8(
     real_consumer(NULL),
     listener(NULL),
 
-    listener_func(),
-    is_order(false)
+    listener_func()
 {
     Nan::HandleScope scope;
 

src/consumer.h

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer.h
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  ONS consumer wrapper for node.js
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2015/12/18 13时25分31秒
- *       Revision:  none
- *       Compiler:  g++
- *
- *         Author:  XadillaX (ZKD), zhukaidi@souche.com
- *   Organization:  Design & Development Center, Souche Car Service Co., Ltd, HANGZHOU
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #ifndef __ONS_CONSUMER_H__
 #define __ONS_CONSUMER_H__

src/consumer_ack.cpp

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer_ack.cpp
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  ONS consumer ACK wrapper for node.js
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2016/01/25 11时37分20秒
- *       Revision:  none
- *       Compiler:  gcc
- *
- *         Author:  XadillaX (ZKD), zhukaidi@souche.com
- *   Organization:  Design & Development Center, Souche Car Service Co., Ltd, HANGZHOU
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #include "consumer_ack.h"
 

src/consumer_ack.h

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer_ack.h
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  ONS consumer ACK wrapper for node.js
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2016/01/25 11时16分17秒
- *       Revision:  none
- *       Compiler:  g++
- *
- *         Author:  XadillaX (ZKD), zhukaidi@souche.com
- *   Organization:  Design & Development Center, Souche Car Service Co., Ltd, HANGZHOU
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #ifndef __ONS_CONSUMER_ACK_H__
 #define __ONS_CONSUMER_ACK_H__
@@ -76,7 +79,7 @@ class ONSConsumerACKInner {
         uv_mutex_unlock(&mutex);
     }
 
-    int WaitResult()
+    COMMON_ACTION WaitResult()
     { 
         uv_mutex_lock(&mutex);
 

src/consumer_listener/base_listener.cpp

@@ -138,7 +138,7 @@ COMMON_ACTION ONSConsumerBaseListener::Consume(Message& message)
     async->data = (void*)param;
     uv_async_send(async);
 
-    int result = ack_inner->WaitResult();
+    COMMON_ACTION result = ack_inner->WaitResult();
 
     async->data = NULL;
     param->ons = NULL;
@@ -159,7 +159,7 @@ COMMON_ACTION ONSConsumerBaseListener::Consume(Message& message)
     // restore `uv_async_t` object
     RestoreAsync(async);
 
-    return (COMMON_ACTION)result;
+    return result;
 }
 
 }

src/consumer_listener/order_consumer_listener.cpp

@@ -31,5 +31,7 @@ ONSOrderConsumerListener::~ONSOrderConsumerListener()
 
 OrderAction ONSOrderConsumerListener::consume(Message& message, ConsumeOrderContext& context)
 {
-    return (OrderAction)ONSConsumerBaseListener::Consume(message);
+    return ONSConsumerBaseListener::Consume(message) == COMMON_ACTION::SUCCESS ?
+        OrderAction::Success :
+        OrderAction::Suspend;
 }

src/consumer_listener/push_consumer_listener.cpp

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer_listener.cpp
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  Consumer listener class and function
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2016/07/13 15时15分32秒
- *       Revision:  none
- *       Compiler:  g++
- *
- *         Author:  XadillaX (zkd), i@2333.moe
- *   Organization:  Design & Development Center, Souche Inc. CHINA
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #include "push_consumer_listener.h"
 
@@ -28,5 +31,7 @@ ONSPushConsumerListener::~ONSPushConsumerListener()
 
 Action ONSPushConsumerListener::consume(Message& message, ConsumeContext& context)
 {
-    return (Action)ONSConsumerBaseListener::Consume(message);
+    return ONSConsumerBaseListener::Consume(message) == COMMON_ACTION::SUCCESS ?
+        Action::CommitMessage :
+        Action::ReconsumeLater;
 }

src/consumer_listener/push_consumer_listener.h

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer_listener.h
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  Consumer listener class and function
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2016/07/13 15时14分09秒
- *       Revision:  none
- *       Compiler:  g++
- *
- *         Author:  XadillaX (zkd), i@2333.moe
- *   Organization:  Design & Development Center, Souche Inc. CHINA
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #ifndef __CONSUMER_LISTENER_H__
 #define __CONSUMER_LISTENER_H__

src/consumer_workers/consumer_prepare_worker.h

@@ -1,19 +1,22 @@
-/*
- * =====================================================================================
+/**
+ *            ___
+ *      |     | |
+ *     / \    | |
+ *    |--o|===|-|
+ *    |---|   |n|
+ *   /     \  |o|
+ *  | O     | |d|
+ *  | N     |=|e|
+ *  | S     | | |
+ *  |_______| |_|
+ *   |@| |@|  | |
+ * ___________|_|_
  *
- *       Filename:  consumer_prepare_worker.h
+ * AliyunONS - Node.js SDK for Aliyun ONS (based on RocketMQ)
  *
- *    Description:  Prepare worker for consumer
+ * Copyright (c) 2016 XadillaX <i@2333.moe>
  *
- *        Version:  1.0
- *        Created:  2016/07/13 15时10分46秒
- *       Revision:  none
- *       Compiler:  g++
- *
- *         Author:  XadillaX (zkd), i@2333.moe
- *   Organization:  Design & Development Center, Souche Inc. CHINA
- *
- * =====================================================================================
+ * MIT LIcense <https://github.com/XadillaX/aliyun-ons/blob/master/LICENSE>
  */
 #ifndef __CONSUMER_PREPARE_WORKER_H__
 #define __CONSUMER_PREPARE_WORKER_H__