added tests for pull#5

.travis.yml

@@ -6,7 +6,10 @@ language: node_js
 node_js:
   - 0.10
   - 0.12
+  - 4.0
+  - 4.1
+  - 5.0
   - iojs
 before_script:
   - "npm install -g mocha grunt-cli"
-  - "grunt build"
+  - "grunt build"

README.md

@@ -287,6 +287,7 @@ This is an advanced example showing some features in action.
 ## Release History
 |Version|Date|Description|
 |:--:|:--:|:--|
+|0.3.8|2015-11-04|Fixed stop behaviour. [Pull#5](https://github.com/mpneuried/rsmq-worker/pull/5). Thanks to [Exinferis](https://github.com/exinferis)|
 |0.3.7|2015-09-02|Added tests to check the behavior during errors within message processing; Added option `alwaysLogErrors` to prevent console logs if an error event handler was attached. [Issue #3](https://github.com/mpneuried/rsmq-worker/issues/3)|
 |0.3.6|2015-09-02|Updated dependencies; optimized readme (thanks to [Tobias Lidskog](https://github.com/tobli) for the [pull #4](https://github.com/mpneuried/rsmq-worker/pull/4))|
 |0.3.5|2015-04-27|again ... fixed argument dispatch for `.send()`|

_src/test/main.coffee

@@ -89,7 +89,6 @@ describe "----- rsmq-worker TESTS -----", ->
 
 		it "error throw within message processing - Issue #3 (A)", ( done )->
 			_examplemsg = utils.randomString( utils.randRange( 4, 99 ), 3 )
-			_start = Date.now()
 			@timeout( 3000 )
 
 			_testFn = ( msg, next, id )->
@@ -118,7 +117,6 @@ describe "----- rsmq-worker TESTS -----", ->
 
 		it "code error within message processing - Issue #3 (B)", ( done )->
 			_examplemsg = utils.randomString( utils.randRange( 4, 99 ), 3 )
-			_start = Date.now()
 			@timeout( 3000 )
 
 			_testFn = ( msg, next, id )->
@@ -148,6 +146,50 @@ describe "----- rsmq-worker TESTS -----", ->
 				should.not.exist( err )
 				return
 			return
+
+		_examplemsg2 = utils.randomString( utils.randRange( 4, 99 ), 3 )
+		it "test stop method - Pull #5 stop", ( done )->
+			_examplemsg = utils.randomString( utils.randRange( 4, 99 ), 3 )
+			@timeout( 6000 )
+
+			idx = 0
+			_testFn = ( msg, next, id )->
+				idx++
+				if idx <= 1
+					should.equal( msg, _examplemsg )
+					worker.stop()
+					worker.send _examplemsg2, 0, ( err )->
+						should.not.exist( err )
+						return
+					next()
+					return
+				throw new Error( "Got second message" )
+				done()
+				return
+
+			_endFn = ( err, rawmsg )->
+				worker.removeListener( "message", _testFn )
+				done()
+				return
 
+
+			worker.on( "message", _testFn )
+
+			worker.send _examplemsg, 0, ( err )->
+				should.not.exist( err )
+				return
+
+			setTimeout( _endFn, 5000 )
+			return
+
+		it "test stop method - Pull #5 start", ( done )->
+			_testFn = ( msg, next, id )->
+				should.equal( msg, _examplemsg2 )
+				done()
+				return
+
+			worker.on( "message", _testFn )
+			worker.start()
+			return
 		return
 	return