New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

servicebus

Package Overview
Dependencies
Maintainers
2
Versions
73
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

servicebus - npm Package Compare versions

Comparing version 0.2.0 to 0.2.1

2

bus/rabbitmq/bus.js

@@ -137,3 +137,3 @@ var amqp = require('amqp'),

self.initialized = true;
self._publish(queueName, message);
self.publish(queueName, message);
};

@@ -140,0 +140,0 @@ self.connection.on('ready', function() {

@@ -9,3 +9,3 @@ {

"description": "Simple service bus for sending events between processes using amqp.",
"version": "0.2.0",
"version": "0.2.1",
"homepage": "https://github.com/mateodelnorte/servicebus",

@@ -12,0 +12,0 @@ "repository": {

@@ -34,6 +34,6 @@ # servicebus

bus.listen('my.event', { ack: true }, function (event, handle) {
handle.acknowledge(); // acknowledge a message
handle.ack(); // short hand is also available
handle.reject(); // reject a message
bus.listen('my.event', { ack: true }, function (event) {
event.handle.acknowledge(); // acknowledge a message
event.handle.ack(); // short hand is also available
event.handle.reject(); // reject a message
});

@@ -138,2 +138,2 @@

Retry provides ability to specify a max number of times an erroring message will be retried before being placed on an error queue. The retry middleware requires the correlate middleware.
Retry provides ability to specify a max number of times an erroring message will be retried before being placed on an error queue. The retry middleware requires the correlate middleware.
SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc