harcon-amqp - npm Package Compare versions

Comparing version 1.2.1 to 1.2.2

lib/AmqpBarrel.js

@@ -37,2 +37,5 @@ 'use strict'
 	socket.on('data', function ( message ) {
+		if ( self.expAck )
+			socket.ack()
+
 		var comm = JSON.parse( message )
@@ -46,4 +49,2 @@
 		if ( !interested ) return false
-		if ( self.expAck )
-			socket.ack()
 		self.innerProcessAmqp( comm )
@@ -93,3 +94,3 @@ } )
 	self.connectURL = config.connectURL || 'amqp://localhost'
-	self.socketType = config.socketType || 'PUSHWORKER' // PUSHWORKER || PUBSUB || PUSHPULL
+	self.socketType = config.socketType || 'PUBSUB' // PUSHWORKER || PUBSUB || PUSHPULL
 	self.expAck = self.socketType === 'PUSHWORKER'
@@ -96,0 +97,0 @@ self.quiteMode = self.socketType === 'PUBSUB'

package.json

 {
   "name": "harcon-amqp",
-  "version": "1.2.1",
+  "version": "1.2.2",
   "description": "AMQP plugin for the harcon messaging/service bus of node-based enterprise entities.",
@@ -5,0 +5,0 @@ "keywords": [

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

27620

decreased by-0.01%

No dependency changes