Releases: googleapis/nodejs-pubsub
Releases · googleapis/nodejs-pubsub
v0.13.0
Features
- #2330 Allow custom endpoints from
options.apiEndpoint
. (Thanks, @mkamioner!)
v0.12.0
v0.11.0
Features
- #2230, #2232: Allow setti
ng a customtimeout
value withtopic.publish()
. (Thanks, @dennismartensson!)
Fixes
- #2242: Set sane defaults for request timeouts.
v0.10.0
v0.9.0
v0.8.1
v0.7.0
⚠️ Breaking Changes!
reuseExisting
option removed
By default, if you provide a subscription name to subscribe()
, a subscription with that name will be created, if necessary.
If you don't provide a name, one will be automatically created.
Before
topic.subscribe('my-subscription', { reuseExisting: true }, function(err, subscription) {
// subscription was either created or re-used
})
After
topic.subscribe('my-subscription', function(err, subscription) {
// subscription was either created or re-used
})
Features
- #1653, #1656: Auto-detect
projectId
. See Authentication for more. - #1257, #1799: Auto-generate subscription names.
- #1837, #1843: Return
timestamp
on all message objects. (Thank you very much, @igorclark!)
v0.6.0
v0.5.0
v0.4.0
⚠️ Breaking Changes
Promises have arrived!
It's been a long time coming, but we're finally here. We've shipped promise support in the Google Cloud Pub/Sub module!
Do I have to use promises?
Nope, carry on. (But keep reading if you use streams)
How do I use promises?
Don't pass a callback:
var pubsub = require('@google-cloud/pubsub')();
pubsub.getTopics()
.then(function(data) {
var topics = data[0];
})
.catch(function(err) {});
How do I use a method as a stream?
All of the streaming functionality from our methods have been moved to their own method.
var pubsub = require('@google-cloud/pubsub')();
- pubsub.getSubscriptions()
+ pubsub.getSubscriptionsStream()
.on('data', function(subscription) {})
- pubsub.getTopics()
+ pubsub.getTopicsStream()
.on('data', function(topic) {})
var topic = pubsub.topic('my-topic-name');
- topic.getSubscriptions()
+ topic.getSubscriptionsStream()
.on('data', function(subscription) {})