Skip to content

Commit 2da878c

Browse files
committed
Add SqsConsumer methods to SnsQsConsumer
1 parent 856839e commit 2da878c

File tree

1 file changed

+28
-0
lines changed

1 file changed

+28
-0
lines changed

pkg/snsqs/SnsQsConsumer.php

+28
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,34 @@ public function __construct(SnsQsContext $context, SqsConsumer $consumer, SnsQsQ
3535
$this->queue = $queue;
3636
}
3737

38+
public function getVisibilityTimeout(): ?int
39+
{
40+
return $this->consumer->getVisibilityTimeout();
41+
}
42+
43+
/**
44+
* The duration (in seconds) that the received messages are hidden from subsequent retrieve
45+
* requests after being retrieved by a ReceiveMessage request.
46+
*/
47+
public function setVisibilityTimeout(int $visibilityTimeout = null): void
48+
{
49+
$this->consumer->setVisibilityTimeout($visibilityTimeout);
50+
}
51+
52+
public function getMaxNumberOfMessages(): int
53+
{
54+
return $this->consumer->getMaxNumberOfMessages();
55+
}
56+
57+
/**
58+
* The maximum number of messages to return. Amazon SQS never returns more messages than this value
59+
* (however, fewer messages might be returned). Valid values are 1 to 10. Default is 1.
60+
*/
61+
public function setMaxNumberOfMessages(int $maxNumberOfMessages): void
62+
{
63+
$this->consumer->setMaxNumberOfMessages($maxNumberOfMessages);
64+
}
65+
3866
public function getQueue(): Queue
3967
{
4068
return $this->queue;

0 commit comments

Comments
 (0)