MetadataFilter is a filter for metadata. Right now support only direct matching of key/value
| 238 | c.FiniteConsumption = finiteConsumption |
| 239 | } |
| 240 | } |
| 241 | |
| 242 | // WithoutTableVerification skips the queue table columns/indexes validation |
| 243 | // on Run. Use only when you are certain the table schema is correct; |
| 244 | // missing mandatory indexes cause full-table scans while polling. |
| 245 | func WithoutTableVerification() ConsumerOption { |
| 246 | return func(c *consumerConfig) { |
| 247 | c.SkipTableVerification = true |
nothing calls this directly
no outgoing calls
no test coverage detected