Skip to content

Commit ebd34b8

Browse files
committed
Add setting subscription attributes to Sns and SnsQs
1 parent 2278fce commit ebd34b8

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

Diff for: SnsQsContext.php

+11
Original file line numberDiff line numberDiff line change
@@ -173,6 +173,17 @@ public function close(): void
173173
$this->getSqsContext()->close();
174174
}
175175

176+
public function setSubscriptionAttributes(SnsQsTopic $topic, SnsQsQueue $queue, array $attributes): void
177+
{
178+
$this->getSnsContext()->setSubscriptionAttributes(new SnsSubscribe(
179+
$topic,
180+
$this->getSqsContext()->getQueueArn($queue),
181+
SnsSubscribe::PROTOCOL_SQS,
182+
false,
183+
$attributes,
184+
));
185+
}
186+
176187
private function getSnsContext(): SnsContext
177188
{
178189
if (null === $this->snsContext) {

0 commit comments

Comments
 (0)