bramqp
Advanced tools
Comparing version 0.3.6 to 0.3.7
@@ -9,3 +9,3 @@ # Other Handle Functions | ||
- `password` The password used to log into AMQPLAIN. Defaults to `'guest'`. | ||
- `heartbeat` A boolean which controls if heartbeats are enabled. If set to true, heartbeats are sent at the time suggested by the server. Defaults to `true`. | ||
- `heartbeat` Controls if heartbeats are enabled. If set to `true`, heartbeats are sent at the time suggested by the server. If set to a number, heartbeats are sent at that number of seconds. Defaults to `true`. | ||
- `vhost` The vhost used to open the connection. Defaults to `'/'`. | ||
@@ -24,3 +24,3 @@ - `callback(error)` Called once the content has been written to the socket. | ||
#### handle.closeAMQPCommunication(callback(error)) | ||
- `callback(error)` Called once the content has been written to the socket. | ||
@@ -35,5 +35,5 @@ | ||
#### handle.setFrameMax(frameMax) | ||
- `frameMax` The new largest frame that should be used; | ||
`setFrameMax` updates the size of the buffers used for AMQP communication. Should be called after receiving `connection.tune` method. |
@@ -258,3 +258,10 @@ 'use strict'; | ||
self.setFrameMax(data['frame-max']); | ||
self.connection['tune-ok'](data['channel-max'], data['frame-max'], heartbeat ? data.heartbeat : 0, | ||
if (heartbeat){ | ||
if (heartbeat === true){ | ||
heartbeat = data.heartbeat; | ||
} | ||
} else { | ||
heartbeat = 0; | ||
} | ||
self.connection['tune-ok'](data['channel-max'], data['frame-max'], heartbeat, | ||
function() { | ||
@@ -272,3 +279,3 @@ if (heartbeat && data.heartbeat) { | ||
self.heartbeatsMissed++; | ||
}, data.heartbeat * 1000); | ||
}, heartbeat * 1000); | ||
@@ -275,0 +282,0 @@ self.on('heartbeat', function() { |
{ | ||
"name" : "bramqp", | ||
"version" : "0.3.6", | ||
"version" : "0.3.7", | ||
"description" : "bakkerthehacker's rhythmic AMQP library", | ||
@@ -23,4 +23,4 @@ "keywords" : [ "amqp", "bramqp" ], | ||
"dependencies" : { | ||
"async" : "~1.3.0", | ||
"xml2js" : "~0.4.4", | ||
"async" : "~1.4.2", | ||
"xml2js" : "~0.4.12", | ||
"buffer-more-ints" : "~0.0.2", | ||
@@ -27,0 +27,0 @@ "pkginfo" : "~0.3.0" |
597783
3952
+ Addedasync@1.4.2(transitive)
- Removedasync@1.3.0(transitive)
Updatedasync@~1.4.2
Updatedxml2js@~0.4.12