File tree Expand file tree Collapse file tree
src/Motor.Extensions.Hosting.PgMq/Options Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -3,9 +3,22 @@ namespace Motor.Extensions.Hosting.PgMq.Options;
33// ReSharper disable once UnusedTypeParameter
44public record PgMqConsumerOptions : PgOptions
55{
6+ /// <summary>
7+ /// The visibility timeout is the amount of time a message is invisible to other consumers
8+ /// after it has been read by a consumer. If the message is NOT deleted or archived within
9+ /// the visibility timeout, it will become visible again and can be read by another consumer.
10+ /// </summary>
611 public int VisibilityTimeoutInSeconds { get ; init ; } = 300 ;
712
13+ /// <summary>
14+ /// Maximum duration of the long-polling operation.
15+ /// 5 is the default, same as in the upstream library.
16+ /// </summary>
817 public int PollTimeoutSeconds { get ; init ; } = 5 ;
918
10- public int PollIntervalMilliseconds { get ; init ; } = 5000 ;
19+ /// <summary>
20+ /// Delay between internal postgres checks of the queue.
21+ /// 250 is the default, same as in the upstream library.
22+ /// </summary>
23+ public int PollIntervalMilliseconds { get ; init ; } = 250 ;
1124}
You can’t perform that action at this time.
0 commit comments