Skip to content

Commit

Permalink
fix(subscription)!: decouple retainAckedMessages from messageRetentio…
Browse files Browse the repository at this point in the history
…nDuration (#625)

* fix(subscription)!: decouple retainAckedMessages from messageRetentionDuration

* remove system-test assertions
  • Loading branch information
callmehiphop authored and sduskis committed May 23, 2019
1 parent 2167536 commit 3431e7c
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 4 deletions.
1 change: 0 additions & 1 deletion src/subscription.ts
Original file line number Diff line number Diff line change
Expand Up @@ -1026,7 +1026,6 @@ export class Subscription extends EventEmitter {
const formatted = extend(true, {}, metadata);

if (typeof metadata.messageRetentionDuration === 'number') {
formatted.retainAckedMessages = true;
(formatted as google.pubsub.v1.ISubscription).messageRetentionDuration = {
seconds: metadata.messageRetentionDuration,
nanos: 0,
Expand Down
2 changes: 0 additions & 2 deletions system-test/pubsub.ts
Original file line number Diff line number Diff line change
Expand Up @@ -339,7 +339,6 @@ describe('pubsub', () => {
sub!.getMetadata((err, metadata) => {
assert.ifError(err);

assert.strictEqual(metadata!.retainAckedMessages, true);
assert.strictEqual(
Number(metadata!.messageRetentionDuration!.seconds),
threeDaysInSeconds
Expand Down Expand Up @@ -371,7 +370,6 @@ describe('pubsub', () => {
.then(([metadata]) => {
const {seconds, nanos} = metadata.messageRetentionDuration!;

assert.strictEqual(metadata.retainAckedMessages, true);
assert.strictEqual(Number(seconds), threeDaysInSeconds);
assert.strictEqual(Number(nanos), 0);
});
Expand Down
1 change: 0 additions & 1 deletion test/subscription.ts
Original file line number Diff line number Diff line change
Expand Up @@ -227,7 +227,6 @@ describe('Subscription', () => {

const formatted = Subscription.formatMetadata_(metadata);

assert.strictEqual(formatted.retainAckedMessages, true);
assert.strictEqual(formatted.messageRetentionDuration!.nanos, 0);

assert.strictEqual(
Expand Down

0 comments on commit 3431e7c

Please sign in to comment.