Merge a8b9a38 into f532084

mpneuried · May 16, 2019 · 66edd30 · 66edd30
2 parents f532084 + a8b9a38
commit 66edd30
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/_src/lib/rsmq-worker.coffee b/_src/lib/rsmq-worker.coffee
@@ -484,7 +484,7 @@ class RSMQWorker extends require( "mpbasic" )()
 					@emit( "next" ) if _useInterval
 					return
 				try
-					@emit "message", msg.message, _fnNext, _id
+					@emit "message", msg, _fnNext, _id
 				catch _err
 					if not @listeners( "error" )?.length or @config.alwaysLogErrors
 						@error "error", _err

diff --git a/_src/test/main.coffee b/_src/test/main.coffee
@@ -43,7 +43,7 @@ describe "----- rsmq-worker TESTS -----", ->
 
 			_testFn = ( msg, next, id )->
 
-				should.equal( msg, _examplemsg )
+				should.equal( msg.message, _examplemsg )
 				next()
 
 				worker.removeListener( "message", _testFn )
@@ -64,7 +64,7 @@ describe "----- rsmq-worker TESTS -----", ->
 			@timeout( _delay*1.5*1000 )
 			_testFn = ( msg, next, id )->
 
-				should.equal( msg, _examplemsg )
+				should.equal( msg.message, _examplemsg )
 				next()
 				worker.removeListener( "message", _testFn )
 				_diff = Math.round( ( Date.now() - _start )/1000 )
@@ -85,7 +85,7 @@ describe "----- rsmq-worker TESTS -----", ->
 			@timeout( _delay*1.5*1000 )
 			_testFn = ( msg, next, id )->
 
-				should.equal( msg, _examplemsg )
+				should.equal( msg.message, _examplemsg )
 				next()
 				_diff = Math.round( ( Date.now() - _start )/1000 )
 				_diff.should.be.above(_delay)
@@ -124,8 +124,8 @@ describe "----- rsmq-worker TESTS -----", ->
 
 			_idx = 0
 			_testFn = ( msg, next, id )->
-				should.equal( msg, _examplemsgs[ _idx ] )
-				
+				should.equal( msg.message, _examplemsgs[ _idx ] )
+
 				if _idx is 0
 					# stop and wait to check the hidden size
 					setTimeout( _runHiddenSize( next ), 1000 )
@@ -174,7 +174,7 @@ describe "----- rsmq-worker TESTS -----", ->
 
 			_idx = 0
 			_testFn = ( msg, next, id )->
-				should.equal( msg, _examplemsgs[ _idx ] )
+				should.equal( msg.message, _examplemsgs[ _idx ] )
 
 				next()
 
@@ -301,7 +301,7 @@ describe "----- rsmq-worker TESTS -----", ->
 			_testFn = ( msg, next, id )->
 				idx++
 				if idx <= 1
-					should.equal( msg, _examplemsg )
+					should.equal( msg.message, _examplemsg )
 					worker.stop()
 					worker.send _examplemsg2, 0, ( err )->
 						should.not.exist( err )
@@ -329,7 +329,7 @@ describe "----- rsmq-worker TESTS -----", ->
 
 		it "test stop method - Pull #5 start", ( done )->
 			_testFn = ( msg, next, id )->
-				should.equal( msg, _examplemsg2 )
+				should.equal( msg.message, _examplemsg2 )
 				done()
 				return