@@ -35,6 +35,34 @@ public function __construct(SnsQsContext $context, SqsConsumer $consumer, SnsQsQ
35
35
$ this ->queue = $ queue ;
36
36
}
37
37
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
+
38
66
public function getQueue (): Queue
39
67
{
40
68
return $ this ->queue ;
0 commit comments