@google-cloud/pubsub
Advanced tools
Comparing version 0.14.0 to 0.14.1
{ | ||
"name": "@google-cloud/pubsub", | ||
"version": "0.14.0", | ||
"version": "0.14.1", | ||
"author": "Google Inc.", | ||
@@ -38,3 +38,3 @@ "description": "Cloud Pub/Sub Client Library for Node.js", | ||
"CONTRIBUTORS", | ||
"COPYING" | ||
"LICENSE" | ||
], | ||
@@ -41,0 +41,0 @@ "repository": "googlecloudplatform/google-cloud-node", |
@@ -59,2 +59,4 @@ /*! | ||
this.subscription = subscription; | ||
this.projectId = subscription.projectId; | ||
this.connections = new Map(); | ||
@@ -234,3 +236,4 @@ | ||
connection.write({ | ||
subscription: self.subscription.name, | ||
subscription: common.util.replaceProjectIdToken( | ||
self.subscription.name, self.projectId), | ||
streamAckDeadlineSeconds: self.settings.ackDeadline / 1000 | ||
@@ -307,2 +310,6 @@ }); | ||
if (!self.projectId || self.projectId === '{{projectId}}') { | ||
self.projectId = pubsub.auth.projectId; | ||
} | ||
var Subscriber = v1(pubsub.options).Subscriber; | ||
@@ -309,0 +316,0 @@ |
@@ -26,2 +26,3 @@ /*! | ||
var googleAuth = require('google-auto-auth'); | ||
var grpc = require('grpc'); | ||
var is = require('is'); | ||
@@ -295,2 +296,3 @@ | ||
this.options.port = baseUrlParts[1]; | ||
this.options.sslCreds = grpc.credentials.createInsecure(); | ||
}; | ||
@@ -297,0 +299,0 @@ |
@@ -33,2 +33,11 @@ /*! | ||
* publisher. | ||
*/ | ||
/** | ||
* A Publisher object allows you to publish messages to a specific topic. | ||
* | ||
* @constructor | ||
* @alias module:pubsub/publisher | ||
* | ||
* @resource [Topics: publish API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/publish} | ||
* | ||
* @param {object=} options - Configuration object. | ||
@@ -42,11 +51,3 @@ * @param {object} options.batching - Batching settings. | ||
* wait before sending a payload. | ||
*/ | ||
/** | ||
* A Publisher object allows you to publish messages to a specific topic. | ||
* | ||
* @constructor | ||
* @alias module:pubsub/publisher | ||
* | ||
* @resource [Topics: publish API Documentation]{@link https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.topics/publish} | ||
* | ||
* @example | ||
@@ -53,0 +54,0 @@ * var topic = pubsub.topic('my-topic'); |
@@ -150,4 +150,2 @@ /*! | ||
* [Subscription resource](https://cloud.google.com/pubsub/docs/reference/rest/v1/projects.subscriptions) | ||
* @param {number} options.ackDeadline - The maximum time after receiving a | ||
* message that you must ack a message before it is redelivered. | ||
* @param {object} options.flowControl - Flow control configurations for | ||
@@ -154,0 +152,0 @@ * receiving messages. |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
562179
6834
0