Skip to content

Commit 3431e7c

Browse files
callmehiphopsduskis
authored andcommitted
fix(subscription)!: decouple retainAckedMessages from messageRetentionDuration (#625)
* fix(subscription)!: decouple retainAckedMessages from messageRetentionDuration * remove system-test assertions
1 parent 2167536 commit 3431e7c

File tree

3 files changed

+0
-4
lines changed

3 files changed

+0
-4
lines changed

src/subscription.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1026,7 +1026,6 @@ export class Subscription extends EventEmitter {
10261026
const formatted = extend(true, {}, metadata);
10271027

10281028
if (typeof metadata.messageRetentionDuration === 'number') {
1029-
formatted.retainAckedMessages = true;
10301029
(formatted as google.pubsub.v1.ISubscription).messageRetentionDuration = {
10311030
seconds: metadata.messageRetentionDuration,
10321031
nanos: 0,

system-test/pubsub.ts

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -339,7 +339,6 @@ describe('pubsub', () => {
339339
sub!.getMetadata((err, metadata) => {
340340
assert.ifError(err);
341341

342-
assert.strictEqual(metadata!.retainAckedMessages, true);
343342
assert.strictEqual(
344343
Number(metadata!.messageRetentionDuration!.seconds),
345344
threeDaysInSeconds
@@ -371,7 +370,6 @@ describe('pubsub', () => {
371370
.then(([metadata]) => {
372371
const {seconds, nanos} = metadata.messageRetentionDuration!;
373372

374-
assert.strictEqual(metadata.retainAckedMessages, true);
375373
assert.strictEqual(Number(seconds), threeDaysInSeconds);
376374
assert.strictEqual(Number(nanos), 0);
377375
});

test/subscription.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -227,7 +227,6 @@ describe('Subscription', () => {
227227

228228
const formatted = Subscription.formatMetadata_(metadata);
229229

230-
assert.strictEqual(formatted.retainAckedMessages, true);
231230
assert.strictEqual(formatted.messageRetentionDuration!.nanos, 0);
232231

233232
assert.strictEqual(

0 commit comments

Comments
 (0)